'commit'

src/main/java/Tools/MySqlExport.java

@@ -0,0 +1,52 @@
+package Tools;
+
+import java.io.IOException;
+import java.util.Properties;
+
+/**
+ * 在进行导出的时候，需要注意命令语句的运行环境，如果已经将mysql安装路径下的bin加入到
+ * 系统的path变量中，那么在导出的时候可以直接使用命令语句，否则，就需要在执行命令语句的
+ * 时候加上命令所在位置的路径，即mysql安装路径想的bin下的mysqldump命令
+ * @author andy
+ *
+ */
+public class MySqlExport {
+
+    /**
+     * 根据属性文件的配置导出指定位置的指定数据库到指定位置
+     * @param properties
+     * @throws IOException
+     */
+    public static void export(Properties properties) throws IOException {
+        Runtime runtime = Runtime.getRuntime();
+        String command = getExportCommand(properties);
+        System.out.println(command);
+        runtime.exec(command);//这里简单一点异常我就直接往上抛
+    }
+
+
+    /**
+     * 利用属性文件提供的配置来拼装命令语句
+     * 在拼装命令语句的时候有一点是需要注意的：一般我们在命令窗口直接使用命令来
+     * 进行导出的时候可以简单使用“>”来表示导出到什么地方，即mysqldump -uusername -ppassword databaseName > exportPath，
+     * 但在Java中这样写是不行的，它需要你用-r明确的指出导出到什么地方，如：
+     * mysqldump -uusername -ppassword databaseName -r exportPath。
+     * @param properties
+     * @return
+     */
+    private static String getExportCommand(Properties properties) {
+        StringBuffer command = new StringBuffer();
+        String username = properties.getProperty("jdbc.username");//用户名
+        String password = properties.getProperty("jdbc.password");//用户密码
+        String exportDatabaseName = properties.getProperty("jdbc.exportDatabaseName");//需要导出的数据库名
+        String host = properties.getProperty("jdbc.host");//从哪个主机导出数据库，如果没有指定这个值，则默认取localhost
+        String port = properties.getProperty("jdbc.port");//使用的端口号
+        String exportPath = properties.getProperty("jdbc.exportPath");//导出路径
+
+        //注意哪些地方要空格，哪些不要空格
+        command.append("mysqldump -u").append(username).append(" -p").append(password)//密码是用的小p，而端口是用的大P。
+                .append(" -h").append(host).append(" -P").append(port).append(" ").append(exportDatabaseName).append(" -r ").append(exportPath);
+        return command.toString();
+    }
+
+}

src/main/java/Tools/ZhengZhou103/AddWenNum.java

@@ -1,6 +1,5 @@
 package Tools.ZhengZhou103;
 
-import cn.hutool.core.io.FileUtil;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.jfinal.kit.Kv;
@@ -11,10 +10,7 @@ import com.jfinal.plugin.activerecord.Record;
 import com.jfinal.plugin.activerecord.dialect.MysqlDialect;
 import com.jfinal.plugin.druid.DruidPlugin;
 
-import java.io.File;
 import java.sql.*;
-import java.time.LocalDateTime;
-import java.time.format.DateTimeFormatter;
 
 public class AddWenNum {
 
@@ -90,18 +86,7 @@ public class AddWenNum {
 
 
     public static void main(String[] args) throws SQLException {
-        //加载配置文件
+        Db103Init.Init();
-        String configFile = "application_ZhengZhou103.properties";
-        PropKit.use(configFile);
-
-        // 数据库配置
-        DruidPlugin druidPlugin = new DruidPlugin(PropKit.get("jdbcUrl"), PropKit.get("user"),
-                PropKit.get("password").trim(), PropKit.get("driverClassName"));
-        druidPlugin.start();
-
-        ActiveRecordPlugin arp = new ActiveRecordPlugin(druidPlugin);
-        arp.setDialect(new MysqlDialect());
-        arp.start();
 
         //想要添加的文号
         String wenHao = "郑动联";
@@ -112,5 +97,8 @@ public class AddWenNum {
 
         //2、form_field下的json数据
         addField(id, wenHao);
+
+        //3、显示更新脚本
+        Db103Init.showUpdateSql();
     }
 }

src/main/java/Tools/ZhengZhou103/Db103Init.java

@@ -0,0 +1,37 @@
+package Tools.ZhengZhou103;
+
+import com.jfinal.kit.PropKit;
+import com.jfinal.plugin.activerecord.ActiveRecordPlugin;
+import com.jfinal.plugin.activerecord.Db;
+import com.jfinal.plugin.activerecord.Record;
+import com.jfinal.plugin.activerecord.dialect.MysqlDialect;
+import com.jfinal.plugin.druid.DruidPlugin;
+
+public class Db103Init {
+    public static void Init(){
+        //加载配置文件
+        String configFile = "103.properties";
+        PropKit.use(configFile);
+
+        // 数据库配置
+        DruidPlugin druidPlugin = new DruidPlugin(PropKit.get("jdbcUrl"), PropKit.get("user"),
+                PropKit.get("password").trim(), PropKit.get("driverClassName"));
+        druidPlugin.start();
+
+        ActiveRecordPlugin arp = new ActiveRecordPlugin(druidPlugin);
+        arp.setDialect(new MysqlDialect());
+        arp.start();
+    }
+
+    public static void showUpdateSql(){
+        String sql = "select field_id,field_attribute from t_intellioa_flow_form_field where form_id=36 and field_label='原文号' and is_deleted=0;";
+        Record record = Db.findFirst(sql);
+        String field_attribute = record.getStr("field_attribute");
+
+        sql = "select form_id,form_json from t_intellioa_flow_form where form_id=?";
+        String form_json = Db.findFirst(sql, 36).getStr("form_json");
+
+        System.out.println("更新语句\n" + "update t_intellioa_flow_form set form_json='" + form_json + "' where form_id=36;");
+        System.out.println("update t_intellioa_flow_form_field set field_attribute='" + field_attribute + "' where form_id=36 and field_label='原文号' and is_deleted=0;");
+    }
+}

src/main/java/Tools/ZhengZhou103/Test_ShowUpdateSql.java

@@ -0,0 +1,9 @@
+package Tools.ZhengZhou103;
+
+public class Test_ShowUpdateSql {
+    public static void main(String[] args) {
+        Db103Init.Init();
+        //3、显示更新脚本
+        Db103Init.showUpdateSql();
+    }
+}

src/main/resources/103.properties

@@ -3,3 +3,4 @@ driverClassName=com.mysql.cj.jdbc.Driver
 user=root
 password=Password123@mysql
 jdbcUrl=jdbc:mysql://10.10.14.203:3306/dsideal_db?rewriteBatchedStatements=true&useUnicode=true&zeroDateTimeBehavior=CONVERT_TO_NULL&useSSL=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai&autoReconnect=true&failOverReadOnly=false
+