[数据源模块]初始提交

src/main/java/com/tykj/workflowcore/ds/service/DataOperation.java

@@ -33,6 +33,7 @@ public class DataOperation {
 
     /**
      * 同步外界数据源中所有表结构
+     *
      * @param dataSourceName 指定数据源的名字
      */
     public void syncAllTablesFromDataSource(String dataSourceName) {
@@ -87,11 +88,23 @@ public class DataOperation {
         );
     }
 
-    public void syncData(String dataSourceName, String tableName) {
+
+    public void syncAllDataFromDataSource(String dataSourceName) {
+        dataSourceManager.switchToDataSource(dataSourceName);
+        List<String> tableNames = getAllTableNames();
+        for (String tableName : tableNames) {
+            syncTableData(tableName, dataSourceName);
+        }
+    }
+
+
+    private void syncTableData(String tableName, String dataSourceName) {
         dataSourceManager.switchToDataSource(dataSourceName);
         List<Map<String, Object>> dataList = getData(tableName);
         dataSourceManager.clear();
+        //清空表数据
         clearTable(tableName);
+        //重新插入所有表数据
         for (Map<String, Object> data : dataList) {
             String sql = insertSql(tableName, data);
             log.info("execute : {}", sql);