再gprs表中添加设备进程列bts_task_inf

LiJun

2018-11-23 f0a1d216a9fe3fd307ef9a47631ba86a500b7963

再gprs表中添加设备进程列bts_task_inf

 BattMonitor_DB_Builder/bin/.gitignore

@@ -1,2 +1 @@
/com/
/main/

 BattMonitor_DB_Builder/bin/com/battdata_rt/BattData_RT_RamDB_Thread_SQL.class

Binary files differ

 BattMonitor_DB_Builder/src/com/battdata_rt/BattData_RT_RamDB_Thread_SQL.java

@@ -320,8 +320,8 @@
     * @param recreate_tb

     */

    public static void createBTSGPRSState_Table(MysqlConnPool conn_pool, boolean recreate_tb) {

        String str1 = "DROP TABLE IF EXISTS "+Sql_Mysql.BTSGPRSState_Table;	
        String str2 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.BTSGPRSState_Table

        String sql_str1 = "DROP TABLE IF EXISTS "+Sql_Mysql.BTSGPRSState_Table;	
        String sql_str2 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.BTSGPRSState_Table

                + " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "

                + "`dev_id` BIGINT NOT NULL DEFAULT 0, "

                + "`op_cmd` INT NOT NULL DEFAULT 0, "                

@@ -333,11 +333,21 @@
        Sql_Mysql sql = new Sql_Mysql(conn_pool.getConn());

        try {        

            if(true == recreate_tb) {

                sql.sqlMysqlExecute(str1);					
                sql.sqlMysqlExecute(sql_str1);					
            }else{

                //sql.sqlMysqlExecute("DELETE FROM " + Sql_Mysql.BTSGPRSState_Table);

            }

            sql.sqlMysqlExecute(str2);

            sql.sqlMysqlExecute(sql_str2);			
            String sql_str3 = " SELECT * FROM information_schema.columns  "

                            + " WHERE table_schema= 'db_ram_db' "

                            + " AND table_name='tb_bts_gprs_state' "

                            + " AND column_name='bts_task_inf'";

            //System.out.println(sql_str3);

            ResultSet rs = sql.sqlMysqlQuery(sql_str3);

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

                sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BTSGPRSState_Table 
                                + " ADD COLUMN `bts_task_inf` varchar(1024) NOT NULL DEFAULT ''");

            }

        } catch (SQLException e) {

            e.printStackTrace();

        } finally {

@@ -385,6 +395,6 @@


    public static void main(String[] args) {

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

        createBattParam_Table(conn_pool,false);

        createBTSGPRSState_Table(conn_pool,false);

    }

}