[hotfix-35535][impala] 修复因为代码合并导致release代码无法编译

Author: FlechazoW

impala/impala-sink/src/main/java/com/dtstack/flink/sql/sink/impala/ImpalaOutputFormat.java

@@ -19,13 +19,13 @@
 package com.dtstack.flink.sql.sink.impala;
 
 import com.dtstack.flink.sql.classloader.ClassLoaderManager;
+import com.dtstack.flink.sql.core.rdb.util.JdbcConnectionUtil;
 import com.dtstack.flink.sql.exception.ExceptionTrace;
 import com.dtstack.flink.sql.factory.DTThreadFactory;
 import com.dtstack.flink.sql.outputformat.AbstractDtRichOutputFormat;
 import com.dtstack.flink.sql.sink.rdb.JDBCTypeConvertUtils;
 import com.dtstack.flink.sql.table.AbstractTableInfo;
 import com.dtstack.flink.sql.util.DtStringUtil;
-import com.dtstack.flink.sql.util.JDBCUtils;
 import com.dtstack.flink.sql.util.KrbUtils;
 import com.google.common.collect.Maps;
 import org.apache.commons.collections.CollectionUtils;
@@ -283,8 +283,8 @@ private void executeUpdateBatch() throws SQLException {
             rows.clear();
         } catch (Exception e) {
             LOG.debug("impala jdbc execute batch error ", e);
-            JDBCUtils.rollBack(connection);
-            JDBCUtils.commit(connection);
+            JdbcConnectionUtil.rollBack(connection);
+            JdbcConnectionUtil.commit(connection);
             updateStatement.clearBatch();
             executeUpdate(connection);
         }
@@ -295,10 +295,10 @@ public void executeUpdate(Connection connection) {
             try {
                 setRecordToStatement(updateStatement, JDBCTypeConvertUtils.getSqlTypeFromFieldType(fieldTypes), row);
                 updateStatement.executeUpdate();
-                JDBCUtils.commit(connection);
+                JdbcConnectionUtil.commit(connection);
             } catch (Exception e) {
-                JDBCUtils.rollBack(connection);
-                JDBCUtils.commit(connection);
+                JdbcConnectionUtil.rollBack(connection);
+                JdbcConnectionUtil.commit(connection);
                 if (metricOutputFormat.outDirtyRecords.getCount() % DIRTY_DATA_PRINT_FREQUENCY == 0 || LOG.isDebugEnabled()) {
                     LOG.error("record insert failed ,this row is {}", row.toString());
                     LOG.error("", e);
@@ -510,16 +510,16 @@ private void dealBatchSqlError(List<String> rowData,
                                    Statement statement,
                                    String templateSql) {
         String errorMsg = "Insert into impala error. \nCause: [%s]\nRow: [%s]";
-        JDBCUtils.rollBack(connection);
-        JDBCUtils.commit(connection);
+        JdbcConnectionUtil.rollBack(connection);
+        JdbcConnectionUtil.commit(connection);
         for (String rowDatum : rowData) {
             String executeSql = templateSql.replace(VALUES_CONDITION, rowDatum);
             try {
                 statement.execute(executeSql);
-                JDBCUtils.commit(connection);
+                JdbcConnectionUtil.commit(connection);
             } catch (SQLException e) {
-                JDBCUtils.rollBack(connection);
-                JDBCUtils.commit(connection);
+                JdbcConnectionUtil.rollBack(connection);
+                JdbcConnectionUtil.commit(connection);
                 if (metricOutputFormat.outDirtyRecords.getCount() % DIRTY_DATA_PRINT_FREQUENCY == 0 || LOG.isDebugEnabled()) {
                     LOG.error(
                         String.format(