src/main/java/com/cyx/config/AppConfig.java

@@ -1,14 +1,9 @@
 package com.cyx.config;
 
-import com.alibaba.druid.filter.stat.StatFilter;
-import com.cyx.db.Jdbc;
 import com.jfinal.config.JFinalConfig;
 import com.jfinal.config.*;
 import com.jfinal.kit.PropKit;
-import com.jfinal.plugin.activerecord.ActiveRecordPlugin;
-import com.jfinal.plugin.activerecord.dialect.AnsiSqlDialect;
 import com.jfinal.plugin.cron4j.Cron4jPlugin;
-import com.jfinal.plugin.druid.DruidPlugin;
 import com.jfinal.template.Engine;
 /**
  * @Author Created by cyx.zhang Administrator on 2024/3/1 16:11 周五
@@ -31,19 +26,6 @@ public class AppConfig extends JFinalConfig {
    */
   @Override
   public void configPlugin(Plugins plugins) {
-    //配置Druid数据库连接池插件
-    DruidPlugin druidPlugin = Jdbc.createDruidPlugin();
-    //配置Druid数据库连接池大小
-    druidPlugin.set(20, 20, 100);
-    //添加 StatFilter 才会有统计数据
-    druidPlugin.addFilter(new StatFilter());
-    plugins.add(druidPlugin);
-
-    //配置ActiveRecord插件
-    ActiveRecordPlugin arp = new ActiveRecordPlugin(druidPlugin);
-    plugins.add(arp);
-    arp.setDialect(new AnsiSqlDialect());
-
     //配置任务调度插件
     Cron4jPlugin cp = new Cron4jPlugin(PropKit.use("cron4j.properties"),"cron4j");
     plugins.add(cp);

src/main/java/com/cyx/cron/MyTask.java

@@ -22,7 +22,13 @@ public class MyTask implements Runnable{
   @Override
   public void run() {
     EventLog.info("......任务调度开始执行......");
-    doStart();
+    String is = Jdbc.jdbc();
+    if ("1".equals(is)) {
+      EventLog.info("......数据库连接成功......");
+      doStart();
+    }else {
+      EventLog.info("......数据库连接失败......");
+    }
     EventLog.info("......任务调度结束执行......");
   }
 

src/main/java/com/cyx/db/Jdbc.java

@@ -17,10 +17,6 @@ public class Jdbc {
    */
   private static Prop p = PropKit.use("config.properties");
 
-  /**
-   * 配置Druid数据库连接池插件
-   * @return
-   */
   public static DruidPlugin createDruidPlugin() {
     DruidPlugin druidPlugin = null;
     try {

src/main/java/com/cyx/main/Main.java

@@ -9,10 +9,6 @@ import com.jfinal.server.undertow.UndertowServer;
  */
 public class Main {
 
-  /**
-   * 主方法
-   * @param args
-   */
   public static void main(String[] args) {
     UndertowServer.start(AppConfig.class, 8099, true);
     EventLog.info("启动成功");