From 89e2b84a38d1c3ab19933a41c3a409be31c8ed5a Mon Sep 17 00:00:00 2001
From: LiJun <LiJun@192.168.10.13>
Date: 星期四, 29 十一月 2018 11:09:14 +0800
Subject: [PATCH] tb_fbs9100s_dfu_state表中添加文件长度列
---
BattMonitor_DB_Builder/src/com/dev/fbs9100/FBS9100S_DFU_SQL.java | 119 ++++++++++++++++++++++++++++++++++-------------------------
1 files changed, 69 insertions(+), 50 deletions(-)
diff --git a/BattMonitor_DB_Builder/src/com/dev/fbs9100/FBS9100S_DFU_SQL.java b/BattMonitor_DB_Builder/src/com/dev/fbs9100/FBS9100S_DFU_SQL.java
index ac385ba..0e1ada0 100644
--- a/BattMonitor_DB_Builder/src/com/dev/fbs9100/FBS9100S_DFU_SQL.java
+++ b/BattMonitor_DB_Builder/src/com/dev/fbs9100/FBS9100S_DFU_SQL.java
@@ -1,50 +1,69 @@
-package com.dev.fbs9100;
-
-import java.sql.SQLException;
-import com.sql.MysqlConnPool;
-import com.sql.Sql_Mysql;
-
-public class FBS9100S_DFU_SQL {
- /***************************************************************************/
- public static final int DFU_STATE_NULL = 0;
- public static final int DFU_STATE_WRITE = 1;
- public static final int DFU_STATE_READ = 2;
- public static final int DFU_STATE_CHECK_OK = 3;
- /***************************************************************************/
- /**
- * 创建 tb_fbs9100s_dfu 表并且将设备id和设备ip插入到表中
- * @param con_pool
- * @param al_param
- */
- public static void createFBS9100S_DFU_TableOnRam(MysqlConnPool con_pool)
- {
- String str1 = "DROP TABLE IF EXISTS " + Sql_Mysql.FBS9100S_DFUState_Table;
- String str2 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.FBS9100S_DFUState_Table
- + " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "
- + "`dev_id` BIGINT NOT NULL DEFAULT 0, "
- + "`sysVersion_new` INT NOT NULL DEFAULT 0, "
- + "`softVersion_new` INT NOT NULL DEFAULT 0, "
- + "`sysVersion_dev` INT NOT NULL DEFAULT 0, "
- + "`softVersion_dev` INT NOT NULL DEFAULT 0, "
- + "`dfu_file` varchar(200) NOT NULL DEFAULT ' ', "
- + "`dfu_en` BOOLEAN NOT NULL DEFAULT false, "
- + "`dfu_wr_stat` INT NOT NULL DEFAULT 0, "
- + "`dfu_data_blocknum` INT NOT NULL DEFAULT 0, "
- + "`dfu_data_blocklen` INT NOT NULL DEFAULT 256, "
- + "`dfu_password` varchar(100) NOT NULL DEFAULT ' ', "
- + " UNIQUE INDEX index_dev_id_uniq (`dev_id`), "
- + " PRIMARY KEY (`num`) ) "
- + " ENGINE=MEMORY DEFAULT CHARSET=utf8";
-
- Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
- try {
- sql.sqlMysqlExecute(str1);
- sql.sqlMysqlExecute(str2);
- } catch (SQLException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- } finally {
- sql.close_con();
- }
- }
-}
+package com.dev.fbs9100;
+
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import com.sql.MysqlConnPool;
+import com.sql.Sql_Mysql;
+
+public class FBS9100S_DFU_SQL {
+ /***************************************************************************/
+ public static final int DFU_STATE_NULL = 0;
+ public static final int DFU_STATE_WRITE = 1;
+ public static final int DFU_STATE_READ = 2;
+ public static final int DFU_STATE_CHECK_OK = 3;
+ /***************************************************************************/
+ /**
+ * 创建 tb_fbs9100s_dfu 表并且将设备id和设备ip插入到表中
+ * @param con_pool
+ * @param al_param
+ */
+ public static void createFBS9100S_DFU_TableOnRam(MysqlConnPool con_pool)
+ {
+ String str1 = "DROP TABLE IF EXISTS " + Sql_Mysql.FBS9100S_DFUState_Table;
+ String str2 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.FBS9100S_DFUState_Table
+ + " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "
+ + "`dev_id` BIGINT NOT NULL DEFAULT 0, "
+ + "`sysVersion_new` INT NOT NULL DEFAULT 0, "
+ + "`softVersion_new` INT NOT NULL DEFAULT 0, "
+ + "`sysVersion_dev` INT NOT NULL DEFAULT 0, "
+ + "`softVersion_dev` INT NOT NULL DEFAULT 0, "
+ + "`dfu_file` varchar(200) NOT NULL DEFAULT ' ', "
+ + "`dfu_en` BOOLEAN NOT NULL DEFAULT false, "
+ + "`dfu_wr_stat` INT NOT NULL DEFAULT 0, "
+ + "`dfu_data_blocknum` INT NOT NULL DEFAULT 0, "
+ + "`dfu_data_blocklen` INT NOT NULL DEFAULT 256, "
+ + "`dfu_password` varchar(100) NOT NULL DEFAULT ' ', "
+ + "`dfu_file_len` INT NOT NULL DEFAULT 0,"
+ + " UNIQUE INDEX index_dev_id_uniq (`dev_id`), "
+ + " PRIMARY KEY (`num`) ) "
+ + " ENGINE=MEMORY DEFAULT CHARSET=utf8";
+
+ Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
+ try {
+ sql.sqlMysqlExecute(str1);
+ sql.sqlMysqlExecute(str2);
+
+
+ String sql_str3 = " SELECT * FROM information_schema.columns "
+ + " WHERE table_schema= 'db_ram_db' "
+ + " AND table_name='tb_fbs9100s_DFU_state' "
+ + " AND column_name='dfu_file_len'";
+ //System.out.println(sql_str3);
+ ResultSet rs = sql.sqlMysqlQuery(sql_str3);
+ if(false == rs.next()) {
+ sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.FBS9100S_DFUState_Table
+ + " ADD COLUMN dfu_file_len int not null DEFAULT 0" +
+ "");
+ }
+ } catch (SQLException e) {
+ e.printStackTrace();
+ } finally {
+ sql.close_con();
+ }
+ }
+
+ public static void main(String[] args) {
+ MysqlConnPool conn_pool = new MysqlConnPool("127.0.0.1",3360,5);
+ createFBS9100S_DFU_TableOnRam(conn_pool);
+ }
+}
--
Gitblit v1.9.1