| | |
|---|
| | | sql.close_con();
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | /**
|
|---|
| | | * 插入默认交直流监控屏数据
|
|---|
| | | * @param pool
|
|---|
| | | * @param dev_id
|
|---|
| | | */
|
|---|
| | | public static void insertAcDc_SecuityBydev_id(MysqlConnPool pool, int dev_id) {
|
|---|
| | | String sql_str_sel = " SELECT * FROM " + Sql_Mysql.Acdc_Secuity_Table + " WHERE dev_id = " + dev_id;
|
|---|
| | | String sql_str_ins = " INSERT INTO " + Sql_Mysql.Acdc_Secuity_Table + "(dev_id) VALUES(" + dev_id + ");";
|
|---|
| | | Sql_Mysql sql = new Sql_Mysql(pool);
|
|---|
| | | ResultSet res = null;
|
|---|
| | | try {
|
|---|
| | | res = sql.sqlMysqlQuery(sql_str_sel);
|
|---|
| | | if(!res.next()) {
|
|---|
| | | sql.sqlMysqlExecute(sql_str_ins);
|
|---|
| | | }
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | sql.logger.error("FBS9100_Task_Thread_SQL.insertAcDc_SecuityBydev_id():" + e.toString(), e);
|
|---|
| | | } finally {
|
|---|
| | | if(null != res) {
|
|---|
| | | try {
|
|---|
| | | res.close();
|
|---|
| | | } catch (SQLException e) {
|
|---|
| | | sql.logger.error("FBS9100_Task_Thread_SQL.insertAcDc_SecuityBydev_id():" + e.toString(), e);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | sql.close_con();
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | /**
|
|---|
| | | * 更新交直流监控屏实时数据
|
|---|
| | | * @param pool
|
|---|
| | | * @param dev_id
|
|---|
| | | */
|
|---|
| | | public static void updateAcDc_SecuityBydev_id(MysqlConnPool pool, int dev_id,BTS61850_AcDc_Secuity secuity) {
|
|---|
| | | String sql_str = " UPDATE " + Sql_Mysql.Acdc_Secuity_Table +
|
|---|
| | | " SET record_time = NOW() " + |
|---|
| | | ",acin1_vola = " + secuity.getAcin1_vola() +
|
|---|
| | | ",acin1_volb = " + secuity.getAcin1_volb() +
|
|---|
| | | ",acin1_volc = " + secuity.getAcin1_volc() +
|
|---|
| | | ",acin1_curra = " + secuity.getAcin1_curra() +
|
|---|
| | | ",acin1_currb = " + secuity.getAcin1_currb() +
|
|---|
| | | ",acin1_currc = " + secuity.getAcin1_currc() +
|
|---|
| | | ",acin1_freq = " + secuity.getAcin1_freq() +
|
|---|
| | | ",acin2_vola = " + secuity.getAcin2_vola() +
|
|---|
| | | ",acin2_volb = " + secuity.getAcin2_volb() +
|
|---|
| | | ",acin2_volc = " + secuity.getAcin2_volc() +
|
|---|
| | | ",acin2_curra = " + secuity.getAcin2_curra() +
|
|---|
| | | ",acin2_currb = " + secuity.getAcin2_currb() +
|
|---|
| | | ",acin2_currc = " + secuity.getAcin2_currc() +
|
|---|
| | | ",acin2_freq = " + secuity.getAcin2_freq() +
|
|---|
| | | ",dc_outvol = " + secuity.getDc_outvol() +
|
|---|
| | | ",load_curr = " + secuity.getLoad_curr() +
|
|---|
| | | " WHERE dev_id = " + dev_id;
|
|---|
| | | Sql_Mysql sql = new Sql_Mysql(pool);
|
|---|
| | | try {
|
|---|
| | | sql.sqlMysqlExecute(sql_str);
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | sql.logger.error("FBS9100_Task_Thread_SQL.insertAcDc_SecuityBydev_id():" + e.toString(), e);
|
|---|
| | | } finally {
|
|---|
| | | sql.close_con();
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | /*********************************************************************************
|
|---|
| | | public static void createAppLog4jTable(MysqlConnPool con_pool, String db_tb) {
|
|---|
| | | String str1 = "CREATE TABLE " + db_tb + " ( "
|
|---|
| | |
|---|
| | | queryBTS61850OffLineyhPlanOnRam(pool, param);
|
|---|
| | |
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | |
|---|
| | | }
|
|---|
