更新实时数据同时更新锁具inf表

DELL

2024-12-19 6ab9c7858c234f51719acc3e514a1af769da578b

 ElectLock_Monitor/src/com/dev/lock/comm/Lock_Task_SQL.java

@@ -14,7 +14,7 @@


   

   public static void insertLock_Rt_Table(MysqlConnPool pool,int lock_id,ElectLock_State state) {

      String sql_str_sel = "SELECT * FROM " + Sql_Mysql.Lock_Rt_Table + " WHERE lock_id = 1";

      String sql_str_sel = "SELECT * FROM " + Sql_Mysql.Lock_Rt_Table + " WHERE lock_id = " + lock_id;

      String sql_str_ins = "INSERT INTO "  + Sql_Mysql.Lock_Rt_Table +  "(lock_id,client_ip) VALUES("+lock_id+",'" + state.getClient_ip() + "');";

      Sql_Mysql sql = new Sql_Mysql(pool.getConn());

      ResultSet res = null;

@@ -68,6 +68,27 @@
   } 

   

   /**

    *    更新 tb_lock_inf 表中锁的状态

    * @param pool

    * @param lock_id

    * @param state

    */

   public static void updateLock_Inf_Table(MysqlConnPool pool,int lock_id,ElectLock_State state) {

      String sql_str = "UPDATE " + Sql_Mysql.Lock_Inf_Table + 
                  " Set lock_state = " +  state.getLock_state() +

                  " WHERE lock_id = " + lock_id;

      Sql_Mysql sql = new Sql_Mysql(pool.getConn());

      try {

         sql.sqlMysqlExecute(sql_str);

      } catch (SQLException e) {

         sql.logger.error(e.toString(),e);

      } finally {

         sql.close_con();

      }

   } 
	
	
   /**

    *    查询是否有需要控制的锁具

    * @param pool

    * @param lock_id