tb_fbs9100s_dfu_state表中添加文件长度列

LiJun

2018-11-29 89e2b84a38d1c3ab19933a41c3a409be31c8ed5a

tb_fbs9100s_dfu_state表中添加文件长度列

 BattMonitor_DB_Builder/bin/com/battdata_rt/BattData_RT_RamDB_Thread_SQL.class

Binary files differ

 BattMonitor_DB_Builder/bin/com/dev/fbs9100/FBS9100S_DFU_SQL.class

Binary files differ

 BattMonitor_DB_Builder/bin/com/sql/Sql_Mysql.class

Binary files differ

 BattMonitor_DB_Builder/src/com/battdata_rt/BattData_RT_RamDB_Thread_SQL.java

@@ -394,7 +394,7 @@
    }



    public static void main(String[] args) {

        MysqlConnPool conn_pool = new MysqlConnPool("123.207.82.239",3360,5);

        MysqlConnPool conn_pool = new MysqlConnPool("127.0.0.1",3360,5);

        createBTSGPRSState_Table(conn_pool,false);

    }

}


 BattMonitor_DB_Builder/src/com/dev/fbs9100/FBS9100S_DFU_SQL.java

@@ -1,5 +1,6 @@
package com.dev.fbs9100;

import java.sql.ResultSet;

import java.sql.SQLException;
import com.sql.MysqlConnPool;
import com.sql.Sql_Mysql;
@@ -32,6 +33,7 @@
                    + "`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";
@@ -40,11 +42,28 @@
        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) {
            // TODO Auto-generated catch block
            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);

    }

}

 BattMonitor_DB_Builder/src/com/sql/Sql_Mysql.java

@@ -563,6 +563,7 @@
                        }

                        

                //---------------------------------------------------------------------------------------------//

				
                //-------------------------------- 2018-10-16 by lijun   (  binf表中添加   station_install->标识机房是否已经安装 )------------------------------------//        

                        res = sqlMysqlQuery("SELECT * FROM information_schema.columns"

                                + " WHERE table_schema='db_battinf'"

@@ -574,7 +575,25 @@
                        }

                        

                //---------------------------------------------------------------------------------------------//

                //-------------------------------- 2018-11-29 by lijun   (  binf表中添加   StationId_ex->基站站址编号   install_user-->安装人)------------------------------------//		
                        res = sqlMysqlQuery("SELECT * FROM information_schema.columns"

                                + " WHERE table_schema='db_battinf'"

                                + " AND table_name='tb_battinf'"

                                + " AND column_name='StationId_ex'");

                        if(false == res.next()) {

                            sqlMysqlExecute("ALTER TABLE " + BattInf_Table 
                                            + " ADD COLUMN `StationId_ex` varchar(20) DEFAULT '' AFTER StationId");

                        }

                        res = sqlMysqlQuery("SELECT * FROM information_schema.columns"

                                + " WHERE table_schema='db_battinf'"

                                + " AND table_name='tb_battinf'"

                                + " AND column_name='install_user'");

                        if(false == res.next()) {

                            sqlMysqlExecute("ALTER TABLE " + BattInf_Table 
                                    + " ADD COLUMN `install_user` varchar(64) DEFAULT ''");

                        }

            

                //---------------------------------------------------------------------------------------------//

                        

                        

        //---------------------------------------------------------------------------------------------//