新增接口tableList

src/main/java/cn/qg/holmes/controller/effect/DbSyncController.java

@@ -105,6 +105,17 @@ public class DbSyncController {
         return JsonResult.buildSuccessResult(tableList);
     }
 
+    /**
+     * 跟数据库同步脚本使用的接口
+     * @param database 数据库名
+     * @return
+     */
+    @GetMapping("/tableList")
+    public String getTableListForSync(@RequestParam String database) {
+        List<String> tableList = databaseSyncService.getTableListByDb(ip, port, username, password, database);
+        return StringUtils.join(tableList, " ");
+    }
+
     /**
      * 老数据库同步，调用Jenkins job sync_database_schema
      * @param dbName 数据库名

src/main/java/cn/qg/holmes/service/effect/impl/DatabaseSyncServiceImpl.java

@@ -158,7 +158,6 @@ public class DatabaseSyncServiceImpl implements DatabaseSyncService {
                     StringBuilder insertSql = new StringBuilder();
                     while (selectResultSet.next()) {
                         String rowValues = getRowValues(selectResultSet, columnNameList.size(), columnTypeList);
-                        // String insertSql = String.format("insert into %s (%s) values(%s);", tableName, columnArrayStr, rowValues);
                         insertSql
                                 .append("insert into ")
                                 .append(tableName)

src/main/java/cn/qg/holmes/task/DbSyncTask.java

@@ -32,7 +32,7 @@ public class DbSyncTask {
     private String password;
 
 //    @Scheduled(cron = "0 0 24 * * ?")
-    @Scheduled(cron = "0 15 15 * * ?")
+    @Scheduled(cron = "0 38 15 * * ?")
     public void getDbInfoFromSourceJob() {
         List<String> dbList = databaseSyncService.getDatabaseList(ip, port, username, password);
         for (String dbName: dbList) {