Feat(mysql-event-listener): Add user and password config to MySQL event listener

Allow configuring MySQL credentials for the event listener using separate mysql-event-listener.db.user and mysql-event-listener.db.password properties. This makes it easier and safer to provide credentials, especially when passwords contain special characters, and aligns with the configuration style of other Trino connectors. The connection logic now uses these properties if provided, falling back to credentials in the JDBC URL if not set.

Author: danielbelchior

docs/src/main/sphinx/admin/event-listeners-mysql.md

@@ -66,5 +66,12 @@ string, user, catalog, and others with information about the query processing.
 * - Property name
   - Description
 * - `mysql-event-listener.db.url`
-  - JDBC connection URL to the database including credentials
+  - Fully qualified JDBC connection URL used to connect to the MySQL database.
+    Credentials can be embedded in the URL if `user` and `password` are not specified separately
+* - `mysql-event-listener.db.user`
+  - Username used for authenticating the JDBC connection to the MySQL database.
+    Ignored if credentials are included in the `URL`
+* - `mysql-event-listener.db.password`
+  - Password used for authenticating the JDBC connection to the MySQL database.
+    Ignored if credentials are included in the `URL`
 :::

plugin/trino-mysql-event-listener/src/main/java/io/trino/plugin/eventlistener/mysql/MysqlEventListenerConfig.java

@@ -24,13 +24,41 @@
 public class MysqlEventListenerConfig
 {
     private String url;
+    private String user;
+    private String password;
 
     @NotNull
     public String getUrl()
     {
         return url;
     }
 
+    public String getUser()
+    {
+        return user;
+    }
+
+    @ConfigSecuritySensitive
+    @Config("mysql-event-listener.db.user")
+    public MysqlEventListenerConfig setUser(String user)
+    {
+        this.user = user;
+        return this;
+    }
+
+    public String getPassword()
+    {
+        return password;
+    }
+
+    @ConfigSecuritySensitive
+    @Config("mysql-event-listener.db.password")
+    public MysqlEventListenerConfig setPassword(String password)
+    {
+        this.password = password;
+        return this;
+    }
+
     @ConfigSecuritySensitive
     @Config("mysql-event-listener.db.url")
     public MysqlEventListenerConfig setUrl(String url)

plugin/trino-mysql-event-listener/src/main/java/io/trino/plugin/eventlistener/mysql/MysqlEventListenerFactory.java

@@ -90,7 +90,16 @@ public void configure(Binder binder)
         @Provides
         public ConnectionFactory createConnectionFactory(MysqlEventListenerConfig config)
         {
-            return () -> new Driver().connect(config.getUrl(), new Properties());
+            return () -> {
+                Properties properties = new Properties();
+                if (config.getUser() != null) {
+                    properties.setProperty("user", config.getUser());
+                }
+                if (config.getPassword() != null) {
+                    properties.setProperty("password", config.getPassword());
+                }
+                return new Driver().connect(config.getUrl(), properties);
+            };
         }
 
         @Singleton

plugin/trino-mysql-event-listener/src/test/java/io/trino/plugin/eventlistener/mysql/TestMysqlEventListenerConfig.java

@@ -28,17 +28,23 @@ final class TestMysqlEventListenerConfig
     void testDefaults()
     {
         assertRecordedDefaults(recordDefaults(MysqlEventListenerConfig.class)
-                .setUrl(null));
+                .setUrl(null)
+                .setUser(null)
+                .setPassword(null));
     }
 
     @Test
     void testExplicitPropertyMappings()
     {
         Map<String, String> properties = Map.of(
-                "mysql-event-listener.db.url", "jdbc:mysql://example.net:3306");
+                "mysql-event-listener.db.url", "jdbc:mysql://example.net:3306",
+                "mysql-event-listener.db.user", "user",
+                "mysql-event-listener.db.password", "password");
 
         MysqlEventListenerConfig expected = new MysqlEventListenerConfig()
-                .setUrl("jdbc:mysql://example.net:3306");
+                .setUrl("jdbc:mysql://example.net:3306")
+                .setUser("user")
+                .setPassword("password");
 
         assertFullMapping(properties, expected);
     }