From 75f29de7f6ec9c9d8e537fe9c5214075e70edef3 Mon Sep 17 00:00:00 2001
From: DELL <1525436766@qq.com>
Date: 星期六, 12 十月 2024 10:17:34 +0800
Subject: [PATCH] 添加通信异常逻辑
---
iec61850_forFoShanAES_Model/src/com/dec/fbs9100/FBS9100_Task_Thread_SQL.java | 29 ++++++++++++++++++++++++-----
1 files changed, 24 insertions(+), 5 deletions(-)
diff --git a/iec61850_forFoShanAES_Model/src/com/dec/fbs9100/FBS9100_Task_Thread_SQL.java b/iec61850_forFoShanAES_Model/src/com/dec/fbs9100/FBS9100_Task_Thread_SQL.java
index 6554bc7..4273946 100644
--- a/iec61850_forFoShanAES_Model/src/com/dec/fbs9100/FBS9100_Task_Thread_SQL.java
+++ b/iec61850_forFoShanAES_Model/src/com/dec/fbs9100/FBS9100_Task_Thread_SQL.java
@@ -655,8 +655,9 @@
{
String sql_str = "SELECT * FROM " + Sql_Mysql.FBS9100SetParam_Table;
Sql_Mysql sql = new Sql_Mysql(con_pool);
- ResultSet res = sql.sqlMysqlQuery(sql_str);
+ ResultSet res = null;
try {
+ res = sql.sqlMysqlQuery(sql_str);
while(res.next())
{
FBS9100_StatAndParam param = null;
@@ -712,8 +713,9 @@
{
String sql_str = "SELECT * FROM " + Sql_Mysql.FBS9100SetParam_Table + " where dev_id = " + param.dev_id;
Sql_Mysql sql = new Sql_Mysql(con_pool);
- ResultSet res = sql.sqlMysqlQuery(sql_str);
+ ResultSet res = null;
try {
+ res = sql.sqlMysqlQuery(sql_str);
if(res.next())
{
if(null != param) {
@@ -820,8 +822,9 @@
//System.out.println(param.dev_id);
String sql_str = "SELECT * FROM " + Sql_Mysql.FBS9100SetDLParam_Table + " where dev_id = " + param.dev_id;
Sql_Mysql sql = new Sql_Mysql(con_pool);
- ResultSet res = sql.sqlMysqlQuery(sql_str);
+ ResultSet res = null;
try {
+ res = sql.sqlMysqlQuery(sql_str);
if(res.next())
{
if(null != param) {
@@ -1299,8 +1302,9 @@
public static void queryFBS9100SysParamBydev_id(MysqlConnPool con_pool, FBS9100_StatAndParam param) {
String sql_str = "SELECT * FROM " + Sql_Mysql.FBS9100SysParam_Table + " where dev_id = " + param.dev_id;
Sql_Mysql sql = new Sql_Mysql(con_pool);
- ResultSet res = sql.sqlMysqlQuery(sql_str);
+ ResultSet res = null;
try {
+ res = sql.sqlMysqlQuery(sql_str);
if(res.next())
{
if(null != param) {
@@ -1329,6 +1333,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();
}
}
@@ -1515,9 +1526,10 @@
public static void queryBTS61850OffLineyhPlanOnRam(MysqlConnPool m_ConnPool, FBS9100_StatAndParam param) {
String sql_str = " SELECT * FROM " + Sql_Mysql.FBS9100_offlineyhplan + " WHERE dev_id = " + param.dev_id ;
Sql_Mysql sql = new Sql_Mysql(m_ConnPool);
- ResultSet res = sql.sqlMysqlQuery(sql_str);
BTS61850_OffLineYHPlan plan = param.bts61850_OffLineYHPlan;
+ ResultSet res = null;
try {
+ res = sql.sqlMysqlQuery(sql_str);
if(res.next()) {
plan.OffLineYH_Cycle = res.getInt("OffLineYH_Cycle");
plan.OffLineYHOnceCycle = res.getInt("OffLineYHOnceCycle");
@@ -1532,6 +1544,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) {
+ e.printStackTrace();
+ }
+ }
sql.close_con();
}
}
--
Gitblit v1.9.1