From 447b83515ae498f46e9d959e7c07f733647fdf06 Mon Sep 17 00:00:00 2001
From: linwei <872216696@qq.com>
Date: Mon, 09 Feb 2026 10:00:24 +0800
Subject: [PATCH] init
---
src/main/java/cn/net/communion/dbdatasync/dbhelper/impl/MySql.java | 67 +++++++++++++++++++++++++++++++++
1 files changed, 67 insertions(+), 0 deletions(-)
diff --git a/src/main/java/cn/net/communion/dbdatasync/dbhelper/impl/MySql.java b/src/main/java/cn/net/communion/dbdatasync/dbhelper/impl/MySql.java
new file mode 100644
index 0000000..dfae0a3
--- /dev/null
+++ b/src/main/java/cn/net/communion/dbdatasync/dbhelper/impl/MySql.java
@@ -0,0 +1,67 @@
+package cn.net.communion.dbdatasync.dbhelper.impl;
+
+import cn.net.communion.dbdatasync.Tool;
+import cn.net.communion.dbdatasync.dbhelper.DbHelper;
+import cn.net.communion.dbdatasync.entity.JobInfo;
+
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+
+import org.apache.log4j.Logger;
+
+public class MySql implements DbHelper {
+ private Logger logger = Logger.getLogger(MySql.class);
+
+ public String assembleSQL(String srcSql, Connection conn, JobInfo jobInfo) throws SQLException {
+ String uniqueName = Tool.generateString(6) + "_" + jobInfo.getName();
+ String[] fields = jobInfo.getDestTableFields().split(",");
+ String[] updateFields = jobInfo.getDestTableUpdate().split(",");
+ String destTable = jobInfo.getDestTable();
+ String destTableKey = jobInfo.getDestTableKey();
+ PreparedStatement pst = conn.prepareStatement(srcSql);
+ ResultSet rs = pst.executeQuery();
+ StringBuffer sql = new StringBuffer();
+ sql.append("insert into ").append(jobInfo.getDestTable()).append(" (").append(jobInfo.getDestTableFields()).append(") values ");
+ long count = 0;
+ while (rs.next()) {
+ sql.append("(");
+ for (int index = 0; index < fields.length; index++) {
+ sql.append("'").append(rs.getString(fields[index])).append(index == (fields.length - 1) ? "'" : "',");
+ }
+ sql.append("),");
+ count++;
+ }
+ if (rs != null) {
+ rs.close();
+ }
+ if (pst != null) {
+ pst.close();
+ }
+ if (count > 0) {
+ sql = sql.deleteCharAt(sql.length() - 1);
+ if ((!jobInfo.getDestTableUpdate().equals("")) && (!jobInfo.getDestTableKey().equals(""))) {
+ sql.append(" on duplicate key update ");
+ for (int index = 0; index < updateFields.length; index++) {
+ sql.append(updateFields[index]).append("= values(").append(updateFields[index]).append(index == (updateFields.length - 1) ? ")" : "),");
+ }
+ return new StringBuffer("alter table ").append(destTable).append(" add constraint ").append(uniqueName).append(" unique (").append(destTableKey).append(");").append(sql.toString())
+ .append(";alter table ").append(destTable).append(" drop index ").append(uniqueName).toString();
+ }
+ return sql.toString();
+ }
+ return null;
+ }
+
+ public void executeSQL(String sql, Connection conn) throws SQLException {
+ PreparedStatement pst = conn.prepareStatement("");
+ String[] sqlList = sql.split(";");
+ for (int index = 0; index < sqlList.length; index++) {
+ pst.addBatch(sqlList[index]);
+ }
+ pst.executeBatch();
+ conn.commit();
+ pst.close();
+ }
+}
--
Gitblit v1.9.3