transactionLog 数据清洗 main类修改123456789

src/main/java/cn/quantgroup/dbc/utils/JdbcExecuters.java

@@ -168,6 +168,7 @@ public class JdbcExecuters {
             conn = HIK_DATA_SOURCE.dataSource.getConnection();
             ps = conn.prepareStatement(sql);
             conn.setAutoCommit(false);
+            System.out.println("执行插入操作开始");
             for (int i = 0; i < transactionLogs.size(); i++) {
                 TransactionLog transactionLog = transactionLogs.get(i);
                 ps.setString(1, "");
@@ -181,6 +182,7 @@ public class JdbcExecuters {
             }
             ps.executeBatch();
             conn.commit();
+            System.out.println("执行插入操作结束");
         }catch(Exception e){
             System.out.println("======执行sqlException异常======"+sql+"\r\n");
             System.out.println("");