蓄电池监控管理平台数据库初始化程序
Administrator
2022-07-13 abffbf4d0cbda3dea8128f6c2c323a51a29f6dfa
BattMonitor_DB_Builder/src/com/sql/Sql_Mysql.java
@@ -35,6 +35,7 @@
   
   final public static String DB_DEV_HISTORY = "`db_dev_history`";                        //设备历史实时数据库
   
   final public static String DB_DEV_TESTPARAM = "`db_dev_testparam`";                        //设备历史实时数据库
   //--------------------------------------------------------------------------------------------//
   public final static String TB_HardDevSmsState = "tb_hard_dev_sms_state";
   //--------------------------------------------------------------------------------------------//
@@ -155,7 +156,9 @@
   public static final String Tb_li9130_bms_state = DB_RamDB + ".`tb_li9130_bms_state`";                     //锂电池BMS告警量
   public static final String Tb_li9130_bms_alm = DB_RamDB + ".`tb_li9130_bms_alm`";
   public static final String Tb_li9130_setparam_plan = DB_RamDB + ".`tb_li9130_setparam_plan`";
   public static final String Tb_ess3100_sysstate = DB_RamDB + ".`tb_ess3100_sysstate`";
   public static final String Tb_ess3100_pcs_state = DB_RamDB + ".`tb_ess3100_pcs_state`";
   public static final String TB_Batt_Gtstate_Table = DB_RamDB +".`tb_batt_gtstate`";                        //山西储能设备实时信息表
   
   
   /**************************** db_user数据库 ***************************************************/
@@ -217,7 +220,9 @@
   public static final String Eletmp_Table = WEB_Site +".`tb_eletmp`";                           //模板表
   public static final String Peak_Statistics_Table = WEB_Site +".`tb_peak_statistics`";            //消峰填谷电价统计表
   public static final String Weather_City2_Table = WEB_Site +".`tb_weather_city2`";               //天气表
   public static final String TB_3D_STATION_Table = WEB_Site +".`tb_3d_station`";
   public static final String TB_3D_STATION_Table = WEB_Site +".`tb_3d_station`";                  //3D机房表
   public static final String TB_Map_Outline_Table = WEB_Site +".`tb_map_outline`";               //首页轮廓图表
   
   
   
@@ -234,6 +239,10 @@
   public final static String Battspare_TABLE = DB_BATT_INF + ".`tb_battspare`";                     
   public final static String Battscrap_TABLE = DB_BATT_INF + ".`tb_battscrap`";                     
   public final static String Battspare_Record_TABLE = DB_BATT_INF + ".`tb_battspare_record`";            
   public final static String A059_Station_Inf_TABLE = DB_BATT_INF + ".`tb_a059_station_inf`";                  //充放电一体机配置机房
   public final static String Battinf_Guides_TABLE = DB_BATT_INF + ".`tb_battinf_guides`";                     //电池组各参数参考线
   public final static String Battmon_Standardcurve_TABLE = DB_BATT_INF + ".`tb_battmon_standardcurve`";         //标准曲线表
   
   
   
@@ -264,6 +273,8 @@
   public static final String Tb_dashboard_module_Table = DB_AppSys + ".`tb_dashboard_module_chart`";
   public static final String Tb_Page_Param_User_Table = DB_AppSys + ".`tb_page_param_user`";
   public static final String Tb_Page_Param2_Table = DB_AppSys + ".`tb_page_param2`";
   public static final String Tb_Menu_Approve_Table = DB_AppSys + ".`tb_menu_approve`";
   
   
   
@@ -305,6 +316,9 @@
   /***************************** db_fbo_testdata 数据库  ************************************/
   public final static String Fbotestdata_Inf_Table = DB_FBO_TESTDATA + ".`tb_fbotestdata_inf`";
   
   /***************************** db_dev_testparam 数据库  **********************************/
   public final static String Batt_TestParam_Table = DB_DEV_TESTPARAM + ".tb_batt_testparam_";            //设备放电参数记录表
   
      
   //--------------------------------------------------------------------------------------------//
@@ -1147,6 +1161,41 @@
      return exist;
   }
   
   /**
    *    检查tb表是否存在
    * @param tb 表名不带数据库名
    * @return true:存在   false:不存在
    * @throws SQLException
    */
   public boolean sqlCheckIfTableExist(String tb)
   {
      String sql_str = " SELECT COUNT(*) as count FROM information_schema.TABLES " +
                   " WHERE table_name ='" + tb + "';";
      ResultSet res = sqlMysqlQuery(sql_str);
      boolean exist = false;
      try {
         if (null != res && res.next()) {
            int count = res.getInt("count");
            if(count > 0) {
               exist = true;
            }
         }
      } catch (Exception e) {
      } finally{
         if(null != res) {
            try {
               res.close();
            } catch (SQLException e) {
               e.printStackTrace();
            }
         }
      }
      return exist;
   }
   //执行sql语句
   public void sqlMysqlExecute(String sql_str) throws SQLException
   {
@@ -1181,11 +1230,9 @@
            }
            mysql_con.setAutoCommit(true);
         } catch (SQLException e1) {
            // TODO Auto-generated catch block
            e1.printStackTrace();
         }
      }
      }
      return exe_res;
   }