diff --git a/src/main/java/Tools/XT_SyncData2022.java b/src/main/java/Tools/XT_SyncData2022.java index 4b733a0..50a49cb 100644 --- a/src/main/java/Tools/XT_SyncData2022.java +++ b/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", - "dsideal", "org.postgresql.Driver"); + DruidPlugin druid2 = new DruidPlugin("jdbc:postgresql://www.wmarkj.com:27027/eduData_db", "postgres", + "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 list = Db.use("source").findAll(tableName); - + List 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、保存 - Db.use("target").save(tableName, "id", rWrite); - System.out.println("正在处理表【" + tableName + "】,第" + cnt + "条数据,当前表共" + list.size() + "条。"); + writeList.add(rWrite); } + //3、保存 + System.out.println(CommonUtil.GetCurrentTimeString() + " 正在处理表【" + tableName + "】,当前表共" + writeList.size() + "条。"); + Db.use("target").batchSave(tableName, writeList, 200); } CommonUtil.printf("恭喜,所有导入工作成功完成!"); }