修改查询方法中执行完毕后关闭Result资源

Administrator

2022-10-28 e7a8b28e968f3da83a82af8796bd18694c71ca6c

 iec_61850_forFoShanAES/src/com/dec/fbs9100/FBS9100_Task_Thread_SQL.java

@@ -511,8 +511,9 @@
      //System.err.println(v_data.m_SysState.dev_61850alam);

      if(v_data.m_SysState.CapTestStopType>=0 && v_data.m_SysState.CapTestStopType<=256) {

         Sql_Mysql sql = new Sql_Mysql(con_pool);

         ResultSet res = null;

         try {

            ResultSet res = sql.sqlMysqlQuery("SELECT num FROM " + Sql_Mysql.FBS9100State_Table + " WHERE dev_id = " + m_pm.dev_id);

            res = sql.sqlMysqlQuery("SELECT num FROM " + Sql_Mysql.FBS9100State_Table + " WHERE dev_id = " + m_pm.dev_id);

            

            if(res.next()) {

               sql.sqlMysqlExecute(sql_str_update);

@@ -522,6 +523,13 @@
         } catch (SQLException e) {

            sql.logger.error("FBS9100_Task_Thread_SQL.updateFbs9100StateByDev_Id():" + e.toString(), e);

         } finally {

            if(null != res) {

               try {

                  res.close();

               } catch (SQLException e) {

                  e.printStackTrace();

               }

            }

            sql.close_con();

         }

      }

@@ -559,8 +567,9 @@
      String sql_str_replace = "REPLACE INTO " + sql_str_base;

      

      Sql_Mysql sql = new Sql_Mysql(con_pool);

      ResultSet res = null;

      try {

         ResultSet res = sql.sqlMysqlQuery("SELECT num FROM " + Sql_Mysql.FBS9100sFodState_Table + " WHERE dev_id = " + m_pm.dev_id);

         res = sql.sqlMysqlQuery("SELECT num FROM " + Sql_Mysql.FBS9100sFodState_Table + " WHERE dev_id = " + m_pm.dev_id);

         

         if(res.next()) {

            sql.sqlMysqlExecute(sql_str_update);

@@ -570,6 +579,13 @@
      } catch (SQLException e) {

         sql.logger.error("FBS9100_Task_Thread_SQL.inseartOrUpdateFBS9100SFODState():" + e.toString(), e);

      } finally {

         if(null != res) {

            try {

               res.close();

            } catch (SQLException e) {

               sql.logger.error("FBS9100_Task_Thread_SQL.inseartOrUpdateFBS9100SFODState():" + e.toString(), e);

            }

         }

         sql.close_con();

      }

   }

@@ -671,9 +687,15 @@
            }

         }

      } catch (SQLException e) {

         // TODO Auto-generated catch block

         sql.logger.error("FBS9100_Task_Thread_SQL.queryFbs9100SetParam():" + e.toString(), e);

      } finally {

         if(null != res) {

            try {

               res.close();

            } catch (SQLException e) {

               sql.logger.error("FBS9100_Task_Thread_SQL.queryFbs9100SetParam():" + e.toString(), e);

            }

         }

         sql.close_con();

      }

   }

@@ -724,6 +746,13 @@
      } catch (SQLException e) {

         sql.logger.error("FBS9100_Task_Thread_SQL.queryFbs9100SetParamBydev_id():" + e.toString(), e);

      } finally {

         if(null != res) {

            try {

               res.close();

            } catch (SQLException e) {

               sql.logger.error("FBS9100_Task_Thread_SQL.queryFbs9100SetParamBydev_id():" + e.toString(), e);

            }

         }

         sql.close_con();

      }

   }

@@ -760,8 +789,9 @@
      String sql_str_replace = "REPLACE INTO " + sql_str_base;

      

      Sql_Mysql sql = new Sql_Mysql(con_pool);

      ResultSet res = null;

      try {

         ResultSet res = sql.sqlMysqlQuery("SELECT num FROM " + Sql_Mysql.FBS9100SetDLParam_Table 
         res = sql.sqlMysqlQuery("SELECT num FROM " + Sql_Mysql.FBS9100SetDLParam_Table 
                                    + " WHERE dev_id = " + param.dev_id);

         

         if(res.next()) {

@@ -772,6 +802,13 @@
      } catch (SQLException e) {

         sql.logger.error("FBS9100_Task_Thread_SQL.inseartOrUpdateFBS9100SFODParam():" + e.toString(), e);

      } finally {

         if(null != res) {

            try {

               res.close();

            } catch (SQLException e) {

               sql.logger.error("FBS9100_Task_Thread_SQL.inseartOrUpdateFBS9100SFODParam():" + e.toString(), e);

            }

         }

         sql.close_con();

      }

   }

@@ -817,6 +854,13 @@
      } catch (SQLException e) {

         sql.logger.error("FBS9100_Task_Thread_SQL.queryFbsCL9100SetParamBydev_id():" + e.toString(), e);

      } finally {

         if(null != res) {

            try {

               res.close();

            } catch (SQLException e) {

               sql.logger.error("FBS9100_Task_Thread_SQL.queryFbsCL9100SetParamBydev_id():" + e.toString(), e);

            }

         }

         sql.close_con();

      }

   }

@@ -1184,9 +1228,9 @@
      String sql_str_update = "UPDATE " + sql_str_base + " WHERE dev_id=" + param.dev_id;

      String sql_str_replace = "REPLACE INTO " + sql_str_base;

      Sql_Mysql sql = new Sql_Mysql(conn_pool);

		
      ResultSet res = null;

      try {

         ResultSet res = sql.sqlMysqlQuery("SELECT num FROM " + Sql_Mysql.FBS9100_61850_jhstate_Table 
         res = sql.sqlMysqlQuery("SELECT num FROM " + Sql_Mysql.FBS9100_61850_jhstate_Table 
                                    + " WHERE dev_id = " + param.dev_id);

         if(res.next()) {

            sql.sqlMysqlExecute(sql_str_update);

@@ -1196,6 +1240,13 @@
      } catch (SQLException e) {

         sql.logger.error("FBS9100_Task_Thread_SQL.insertOrUpdateJhStateTable():" + e.toString(), e);

      } finally {

         if(null != res) {

            try {

               res.close();

            } catch (SQLException e) {

               sql.logger.error("FBS9100_Task_Thread_SQL.insertOrUpdateJhStateTable():" + e.toString(), e);

            }

         }

         sql.close_con();

      }

   }

@@ -1280,6 +1331,13 @@
      } catch (SQLException e) {

         sql.logger.error("FBS9100_Task_Thread_SQL.queryFBS9100SysParamBydev_id():" + e.toString(), e);

      } finally {

         if(null != res) {

            try {

               res.close();

            } catch (SQLException e) {

               sql.logger.error("FBS9100_Task_Thread_SQL.queryFBS9100SysParamBydev_id():" + e.toString(), e);

            }

         }

         sql.close_con();

      }

   }

@@ -1487,6 +1545,13 @@
      } catch (SQLException e) {

         sql.logger.error("FBS9100_Task_Thread_SQL.queryBTS61850OffLineyhPlanOnRam():" + e.toString(), e);

      } finally {

         if(null != res) {

            try {

               res.close();

            } catch (SQLException e) {

               sql.logger.error("FBS9100_Task_Thread_SQL.queryBTS61850OffLineyhPlanOnRam():" + e.toString(), e);

            }

         }

         sql.close_con();

      }

   }