修改Dameng 赋值bug

seatunnel-datasource/seatunnel-datasource-plugins/datasource-jdbc-dameng/src/main/java/org/apache/seatunnel/datasource/plugin/demeng/jdbc/DamengJdbcDataSourceChannel.java

@@ -249,10 +249,10 @@ public class DamengJdbcDataSourceChannel implements DataSourceChannelExt {
             throws SQLException, ClassNotFoundException {
         checkNotNull(requestParams.get(DamengOptionRule.DRIVER.key()));
         checkNotNull(requestParams.get(DamengOptionRule.URL.key()), "Jdbc url cannot be null");
-        String url = DamengOptionRule.URL.key();
+        String url = requestParams.get(DamengOptionRule.URL.key());
+        String username = requestParams.get(DamengOptionRule.USER.key());
+        String password = requestParams.get(DamengOptionRule.PASSWORD.key());
         if (requestParams.containsKey(DamengOptionRule.USER.key())) {
-            String username = requestParams.get(DamengOptionRule.USER.key());
-            String password = requestParams.get(DamengOptionRule.PASSWORD.key());
 
             Class.forName(DamengOptionRule.DriverType.DEMENG.getDriverClassName());
             Connection conn = DriverManager.getConnection(url, username, password);
@@ -260,7 +260,7 @@ public class DamengJdbcDataSourceChannel implements DataSourceChannelExt {
             return conn;
         }
         Class.forName(DamengOptionRule.DriverType.DEMENG.getDriverClassName());
-        Connection conn = DriverManager.getConnection(url, "SYSDBA", null);
+        Connection conn = DriverManager.getConnection(url, "SYSDBA", password);
         conn.setAutoCommit(true);
         return conn;
     }