package com.thread;
|
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
import com.base.Com;
|
import com.mode.Device_Inf;
|
import com.mode.Dynamicload_State_rt;
|
import com.mode.Electric_State_2kw;
|
import com.mode.Electric_state;
|
import com.sql.MysqlConnPool;
|
import com.sql.Sql_Mysql;
|
|
public class Manage_Simul_SQL {
|
|
/**
|
* ¼ÓÔØËùÓеÄÉ豸
|
* @param gB_MysqlConnPool
|
* @param devices
|
*/
|
public static void queryAllDevice(MysqlConnPool pool, List<Device_Inf> devices) {
|
String sql_str = " SELECT * FROM "+ Sql_Mysql.Tb_Device_Inf_Table;
|
Sql_Mysql sql = new Sql_Mysql(pool.getConn());
|
ResultSet res = null;
|
try {
|
res = sql.sqlMysqlQuery(sql_str);
|
while(res.next()) {
|
Device_Inf dev = new Device_Inf();
|
dev.setDevice_id(res.getInt("device_id"));
|
dev.setDevice_ip(res.getString("device_ip"));
|
dev.setDevice_name(res.getString("device_name"));
|
dev.setMaint_cycle(res.getInt("maint_cycle"));
|
dev.setSystem_id(res.getInt("system_id"));
|
dev.setSystem_name(res.getString("system_name"));
|
dev.setUse_starttime(res.getDate("use_starttime"));
|
dev.setUser_id(res.getInt("user_id"));
|
devices.add(dev);
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
} finally {
|
if(null != res) {
|
try {
|
res.close();
|
} catch (SQLException e) {
|
e.printStackTrace();
|
}
|
}
|
sql.close_con();
|
}
|
}
|
//²åÈ븺ÔØĬÈÏÊý¾Ý
|
public static void insertDynamicload(MysqlConnPool conn_pool, Dynamicload_State_rt state) {
|
String sql_str = " replace into " + Sql_Mysql.Tb_Dynamicload_State_Rt_Table + "(dev_id) values("+state.getDev_id()+")";
|
Sql_Mysql sql = new Sql_Mysql(conn_pool.getConn());
|
try {
|
//System.out.println(sql_str);
|
sql.sqlMysqlExecute(sql_str);
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
//¼ÓÔظºÔØʵʱÊý¾Ý
|
public static void updateDynamicload(MysqlConnPool conn_pool, Dynamicload_State_rt state) {
|
String sql_str = " UPDATE " + Sql_Mysql.Tb_Dynamicload_State_Rt_Table
|
+ " SET "
|
+" record_time='" + Com.getDateTimeFormat(state.getRecord_time(), Com.DTF_YMDhms)+"'"
|
+",start_auto=" + state.getStart_auto()
|
+",stop_auto=" + state.getStop_auto()
|
+",sudden_crease=" + state.getSudden_crease()
|
+",all_open=" + state.getAll_open()
|
+",actual_set_power=" + state.getActual_set_power()
|
+",output_power=" + state.getOutput_power()
|
+",set_power=" + state.getSet_power()
|
+",interval_time=" + state.getInterval_time()
|
+",actual_curr=" + state.getActual_curr()
|
+",actual_mov=" + state.getActual_mov()
|
+",switch_on=" + state.getSwitch_on()
|
+",FZ_autostate1=" + state.getFZ_autostate1()
|
+",FZ_autostate2=" + state.getFZ_autostate2()
|
+",FZ_autostate3=" + state.getFZ_autostate3()
|
+",FZ_autostate4=" + state.getFZ_autostate4()
|
+",FZ_autostate5=" + state.getFZ_autostate5()
|
+",react_overtem=" + state.getReact_overtem()
|
+",water_overtem=" + state.getWater_overtem()
|
+",water_level_low=" + state.getWater_level_low()
|
+",water_pressure_high=" + state.getWater_pressure_high()
|
+",local_control=" + state.getLocal_control()
|
+",back_control=" + state.getBack_control()
|
+",central_control=" + state.getCentral_control()
|
+",switch_state=" + state.getSwitch_state()
|
+",inter_volume_M200=" + state.getInter_volume_M200()
|
+",fan_button=" + state.getFan_button()
|
+",fan_output=" + state.getFan_output()
|
+",allow_close=" + state.allow_close
|
+ " WHERE dev_id = " + state.dev_id;
|
Sql_Mysql sql = new Sql_Mysql(conn_pool.getConn());
|
try {
|
//System.out.println(sql_str);
|
sql.sqlMysqlExecute(sql_str);
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
//²åÈë4MWµçԴĬÈÏÊý¾Ý
|
public static void insert4MWPower(MysqlConnPool conn_pool, Electric_state state) {
|
String sql_str = " replace into " + Sql_Mysql.Tb_Electric_State_Table + "(electric_id) values("+state.getElectric_id()+")";
|
Sql_Mysql sql = new Sql_Mysql(conn_pool.getConn());
|
try {
|
//System.out.println(sql_str);
|
sql.sqlMysqlExecute(sql_str);
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
//¼ÓÔØ4MWµçԴʵʱÊý¾Ý
|
public static void update4MWPower(MysqlConnPool conn_pool, Electric_state state) {
|
String sql_str = " update "+ Sql_Mysql.Tb_Electric_State_Table +" "
|
+ " SET case_trip_output = "+state.case_trip_output+","
|
+" record_time='" + Com.getDateTimeFormat(state.getRecord_time(), Com.DTF_YMDhms)+"',"
|
+ " fault_reset_signal = "+state.fault_reset_signal+","
|
+ " high_vol_switch_status = "+state.high_vol_switch_status+","
|
+ " stop_button = "+state.stop_button+","
|
+ " main_cabinet_fan_status = "+state.main_cabinet_fan_status+","
|
+ " trans_cabinet_door_lock = "+state.trans_cabinet_door_lock+","
|
+ " trans_cabinet_overtem_alarm = "+state.trans_cabinet_overtem_alarm+","
|
+ " trans_cabinet_overtem_trip = "+state.trans_cabinet_overtem_trip+","
|
+ " qs1_state = "+state.qs1_state+","
|
+ " qs2_state = "+state.qs2_state+","
|
+ " switch_cabinet_door_status = "+state.switch_cabinet_door_status+","
|
+ " alldcvol = "+state.alldcvol+","
|
+ " alldccurr = "+state.alldccurr+","
|
+ " conn_flag = "+state.conn_flag+" "
|
+ " WHERE electric_id ="+state.electric_id;
|
Sql_Mysql sql = new Sql_Mysql(conn_pool.getConn());
|
try {
|
//System.out.println(sql_str);
|
sql.sqlMysqlExecute(sql_str);
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
//²åÈë2MWµçԴĬÈÏÊý¾Ý
|
public static void insert2MWPower(MysqlConnPool conn_pool, Electric_State_2kw state) {
|
String sql_str = " replace into " + Sql_Mysql.Tb_Electric2mw_State_Table + "(electric2KW_id) values("+state.getElectric2KW_id()+")";
|
Sql_Mysql sql = new Sql_Mysql(conn_pool.getConn());
|
try {
|
//System.out.println(sql_str);
|
sql.sqlMysqlExecute(sql_str);
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
//¼ÓÔØ2MWµçԴʵʱÊý¾Ý
|
public static void update2MWPower(MysqlConnPool conn_pool, Electric_State_2kw state) {
|
String sql_str = " UPDATE "+Sql_Mysql.Tb_Electric2mw_State_Table +
|
" Set brachdcvol= " + state.brachdcvol +
|
",record_time='" + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms) +
|
"',brachdccurr=" + state.brachdccurr +
|
",alldcvol=" + state.alldcvol +
|
",alldccurr=" + state.alldccurr +
|
",stopchargevol_one=" + state.stopchargevol_one +
|
",stopchargevol_two=" + state.stopchargevol_two +
|
",stopchargevol_three=" + state.stopchargevol_three +
|
",stopchargevol_four=" + state.stopchargevol_four +
|
",stopchargevol_five=" + state.stopchargevol_five +
|
",controlangle=" + state.controlangle +
|
",localgivevol=" + state.localgivevol +
|
",volset=" + state.volset +
|
",localgivecurr=" + state.localgivecurr +
|
",currset=" + state.currset +
|
",chargecurr_one=" + state.chargecurr_one +
|
",chargecurr_two=" + state.chargecurr_two +
|
",chargecurr_three=" + state.chargecurr_three +
|
",chargecurr_four=" + state.chargecurr_four +
|
",chargecurr_five=" + state.chargecurr_five +
|
",consvolmode_chargecurr=" +state.consvolmode_chargecurr+
|
" Where electric2KW_id = " + state.electric2KW_id;
|
Sql_Mysql sql = new Sql_Mysql(conn_pool.getConn());
|
try {
|
//System.out.println(sql_str);
|
sql.sqlMysqlExecute(sql_str);
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
}
|
