You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2025/06/27 01:35:51 UTC
(iotdb) branch ty/mysql-connector updated: format code
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 39e38c18bb5 format code
39e38c18bb5 is described below
commit 39e38c18bb57a818bc615b53cb19ad3b8ded6f81
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Fri Jun 27 09:35:34 2025 +0800
format code
---
.../function/tvf/connector/JDBCConnectionPool.java | 13 ++++++++++++-
.../function/tvf/connector/MySqlConnectorTableFunction.java | 7 ++++++-
2 files changed, 18 insertions(+), 2 deletions(-)
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 ecd1ff92cb0..612d548079f 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
@@ -1,7 +1,18 @@
package org.apache.iotdb.db.queryengine.plan.relational.function.tvf.connector;
import org.apache.iotdb.db.exception.sql.SemanticException;
-import org.apache.iotdb.db.queryengine.plan.relational.function.tvf.connector.converter.*;
+import org.apache.iotdb.db.queryengine.plan.relational.function.tvf.connector.converter.BinaryConverter;
+import org.apache.iotdb.db.queryengine.plan.relational.function.tvf.connector.converter.BlobConverter;
+import org.apache.iotdb.db.queryengine.plan.relational.function.tvf.connector.converter.BooleanConverter;
+import org.apache.iotdb.db.queryengine.plan.relational.function.tvf.connector.converter.DateConverter;
+import org.apache.iotdb.db.queryengine.plan.relational.function.tvf.connector.converter.DoubleConverter;
+import org.apache.iotdb.db.queryengine.plan.relational.function.tvf.connector.converter.FloatConverter;
+import org.apache.iotdb.db.queryengine.plan.relational.function.tvf.connector.converter.Int32Converter;
+import org.apache.iotdb.db.queryengine.plan.relational.function.tvf.connector.converter.Int64Converter;
+import org.apache.iotdb.db.queryengine.plan.relational.function.tvf.connector.converter.ResultSetConverter;
+import org.apache.iotdb.db.queryengine.plan.relational.function.tvf.connector.converter.StringConverter;
+import org.apache.iotdb.db.queryengine.plan.relational.function.tvf.connector.converter.TimeConverter;
+import org.apache.iotdb.db.queryengine.plan.relational.function.tvf.connector.converter.TimestampConverter;
import org.apache.iotdb.udf.api.type.Type;
import org.slf4j.Logger;
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 5086370ae01..2fe02b72bdd 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
@@ -25,7 +25,12 @@ import org.apache.tsfile.utils.ReadWriteIOUtils;
import java.io.DataOutputStream;
import java.io.IOException;
import java.nio.ByteBuffer;
-import java.sql.*;
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.ResultSetMetaData;
+import java.sql.SQLException;
+import java.sql.Statement;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;