'commit'

src/main/java/Tools/XT_SyncData2022.java

@@ -8,6 +8,7 @@ import com.jfinal.plugin.activerecord.Record;
 import com.jfinal.plugin.activerecord.dialect.PostgreSqlDialect;
 import com.jfinal.plugin.druid.DruidPlugin;
 
+import java.util.ArrayList;
 import java.util.HashSet;
 import java.util.List;
 import java.util.Set;
@@ -24,8 +25,8 @@ public class XT_SyncData2022 {
         arp1.start();
 
         //写入库
-        DruidPlugin druid2 = new DruidPlugin("jdbc:postgresql://10.10.14.231:5432/eduData_xt", "postgres",
+        DruidPlugin druid2 = new DruidPlugin("jdbc:postgresql://www.wmarkj.com:27027/eduData_db", "postgres",
-                "dsideal", "org.postgresql.Driver");
+                "DsideaL147258369", "org.postgresql.Driver");
         druid2.start();
         ActiveRecordPlugin arp2 = new ActiveRecordPlugin("target", druid2);
         arp2.setDialect(new PostgreSqlDialect());
@@ -53,7 +54,7 @@ public class XT_SyncData2022 {
             }
 
             List<Record> list = Db.use("source").findAll(tableName);
-
+            List<Record> writeList = new ArrayList<>();
             int cnt = 0;
             for (Record sourceRecord : list) {
                 cnt++;
@@ -75,10 +76,11 @@ public class XT_SyncData2022 {
                     rWrite.set(str, "");//加上默认值
                 }
                 rWrite.set("recordyear", 2022);
-                //3、保存
+                writeList.add(rWrite);
-                Db.use("target").save(tableName, "id", rWrite);
-                System.out.println("正在处理表【" + tableName + "】,第" + cnt + "条数据,当前表共" + list.size() + "条。");
             }
+            //3、保存
+            System.out.println(CommonUtil.GetCurrentTimeString() + " 正在处理表【" + tableName + "】,当前表共" + writeList.size() + "条。");
+            Db.use("target").batchSave(tableName, writeList, 200);
         }
         CommonUtil.printf("恭喜，所有导入工作成功完成！");
     }