transactionLog 数据清洗 main类修改1234

src/main/java/cn/quantgroup/dbc/spark/transactionlog/CleanningTransactionLogMain.java

 package cn.quantgroup.dbc.spark.transactionlog;
 
 import cn.quantgroup.dbc.utils.JdbcExecuters;
-import cn.quantgroup.dbc.utils.PagingUtil;
 import com.alibaba.fastjson.JSON;
 import org.apache.spark.sql.Dataset;
 import org.apache.spark.sql.SparkSession;
@@ -9,9 +8,6 @@ import org.apache.spark.sql.SparkSession;
 import java.sql.Timestamp;
 import java.text.SimpleDateFormat;
 import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.List;
-import java.util.Map;
 
 /**
  * @Author fengjunkai
@@ -49,7 +45,7 @@ public class CleanningTransactionLogMain {
                     transactionLog.setUpdated_at(timestamp);
 
                     if (transactionLogs.size() != 0 && transactionLogs.size() % 200 == 0) {
-//                        JdbcExecuters.prepareBatchUpdateExecuteTransactionid(sql, transactionLogs);
+                        JdbcExecuters.prepareBatchUpdateExecuteTransactionid(sql, transactionLogs);
                         System.out.println("执行sql集合: "+JSON.toJSONString(transactionLogs));
                         transactionLogs.clear();
                     }
@@ -58,7 +54,7 @@ public class CleanningTransactionLogMain {
                     e.printStackTrace();
                 }
             });
-//            JdbcExecuters.prepareBatchUpdateExecuteTransactionid(sql, transactionLogs);
+            JdbcExecuters.prepareBatchUpdateExecuteTransactionid(sql, transactionLogs);
         });
 
         ss.stop();