| | |
|---|
| | | try {
|
|---|
| | | res = sql.sqlMysqlQuery(sql_str_sel);
|
|---|
| | | if(res.next()) {
|
|---|
| | | sql.sqlMysqlExecute("UPDATE " + Sql_Mysql.Ied_NodeState_Table + " SET node_value = '" + value.node_value + "',node_name = '" + value.node_name + "' WHERE node_path = '" + value.node_path + "';");
|
|---|
| | | //sql.sqlMysqlExecute("UPDATE " + Sql_Mysql.Ied_NodeState_Table + " SET node_value = '" + value.node_value + "',node_name = '" + value.node_name + "' WHERE node_path = '" + value.node_path + "';");
|
|---|
| | | }else {
|
|---|
| | | sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.Ied_NodeState_Table + "(node_path,node_name,node_value) VALUES('" + value.node_path + "','" + value.node_name + "','" + value.node_value + "');");
|
|---|
| | | }
|
|---|
| | |
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | |
|---|
| | | public static void updateupdateIed_NodeState_Table(MysqlConnPool pool,ScoutData data) {
|
|---|
| | | StringBuffer sql_str = new StringBuffer(" UPDATE " + Sql_Mysql.Ied_NodeState_Table + " SET node_value = " + data.node_value + ",node_name = '"+ data.node_name +"' where node_path = '"+ data.node_path +"';");
|
|---|
| | | Sql_Mysql sql = new Sql_Mysql(pool);
|
|---|
| | | try {
|
|---|
| | | //System.out.println(sql_str.toString());
|
|---|
| | | sql.sqlMysqlExecute(sql_str.toString());
|
|---|
| | | } catch (SQLException e) {
|
|---|
| | | sql.logger.error("BTS61850_IEDScout_Task_Thread_SQL.updateupdateIed_NodeState_Table():" + e.toString(), e);
|
|---|
| | | } finally {
|
|---|
| | | sql.close_con();
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | /**
|
|---|
| | | * 清空'db_ied_scout.tb_ied_nodestate'表中的所有数据
|
|---|
| | | * @param pool
|
|---|
