'commit'

src/main/java/com/dsideal/base/Tools/ChangUrlLink.java

@@ -0,0 +1,40 @@
+package com.dsideal.base.Tools;
+
+import com.dsideal.base.DataEase.Model.DataEaseModel;
+import com.dsideal.base.Res.Model.ResourceModel;
+import com.dsideal.base.Tools.Util.DevMysqlUtil;
+import com.jcraft.jsch.JSchException;
+import com.jfinal.kit.StrKit;
+import com.jfinal.plugin.activerecord.Db;
+import com.jfinal.plugin.activerecord.Record;
+
+import java.io.IOException;
+import java.util.List;
+
+public class ChangUrlLink {
+
+    public static DataEaseModel dm = new DataEaseModel();
+
+    public static void main(String[] args) throws IOException, JSchException {
+        DevMysqlUtil.Init();
+        //原地址
+        String sourceHost = "http://10.10.21.20:9000/dsBase/";
+        //目标地址
+        String targetHost = "https://www.edusoa.com/dsBase/";
+
+        String sql = "select * from visualization_link_jump_info";
+        List<Record> list = Db.use(DataEaseModel.DB_NAME).find(sql);
+        String prefix = "http://";
+        for (Record record : list) {
+            String content = record.getStr("content");
+            long id = record.getLong("id");
+            if (!StrKit.isBlank(content)
+                    //只有http的不要
+                    && content.startsWith(prefix) && content.length() > prefix.length()) {
+                System.out.println(content);
+                //sql="update visualization_link_jump_info set content=? where id=?";
+                //Db.use(DataEaseModel.DB_NAME).update(sql, content.replace(sourceHost, targetHost), id);
+            }
+        }
+    }
+}

src/main/java/com/dsideal/base/Tools/ChangeUrlLink.java

@@ -1,33 +0,0 @@
-package com.dsideal.base.Tools;
-
-import com.dsideal.base.DataEase.Model.DataEaseModel;
-import com.dsideal.base.Tools.Util.SshConnectUtil;
-import com.jcraft.jsch.JSchException;
-import com.jcraft.jsch.Session;
-import com.jfinal.plugin.activerecord.Db;
-import com.jfinal.plugin.activerecord.Record;
-
-import java.io.File;
-import java.io.IOException;
-import java.sql.SQLOutput;
-import java.util.List;
-
-public class ChangeUrlLink {
-    public static DataEaseModel dm = new DataEaseModel();
-
-    public static void main(String[] args) throws IOException, JSchException {
-        //通过ssh链接到Mysql数据库
-        Session session = SshConnectUtil.Init();
-
-        String sql="select * from core_chart_view";
-        List<Record> list = Db.use(DataEaseModel.DB_NAME).find(sql);
-        for (Record record : list) {
-            String custom_attr=record.getStr("custom_attr");
-            if(custom_attr.contains("http://")){
-                System.out.println("Found");
-            }
-        }
-        //关闭Ssh链接
-        session.disconnect();
-    }
-}

src/main/java/com/dsideal/base/Tools/ExportExcel.java

@@ -1,6 +1,7 @@
 package com.dsideal.base.Tools;
 
 import com.dsideal.base.DataEase.Model.DataEaseModel;
+import com.dsideal.base.Tools.Util.DevMysqlUtil;
 import com.dsideal.base.Tools.Util.SshConnectUtil;
 import com.dsideal.base.Util.ExcelCommonUtil;
 import com.jcraft.jsch.JSchException;
@@ -18,8 +19,7 @@ public class ExportExcel {
     public static DataEaseModel dm = new DataEaseModel();
 
     public static void main(String[] args) throws IOException, JSchException {
-        //通过ssh链接到Mysql数据库
-        Session session = SshConnectUtil.Init();
+        DevMysqlUtil.Init();
 
         //Excel的保存目录
         String exportPath = "D:/360Downloads/Excel";
@@ -68,7 +68,5 @@ public class ExportExcel {
             dm.exportExcel(3, tableName, dataSetName, exportPath, areaName);
         }
         System.out.println("导出完成！");
-        //关闭Ssh链接
-        session.disconnect();
     }
 }

src/main/java/com/dsideal/base/Tools/Util/DevMysqlUtil.java

@@ -0,0 +1,52 @@
+package com.dsideal.base.Tools.Util;
+
+import com.dsideal.base.DataEase.Model.DataEaseModel;
+import com.dsideal.base.Plugin.YamlProp;
+import com.dsideal.base.Tools.InitDataEaseDataSet;
+import com.jfinal.kit.Prop;
+import com.jfinal.plugin.activerecord.ActiveRecordPlugin;
+import com.jfinal.plugin.activerecord.dialect.MysqlDialect;
+import com.jfinal.plugin.hikaricp.HikariCpPlugin;
+
+import java.io.File;
+
+public class DevMysqlUtil {
+    public static Prop PropKit;
+
+    public static void Init() {
+        //加载配置文件
+        String configFile = "application.yaml";
+        PropKit = new YamlProp(configFile);
+
+        HikariCpPlugin masterPlugin = new HikariCpPlugin(PropKit.get("mysql.jdbcUrl"), PropKit.get("mysql.user"),
+                PropKit.get("mysql.password").trim(), PropKit.get("mysql.driverClassName"));
+        HikariCpPlugin dataEasePlugin = new HikariCpPlugin(PropKit.get("mysql.jdbcUrl").replace("ds_db", "dataease"), PropKit.get("mysql.user"),
+                PropKit.get("mysql.password").trim(), PropKit.get("mysql.driverClassName"));
+
+        masterPlugin.start();
+
+        dataEasePlugin.start();
+
+        // 配置ActiveRecord插件
+        ActiveRecordPlugin arp = new ActiveRecordPlugin(masterPlugin);
+        arp.setDialect(new MysqlDialect());
+
+        ActiveRecordPlugin arpDataEase = new ActiveRecordPlugin(DataEaseModel.DB_NAME, dataEasePlugin);
+        arpDataEase.setDialect(new MysqlDialect());
+
+        //遍历sql目录下所有的sql文件
+        File sqlDir;
+        String basePath = InitDataEaseDataSet.class.getResource("/").getPath();
+        sqlDir = new File(basePath + "/Sql");
+        File[] sqlFiles = sqlDir.listFiles();
+        for (File sqlFile : sqlFiles != null ? sqlFiles : new File[0]) {
+            //只加载.sql文件
+            if (sqlFile.getName().indexOf(".sql") > 0) {
+                arp.addSqlTemplate("/Sql/" + sqlFile.getName());
+                arpDataEase.addSqlTemplate("/Sql/" + sqlFile.getName());
+            }
+        }
+        arp.start();
+        arpDataEase.start();
+    }
+}