#1818 sql jdbc et

Author: wangcheng15

streamingpro-core/src/main/java/streaming/core/datasource/JDBCUtils.scala

@@ -1,9 +1,9 @@
 package streaming.core.datasource
 
 import java.sql.ResultSet
-
 import org.apache.spark.sql.mlsql.session.MLSQLException
 
+import java.util.Properties
 import scala.collection.mutable
 import scala.collection.mutable.ArrayBuffer
 
@@ -38,7 +38,13 @@ object JDBCUtils {
     val driver = options("driver")
     val url = options("url")
     Class.forName(driver)
-    val connection = java.sql.DriverManager.getConnection(url, options("user"), options("password"))
+
+    val infos = new Properties()
+    options.foreach(item => {
+      infos.put(item._1, item._2)
+    })
+    val connection = java.sql.DriverManager.getConnection(url, infos)
+
     try {
       options.get("driver-statement-query").map { sql =>
         val stat = connection.prepareStatement(sql)