(iotdb) branch ty/mysql-connector updated: Change

[jackietien]

This is an automated email from the ASF dual-hosted git repository.

jackietien pushed a commit to branch ty/mysql-connector
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/ty/mysql-connector by this 
push:
     new 8aca99dc2b2 Change
8aca99dc2b2 is described below

commit 8aca99dc2b25082d9a46d7a6892dbb99d1e2f62c
Author: JackieTien97 <jackietie...@gmail.com>
AuthorDate: Fri Jun 6 17:46:31 2025 +0800

    Change
---
 .../plan/relational/function/tvf/connector/JDBCConnectionPool.java  | 6 ++++++
 .../function/tvf/connector/MySqlConnectorTableFunction.java         | 2 +-
 2 files changed, 7 insertions(+), 1 deletion(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/tvf/connector/JDBCConnectionPool.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/tvf/connector/JDBCConnectionPool.java
index 2f7d0c8d821..ecd1ff92cb0 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/tvf/connector/JDBCConnectionPool.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/tvf/connector/JDBCConnectionPool.java
@@ -43,6 +43,9 @@ public class JDBCConnectionPool {
       case java.sql.Types.FLOAT:
         return Type.FLOAT;
       case java.sql.Types.DOUBLE:
+      case java.sql.Types.REAL:
+      case java.sql.Types.NUMERIC:
+      case java.sql.Types.DECIMAL:
         return Type.DOUBLE;
       case java.sql.Types.CHAR:
       case java.sql.Types.VARCHAR:
@@ -79,6 +82,9 @@ public class JDBCConnectionPool {
       case java.sql.Types.FLOAT:
         return new FloatConverter();
       case java.sql.Types.DOUBLE:
+      case java.sql.Types.REAL:
+      case java.sql.Types.NUMERIC:
+      case java.sql.Types.DECIMAL:
         return new DoubleConverter();
       case java.sql.Types.CHAR:
       case java.sql.Types.VARCHAR:
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/tvf/connector/MySqlConnectorTableFunction.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/tvf/connector/MySqlConnectorTableFunction.java
index 3981d290b10..5086370ae01 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/tvf/connector/MySqlConnectorTableFunction.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/tvf/connector/MySqlConnectorTableFunction.java
@@ -102,7 +102,7 @@ public class MySqlConnectorTableFunction implements 
TableFunction {
 
   private static final String SQL = "SQL";
   private static final String URL = "URL";
-  private static final String DEFAULT_URL = 
"jdbc:mysql://localhost:3306/test?";
+  private static final String DEFAULT_URL = "jdbc:mysql://localhost:3306";
   private static final String USERNAME = "USERNAME";
   private static final String DEFAULT_USERNAME = "root";
   private static final String PASSWORD = "PASSWORD";