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

Administrator

2022-10-28 e7a8b28e968f3da83a82af8796bd18694c71ca6c

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

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

@@ -101,8 +101,15 @@
            }

            res.close();

        } catch (SQLException e) {

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

            sql.logger.error("BTS61850_Task_Thread_SQL:deleteHistoryData():" + e.toString(), e);

        } finally {

            if(null != res) {

                try {

                    res.close();

                } catch (SQLException e) {

                    sql.logger.error("BTS61850_Task_Thread_SQL:deleteHistoryData():" + e.toString(), e);

                }

            }

            sql.close_con();

        }

    }


 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();

        }

    }