[Bug-#1913][chunjun-connector-jdbc-base] clickhouse jdbc connection a…

…re not Not supporting transactions.
DTStack · Aug 12, 2024 · b1c92a8 · b1c92a8
1 parent 284c84f
commit b1c92a8
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/...or-jdbc-base/src/main/java/com/dtstack/chunjun/connector/jdbc/source/JdbcInputFormat.java b/...or-jdbc-base/src/main/java/com/dtstack/chunjun/connector/jdbc/source/JdbcInputFormat.java
@@ -25,6 +25,7 @@
 import com.dtstack.chunjun.connector.jdbc.util.key.KeyUtil;
 import com.dtstack.chunjun.constants.Metrics;
 import com.dtstack.chunjun.enums.ColumnType;
+import com.dtstack.chunjun.enums.Semantic;
 import com.dtstack.chunjun.metrics.BigIntegerAccumulator;
 import com.dtstack.chunjun.metrics.StringAccumulator;
 import com.dtstack.chunjun.restore.FormatState;
@@ -105,7 +106,9 @@ public void openInternal(InputSplit inputSplit) {
         String querySQL = null;
         try {
             dbConn = getConnection();
-            dbConn.setAutoCommit(false);
+            if (Semantic.getByName(config.getSemantic()) == Semantic.EXACTLY_ONCE) {
+                dbConn.setAutoCommit(false);
+            }
 
             querySQL = buildQuerySql(currentJdbcInputSplit);
             jdbcConfig.setQuerySql(querySQL);