'commit'

src/main/java/Tools/Crawler/CrawlerStart.java

@@ -3,7 +3,7 @@ package Tools.Crawler;
 import Tools.Crawler.Util.KnowledgeLesson;
 import Tools.Crawler.Util.PgInit;
 
-public class Start {
+public class CrawlerStart {
     public static void main(String[] args) {
         PgInit.Init();
         //BookLesson.Start();

src/main/java/Tools/Crawler/SyncDataEase.java

@@ -0,0 +1,11 @@
+package Tools.Crawler;
+
+import Tools.Crawler.Util.DataEaseInit;
+import Tools.Crawler.Util.PgInit;
+
+public class SyncDataEase {
+    public static void main(String[] args) {
+        PgInit.Init();
+        DataEaseInit.Init();
+    }
+}

src/main/java/Tools/Crawler/Util/DataEaseInit.java

@@ -0,0 +1,38 @@
+package Tools.Crawler.Util;
+
+import com.dsideal.QingLong.Start;
+import com.jfinal.kit.PropKit;
+import com.jfinal.plugin.activerecord.ActiveRecordPlugin;
+import com.jfinal.plugin.activerecord.CaseInsensitiveContainerFactory;
+import com.jfinal.plugin.activerecord.dialect.MysqlDialect;
+import com.jfinal.plugin.hikaricp.HikariCpPlugin;
+
+import java.io.File;
+
+public class DataEaseInit {
+    public static void Init(){
+        // 初始化数据库连接
+        PropKit.clear();
+        PropKit.use("application.properties");
+        HikariCpPlugin hpDataEase = new HikariCpPlugin(PropKit.get("dataEase_jdbcUrl"), PropKit.get("dataEase_user"),
+                PropKit.get("dataEase_password").trim(), PropKit.get("dataEase_driverClassName"));
+        hpDataEase.start();
+        ActiveRecordPlugin arpDataEase = new ActiveRecordPlugin("dataease",hpDataEase);
+        arpDataEase.setContainerFactory(new CaseInsensitiveContainerFactory(true));
+        arpDataEase.setDialect(new MysqlDialect());
+
+        String basePath = Start.class.getClassLoader().getResource(".").getPath();
+        File sqlDir = new File(basePath + "/Sql");
+        File[] sqlFiles = sqlDir.listFiles();
+        File[] var10 = sqlFiles != null ? sqlFiles : new File[0];
+        int var11 = var10.length;
+
+        for (int i = 0; i < var11; ++i) {
+            File sqlFile = var10[i];
+            if (sqlFile.getName().indexOf(".sql") > 0) {
+                arpDataEase.addSqlTemplate("/Sql/" + sqlFile.getName());
+            }
+        }
+        arpDataEase.start();
+    }
+}

src/main/java/Tools/Crawler/Util/PgInit.java

@@ -11,6 +11,7 @@ import java.io.File;
 
 public class PgInit {
     public static void Init(){
+        PropKit.clear();
         // 初始化数据库连接
         PropKit.use("application.properties");
         HikariCpPlugin hp = new HikariCpPlugin(PropKit.get("jdbcUrl"), PropKit.get("user"),

src/main/resources/application.properties

@@ -5,6 +5,12 @@ password=DsideaL147258369
 # 长春市
 jdbcUrl=jdbc:postgresql://10.10.14.71:5432/szjz_db?reWriteBatchedInserts=true
 
+# DataEase数据库信息
+dataEase_driverClassName=com.mysql.cj.jdbc.Driver
+dataEase_user=root
+dataEase_password=Password123@mysql
+dataEase_jdbcUrl=jdbc:mysql://10.10.14.203:3306/ds_db?rewriteBatchedStatements=true&useUnicode=true&zeroDateTimeBehavior=CONVERT_TO_NULL&useSSL=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai&autoReconnect=true&failOverReadOnly=false
+
 # MaxKB数据库信息
 MaxKB_user=root
 MaxKB_password=Password123@postgres