V1.102 2024-01-22 1.电源通信程序运行时不再删除配电柜实时状态表重新创建 2.读取方式改为从集合中读取 3.ACDC高频开关...

DELL

2024-01-23 26696408ae5298bd6773f7c768417eb964f530ad

 IEC61850_ForPowerSupply_ForNW/src/com/power/mysql/Sql_Mysql.java

@@ -133,7 +133,7 @@
                  + "PRIMARY KEY (`num`)) "

                  + "ENGINE=InnoDB DEFAULT CHARSET=utf8;";

      

      String table_2_0 = "DROP TABLE IF EXISTS " + PWRDEV_ACDATA_TABLE;

      //String table_2_0 = "DROP TABLE IF EXISTS " + PWRDEV_ACDATA_TABLE;

      String table_2 = "CREATE TABLE IF NOT EXISTS " + PWRDEV_ACDATA_TABLE

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

                  + "`PowerDeviceId`  bigint NOT NULL DEFAULT 0 ,"

@@ -201,7 +201,7 @@
                  + "PRIMARY KEY (`num`)) "

                  + "ENGINE=InnoDB DEFAULT CHARSET=utf8;";

      

      String table_3_0 = "DROP TABLE IF EXISTS " + PWRDEV_ACDCDATA_TABLE;

      //String table_3_0 = "DROP TABLE IF EXISTS " + PWRDEV_ACDCDATA_TABLE;

      String table_3 = "CREATE TABLE IF NOT EXISTS " + PWRDEV_ACDCDATA_TABLE

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

                  + "`PowerDeviceId`  bigint NOT NULL DEFAULT 0 ,"

@@ -416,7 +416,7 @@
                  + "PRIMARY KEY (`num`)) "

                  + "ENGINE=InnoDB DEFAULT CHARSET=utf8;";

      

            String table_4_0 = "DROP TABLE IF EXISTS " + PWRDEV_DCDATA_TABLE;

            //String table_4_0 = "DROP TABLE IF EXISTS " + PWRDEV_DCDATA_TABLE;

            String table_4 = "CREATE TABLE IF NOT EXISTS " + PWRDEV_DCDATA_TABLE

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

                  + "`PowerDeviceId`  bigint NOT NULL DEFAULT 0 ,"

@@ -617,9 +617,9 @@
      //logger.info(table_3);

      //logger.info(table_13);

      

      sqlMysqlExecute(table_2_0);

      sqlMysqlExecute(table_3_0);

      sqlMysqlExecute(table_4_0);

      //sqlMysqlExecute(table_2_0);

      //sqlMysqlExecute(table_3_0);

      //sqlMysqlExecute(table_4_0);

      sqlMysqlExecute(table_12_0);

      sqlMysqlExecute(table_14_0);

      sqlMysqlExecute(table_15_0);

@@ -675,6 +675,13 @@
      sql.setQueryTimeout(30);

      sql.execute(sql_str);

   }

   //执行sql语句

   public void sqlMysqlTotalExecute(String sql_str) throws SQLException

   {

      Statement sql = mysql_con.createStatement();

      sql.setQueryTimeout(5*60);

      sql.execute(sql_str);

   }

   

   

   //在事物中执行多条sql语句

@@ -729,6 +736,25 @@
      

      return res;

   }

   //根据sql语句执行sql查询语句

   public ResultSet sqlMysqlTotalQuery(String sql_str)

   {

      ResultSet res = null;

      try

      {

         Statement sql = mysql_con.createStatement();

         sql.setQueryTimeout(5*60);

         String query = sql_str;

         res =  sql.executeQuery(query);

      }

      catch(SQLException ex)

      {

         //System.err.println("SQLException:" + ex.getMessage());

         logger.error(ex.toString(), ex);

      }

		
      return res;

   }

   

   //根据sql语句执行sql更新语句

   public void sqlMysqlUpdate(String sql_str)