新增数据同步方式及配置，当选择为sql时则为数据库直连同步，全局替换所有的同步方法，用户修改，离职，注销修改调整，文件上传去除同步推送上传

zhongrj

2022-08-22 3c607f075990d6d3238daa7db1c68eaae8126424

 src/main/java/org/springblade/modules/FTP/MysqlCenlint.java

@@ -1,15 +1,15 @@
package org.springblade.modules.FTP;


import org.springblade.common.config.DataSyncConfig;
import org.springblade.common.config.FtpConfig;

import java.io.File;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

import static org.springblade.common.config.FtpConfig.*;
import static org.springblade.common.config.FtpConfig.localPath;


public class MysqlCenlint {
@@ -22,15 +22,17 @@
      try {
         int ColumnCount;
         //int RowCount;
         String driver = "com.mysql.jdbc.Driver";
         String url = sqlConnect; //换成要连接的数据库信息
         String user = username;
         String password = FtpConfig.password;
         String driver = DataSyncConfig.driver;
         //换成要连接的数据库信息
         String url = DataSyncConfig.url;
         String user = DataSyncConfig.username;
         String password = DataSyncConfig.password;
         Class.forName ( driver );
         Connection conn = (Connection) DriverManager.getConnection ( url, user, password );
         if (!conn.isClosed ()) {
            System.out.println ( "数据库连接成功：" );
            String sqls = sql; //sql
            //sql
            String sqls = sql;
            PreparedStatement ps = conn.prepareStatement ( sqls );
            boolean execute = ps.execute();
            ps.close ();
@@ -51,10 +53,11 @@
      try {
         int ColumnCount;
         //int RowCount;
         String driver = "com.mysql.jdbc.Driver";
         String url = sqlConnect; //换成要连接的数据库信息
         String user = username;
         String password = FtpConfig.password;
         String driver = DataSyncConfig.driver;
         //换成要连接的数据库信息
         String url = DataSyncConfig.url;
         String user = DataSyncConfig.username;
         String password = DataSyncConfig.password;
         Class.forName ( driver );
         Connection conn = (Connection) DriverManager.getConnection ( url, user, password );
         if (!conn.isClosed ()) {
@@ -80,10 +83,11 @@
      try {
         int ColumnCount;
         //int RowCount;
         String driver = "com.mysql.jdbc.Driver";
         String url = sqlConnect; //换成要连接的数据库信息
         String user = username;
         String password = FtpConfig.password;
         String driver = DataSyncConfig.driver;
         //换成要连接的数据库信息
         String url = DataSyncConfig.url;
         String user = DataSyncConfig.username;
         String password = DataSyncConfig.password;
         Class.forName ( driver );
         Connection conn = (Connection) DriverManager.getConnection ( url, user, password );
         if (!conn.isClosed ()) {