zm/nuttyreading-java
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

数据合并

Browse Source
This commit is contained in:
wuchunlei
2024-05-15 16:45:27 +08:00
parent 3c7c6e72e8
commit 40ab36a0dd
1 changed files with 9 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/main/java/com/peanut/common/utils/DataMigrationUtil.java
View File

@@ -30,7 +30,7 @@ public class DataMigrationUtil extends Thread {
// courseCatalogueChapter(); // courseCatalogueChapter();
// courseCatalogueChapterVideo(); // courseCatalogueChapterVideo();
// user();//用的都是copy表里的数据 // user();//用的都是copy表里的数据
//TRUNCATE
} }
@@ -48,6 +48,9 @@ public class DataMigrationUtil extends Thread {
Map map = new HashMap(); Map map = new HashMap();
map.put("oid",resultSet.getString("oid")); map.put("oid",resultSet.getString("oid"));
map.put("title",resultSet.getString("title")); map.put("title",resultSet.getString("title"));
map.put("sort",resultSet.getString("orderNo"));
map.put("image",resultSet.getString("thumbnail"));
map.put("content",resultSet.getString("introduceTxt"));
map.put("createDate",resultSet.getString("createDate")); map.put("createDate",resultSet.getString("createDate"));
list.add(map); list.add(map);
} }
@@ -62,11 +65,14 @@ public class DataMigrationUtil extends Thread {
connection.setAutoCommit(false); connection.setAutoCommit(false);
System.out.println("===== 开始插入数据 ====="); System.out.println("===== 开始插入数据 =====");
long startTime = System.currentTimeMillis(); long startTime = System.currentTimeMillis();
PreparedStatement preparedStatement = connection.prepareStatement("INSERT ignore INTO course (uid,title,create_time) VALUES ( ?, ?, ?)"); PreparedStatement preparedStatement = connection.prepareStatement("INSERT ignore INTO course_copy1 (uid,title,sort,image,content,create_time) VALUES ( ?, ?, ?, ?, ?, ?)");
for (int i = 0; i < list.size(); i++) { for (int i = 0; i < list.size(); i++) {
preparedStatement.setString(1,list.get(i).get("oid").toString()); preparedStatement.setString(1,list.get(i).get("oid").toString());
preparedStatement.setString(2,list.get(i).get("title").toString()); preparedStatement.setString(2,list.get(i).get("title").toString());
preparedStatement.setString(3,list.get(i).get("createDate").toString()); preparedStatement.setString(3,list.get(i).get("sort").toString());
preparedStatement.setString(4,list.get(i).get("image").toString());
preparedStatement.setString(5,list.get(i).get("content").toString());
preparedStatement.setString(6,list.get(i).get("createDate").toString());
// 添加到批处理中 // 添加到批处理中
preparedStatement.addBatch(); preparedStatement.addBatch();
if (i+1 % 5000 == 0) { if (i+1 % 5000 == 0) {