package com.power.mysql;

import com.power.data.EnvmDev_Data;
import com.power.data.PowerDev_acData;
import com.power.data.PowerDev_acdcData;
import com.power.data.PowerDev_dcData;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

/**
 * 	创建数据库以及表格
 * @author 军
 *
 */
public class Sql_Mysql 
{
	//--------------------------------------------------------------------------------------------//
	final public static String WEB_Site = "web_site";
	
	final public static String DB_PWRDEV_INF = "`db_pwrdev_inf`";
	final public static String DB_PWRDEV_ALARM = "`db_pwrdev_alarm`";
	final public static String DB_PWRDEV_DATA_RT = "`db_pwrdev_data_rt`";
	
	final public static String DB_PWRDEV_DATA_HISTORY = "`db_pwrdev_data_history`";
	
	public final static String TB_PWRDEV_INF = "tb_pwrdev_inf";
	public final static String TB_PWRAPP_SYS = "tb_pwrapp_sys";	
	
	public final static String TB_PWRDEV_ALARM = "tb_pwrdev_alarm";
	public final static String TB_PWRDEV_ALARM_HISTORY = "tb_pwrdev_alarm_history";
	
	public final static String TB_PWRDEV_ACDATA = "tb_pwrdev_acdata";
	public final static String TB_PWRDEV_DCDATA = "tb_pwrdev_dcdata";
	public final static String TB_PWRDEV_ACDCDATA = "tb_pwrdev_acdcdata";
	
	public final static String PWRDEV_INF_TABLE = DB_PWRDEV_INF + ".`tb_pwrdev_inf`";
	public final static String PWRAPP_SYS_TABLE = DB_PWRDEV_INF + ".`tb_pwrapp_sys`";
	
	public final static String PWRDEV_STAINF_TABLE = DB_PWRDEV_INF + ".`tb_pwrapp_stainf`";
	public final static String PWRDEV_ACINF_TABLE = DB_PWRDEV_INF + ".`tb_pwrapp_acinf`";
	public final static String PWRDEV_ACDCINF_TABLE = DB_PWRDEV_INF + ".`tb_pwrapp_acdcinf`";
	public final static String PWRDEV_DCINF_TABLE = DB_PWRDEV_INF + ".`tb_pwrapp_dcinf`";
	
	public final static String PWRDEV_ALARM_TABLE = DB_PWRDEV_ALARM + ".`tb_pwrdev_alarm`";
	public final static String PWRDEV_ALARM_HISTORY_TABLE = DB_PWRDEV_ALARM + ".`tb_pwrdev_alarm_history`";
	public final static String PWRDEV_ALARM_PARAM_TABLE = DB_PWRDEV_ALARM + ".`tb_pwrdev_alarm_param_";
	public final static String PWRDEV_ALARM_PARAM_MB_TABLE = DB_PWRDEV_ALARM + ".`tb_pwrdev_alarm_param`";
	public final static String PWRDEV_ALARM_CONFIG_TABLE = DB_PWRDEV_ALARM + ".`tb_pwrdev_alarm_config`";
	public final static String PWRDEV_ALARM_TIMEADJ_TABLE = DB_PWRDEV_ALARM + ".`tb_pwrdev_time_adj_alarm`";
	public final static String PWRDEV_ALARM_TIMEOUT_TABLE = DB_PWRDEV_ALARM + ".`tb_pwrdev_time_out_alarm`";
	
	public final static String PWRDEV_ACDATA_TABLE = DB_PWRDEV_DATA_RT + ".`tb_pwrdev_acdata`";
	public final static String PWRDEV_DCDATA_TABLE = DB_PWRDEV_DATA_RT + ".`tb_pwrdev_dcdata`";
	public final static String PWRDEV_ACDCDATA_TABLE = DB_PWRDEV_DATA_RT + ".`tb_pwrdev_acdcdata`";
	
	public final static String PWRDEV_RT_INFO_TABLE = DB_PWRDEV_DATA_RT + ".`tb_pwrdev_rt_info`";

	public final static String PWRDEV_HISTORY_DATA_TABLE = DB_PWRDEV_DATA_HISTORY + ".`tb_pwrdev_historydata_";	
	
	//--------------------------------------------------------------------------------------------//
	//--------------------------------------------------------------------------------------------//
	public Connection mysql_con = null;
	
	public Logger logger = LogManager.getLogger(Sql_Mysql.class);
	
	public Sql_Mysql(Connection conn)
	{
		mysql_con = conn;
	}
	
	public void close_con()
	{
		try {
			mysql_con.close();
		} catch (SQLException e) {
			logger.error(e.toString(), e);
		}
	}
	
	public void checkAndCreateDB() throws SQLException
	{
		sqlMysqlExecute("CREATE DATABASE IF NOT EXISTS " + DB_PWRDEV_INF);
		sqlMysqlExecute("CREATE DATABASE IF NOT EXISTS " + DB_PWRDEV_ALARM);
		sqlMysqlExecute("CREATE DATABASE IF NOT EXISTS " + DB_PWRDEV_DATA_RT);
		sqlMysqlExecute("CREATE DATABASE IF NOT EXISTS " + DB_PWRDEV_DATA_HISTORY);
		
		String table_1 = "CREATE TABLE IF NOT EXISTS " + PWRDEV_INF_TABLE
						+ " ( `num` INT NOT NULL AUTO_INCREMENT,"
						+ "`StationId` VARCHAR(20) NOT NULL DEFAULT '0',"
						+ "`StationName` VARCHAR(100) NOT NULL DEFAULT ' ',"
						+ "`StationName1` VARCHAR(100) NOT NULL DEFAULT ' ',"
						+ "`StationName2` VARCHAR(100) NOT NULL DEFAULT ' ',"
						+ "`StationName3` VARCHAR(100) NOT NULL DEFAULT ' ',"
						+ "`StationName4` VARCHAR(100) NOT NULL DEFAULT ' ',"
						+ "`StationName5` VARCHAR(100) NOT NULL DEFAULT ' ',"
						+ "`StationName6` VARCHAR(100) NOT NULL DEFAULT ' ',"
						+ "`StationName7` VARCHAR(100) NOT NULL DEFAULT ' ',"
						+ "`StationName8` VARCHAR(100) NOT NULL DEFAULT ' ',"
						+ "`StationName9` VARCHAR(100) NOT NULL DEFAULT ' ',"
						+ "`StationIP` VARCHAR(20) NOT NULL DEFAULT '0',"
						+ "`PowerDeviceId` BIGINT NOT NULL DEFAULT '0',"
						+ "`PowerDeviceIp` VARCHAR(50) NOT NULL DEFAULT '192.168.0.88',"
						+ "`PowerDeviceName` VARCHAR(100) NOT NULL DEFAULT '0',"
						+ "`ProtocolName` VARCHAR(100) NOT NULL DEFAULT '0',"
						+ "`DeviceId` VARCHAR(20) NOT NULL DEFAULT '0',"
						+ "`DeviceName` VARCHAR(100) NOT NULL DEFAULT '0',"
						+ "`PowerProducer` VARCHAR(45) NOT NULL DEFAULT '0',"
						+ "`PowerProductDate` DATE NOT NULL DEFAULT '2006-07-06',"
						+ "`PowerInUseDate` DATE NOT NULL DEFAULT '2006-07-06',"
						+ "INDEX index_station_id (`StationId`), "
						+ "INDEX index_powerdev_id (`PowerDeviceId`), "
						+ "INDEX index_station_name (`StationName`), "
						+ "PRIMARY KEY (`num`)) "
						+ "ENGINE=InnoDB DEFAULT CHARSET=utf8;";
		
		String table_5 = "CREATE TABLE IF NOT EXISTS " + PWRAPP_SYS_TABLE
						+ " (`num` int(11) NOT NULL AUTO_INCREMENT,"
						+ "`SqlDB_Version` float NOT NULL DEFAULT '1',"
						+ "`SqlDB_BackUpTime` datetime NOT NULL DEFAULT '2000-01-01 00:00:00',"
						+ "`SqlDB_BackUpManual_EN` tinyint(1) NOT NULL DEFAULT '0',"
						+ "`AppServer_Reinit_PowerData_EN` tinyint(1) NOT NULL DEFAULT '0',"
						+ "`AppServer_Reinit_Config_EN` tinyint(1) NOT NULL DEFAULT '0',"
						+ "`AppServer_Version` float NOT NULL DEFAULT '1',"
						+ "`AppClient_Version` float NOT NULL DEFAULT '1',"
						+ "`AppName` varchar(50) NOT NULL DEFAULT '0',"
						+ "PRIMARY KEY (`num`)) "
						+ "ENGINE=InnoDB DEFAULT CHARSET=utf8;";
		
		String table_2_0 = "DROP TABLE IF EXISTS " + PWRDEV_ACDATA_TABLE;
		String table_2 = "CREATE TABLE IF NOT EXISTS " + PWRDEV_ACDATA_TABLE
						+ "( `num`  bigint NOT NULL AUTO_INCREMENT ,"
						+ "`PowerDeviceId`  bigint NOT NULL DEFAULT 0 ,"
						+ "`record_datetime`  datetime NOT NULL DEFAULT  '2005-1-1 00:00:00' ,"
						+ "`acIn1_volA`  float NOT NULL DEFAULT 0 ,"
						+ "`acIn1_volB`  float NOT NULL DEFAULT 0 ,"
						+ "`acIn1_volC`  float NOT NULL DEFAULT 0 ,"
						+ "`acIn1_currA`  float NOT NULL DEFAULT 0 ,"
						+ "`acIn1_currB`  float NOT NULL DEFAULT 0 ,"
						+ "`acIn1_currC`  float NOT NULL DEFAULT 0 ,"
						+ "`acIn2_volA`  float NOT NULL DEFAULT 0 ,"
						+ "`acIn2_volB`  float NOT NULL DEFAULT 0 ,"
						+ "`acIn2_volC`  float NOT NULL DEFAULT 0 ,"
						+ "`acIn2_currA`  float NOT NULL DEFAULT 0 ,"
						+ "`acIn2_currB`  float NOT NULL DEFAULT 0 ,"
						+ "`acIn2_currC`  float NOT NULL DEFAULT 0 ,"
						+ "`temprature`  float NOT NULL DEFAULT 0 ,"
						+ "`acVolH_Limit`  float NOT NULL DEFAULT 0 ,"
						+ "`acVolL_Limit`  float NOT NULL DEFAULT 0 ,"
						
						+ "`is_acIn1_powerdown`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn2_powerdown`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn1_thunder_err`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn2_thunder_err`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn1_trip`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn2_trip`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn1_over_volA`  tinyint(1) NOT NULL DEFAULT 0 ,"
						+ "`is_acIn1_under_volA`  tinyint(1) NOT NULL DEFAULT 0 ,"
						+ "`is_acIn1_less_A`  tinyint(1) NOT NULL DEFAULT 0 ,"
						+ "`is_acIn1_over_volB`  tinyint(1) NOT NULL DEFAULT 0 ,"
						+ "`is_acIn1_under_volB`  tinyint(1) NOT NULL DEFAULT 0 ,"
						+ "`is_acIn1_less_B`  tinyint(1) NOT NULL DEFAULT 0, "			
						+ "`is_acIn1_over_volC`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn1_under_volC`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn1_less_C`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn2_over_volA`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn2_under_volA`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn2_less_A`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn2_over_volB`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn2_under_volB`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn2_less_B`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn2_over_volC`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn2_under_volC`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn2_less_C`  tinyint(1) NOT NULL DEFAULT 0, "
						
						+ "`is_acIn1_monitorerr`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn1_fuse`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn2_fuse`  tinyint(1) NOT NULL DEFAULT 0, ";
						
						String ss;
						for(int i=0;i<PowerDev_acData.AC_SW_COUNT_AT_FSW;i++)
						{
							ss = "`is_fsw1_sw"+(i+1)+"_trip` "+" tinyint(1) NOT NULL DEFAULT 0, ";
							table_2 += ss;
						}
						for(int i=0;i<PowerDev_acData.AC_SW_COUNT_AT_FSW;i++)
						{
							ss = "`is_fsw2_sw"+(i+1)+"_trip` "+" tinyint(1) NOT NULL DEFAULT 0, ";
							table_2 += ss;
						}
						
				table_2 += "`is_total_alarm`  tinyint(1) NOT NULL DEFAULT 0, "	
						+ "`is_ac_tempAlarm`  tinyint(1) NOT NULL DEFAULT 0, "						
						+ "INDEX index_powerdev_id (`PowerDeviceId`), "
						+ "PRIMARY KEY (`num`)) "
						+ "ENGINE=InnoDB DEFAULT CHARSET=utf8;";
		
		String table_3_0 = "DROP TABLE IF EXISTS " + PWRDEV_ACDCDATA_TABLE;
		String table_3 = "CREATE TABLE IF NOT EXISTS " + PWRDEV_ACDCDATA_TABLE
						+ "( `num`  bigint NOT NULL AUTO_INCREMENT ,"
						+ "`PowerDeviceId`  bigint NOT NULL DEFAULT 0 ,"
						+ "`record_datetime`  datetime NOT NULL DEFAULT  '2005-1-1 00:00:00' ,"
						+ "`acIn1_volA`  float NOT NULL DEFAULT 0 ,"
						+ "`acIn1_volB`  float NOT NULL DEFAULT 0 ,"
						+ "`acIn1_volC`  float NOT NULL DEFAULT 0 ,"
						+ "`acIn2_volA`  float NOT NULL DEFAULT 0 ,"
						+ "`acIn2_volB`  float NOT NULL DEFAULT 0 ,"
						+ "`acIn2_volC`  float NOT NULL DEFAULT 0 ,"
						+ "`acOut_volA`  float NOT NULL DEFAULT 0 ,"
						+ "`acOut_volB`  float NOT NULL DEFAULT 0 ,"
						+ "`acOut_volC`  float NOT NULL DEFAULT 0 ,"
						+ "`acOut_currA`  float NOT NULL DEFAULT 0 ,"
						+ "`acOut_currB`  float NOT NULL DEFAULT 0 ,"
						+ "`acOut_currC`  float NOT NULL DEFAULT 0 ,"		
						+ "`dcOut_vol`  float NOT NULL DEFAULT 0 ,"
						+ "`dcOut_curr`  float NOT NULL DEFAULT 0 ,"
						+ "`battgroup1_vol`  float NOT NULL DEFAULT 0 ,"
						+ "`battgroup1_curr`  float NOT NULL DEFAULT 0 ,"
						+ "`battgroup2_vol`  float NOT NULL DEFAULT 0 ,"
						+ "`battgroup2_curr`  float NOT NULL DEFAULT 0 ,"
						+ "`temprature`  float NOT NULL DEFAULT 0 ,"
						+ "`m_outputvol`  float NOT NULL DEFAULT 0 ,";
		
						String tmpstr;
						for(int i=0;i<PowerDev_acdcData.AC_DC_NUM_IN_SYS;i++)
						{
							tmpstr = "`m"+(i+1)+"_outCurr` "+" float NOT NULL DEFAULT 0 ,";
							table_3 += tmpstr;
						}
						
				table_3 += "`is_acIn1_over_volA`  tinyint(1) NOT NULL DEFAULT 0 ,"
						+ "`is_acIn1_under_volA`  tinyint(1) NOT NULL DEFAULT 0 ,"
						+ "`is_acIn1_less_A`  tinyint(1) NOT NULL DEFAULT 0 ,"
						+ "`is_acIn1_over_volB`  tinyint(1) NOT NULL DEFAULT 0 ,"
						+ "`is_acIn1_under_volB`  tinyint(1) NOT NULL DEFAULT 0,"
						+ "`is_acIn1_less_B`  tinyint(1) NOT NULL DEFAULT 0, "			
						+ "`is_acIn1_over_volC`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn1_under_volC`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn1_less_C`  tinyint(1) NOT NULL DEFAULT 0, "			
						+ "`is_acIn1_thunder_err`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn1_powerdown`  tinyint(1) NOT NULL DEFAULT 0, "				
						+ "`is_acIn2_over_volA`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn2_under_volA`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn2_less_A`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn2_over_volB`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn2_under_volB`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn2_less_B`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn2_over_volC`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn2_under_volC`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn2_less_C`  tinyint(1) NOT NULL DEFAULT 0, "				
						+ "`is_acIn2_thunder_err`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn2_powerdown`  tinyint(1) NOT NULL DEFAULT 0, "		
						+ "`is_acIn_monitorerr`  tinyint(1) NOT NULL DEFAULT 0, "		
						+ "`is_dcOut_over_vol`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_dcOut_under_vol`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_battgroup_down`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_jun_charge`  tinyint(1) NOT NULL DEFAULT 0, ";
				
						for(int i=0;i<PowerDev_acdcData.AC_DC_NUM_IN_SYS;i++)
						{
							tmpstr = "`is_acdcMod"+(i+1)+"_err` "+" tinyint(1) NOT NULL DEFAULT 0, ";
							table_3 += tmpstr;
							
							tmpstr = "`is_acdcMod"+(i+1)+"_off` "+" tinyint(1) NOT NULL DEFAULT 1, ";
							table_3 += tmpstr;
						}
						
				table_3 += "`is_acIn1_trip`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn2_trip`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_loader_fuse`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_battgroup1_fuse`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_battgroup2_fuse`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_total_alarm`  tinyint(1) NOT NULL DEFAULT 0, ";						
						//+ "INDEX index_powerdev_id (`PowerDeviceId`), "
						//+ "PRIMARY KEY (`num`)) "
						//+ "ENGINE=InnoDB DEFAULT CHARSET=utf8;";
				//----------------------------------------------------------------
				//----------------------------------------------------------------
				table_3 += "`acIn1_currA`  float NOT NULL DEFAULT 0 ,"
						+ "`acIn1_currB`  float NOT NULL DEFAULT 0 ,"
						+ "`acIn1_currC`  float NOT NULL DEFAULT 0 ,"
						+ "`loader_curr`  float NOT NULL DEFAULT 0 ,"
						+ "`battgroup1_ah`  float NOT NULL DEFAULT 0 ,"
						+ "`battgroup1_temp`  float NOT NULL DEFAULT 0 ,"
						+ "`battgroup2_ah`  float NOT NULL DEFAULT 0 ,"
						+ "`battgroup2_temp`  float NOT NULL DEFAULT 0 ,"
						+ "`acdcm_temp`  float NOT NULL DEFAULT 0 ,";
						for(int i=0;i<PowerDev_acdcData.AC_DC_NUM_IN_SYS;i++)
						{
							tmpstr = "`m"+(i+1)+"_out_vol` "+" float NOT NULL DEFAULT 0 ,";
							table_3 += tmpstr;
						}
						
				table_3 += "`is_acb1_over_currA`  tinyint(1) NOT NULL DEFAULT 0 ,"
						+ "`is_acb1_over_currB`  tinyint(1) NOT NULL DEFAULT 0 ,"
						+ "`is_acb1_over_currC`  tinyint(1) NOT NULL DEFAULT 0 ,"
						+ "`is_acIn1_poweron`  tinyint(1) NOT NULL DEFAULT 0 ,"
						+ "`is_acIn2_poweron`  tinyint(1) NOT NULL DEFAULT 0,"
						+ "`is_dcOut_over_curr`  tinyint(1) NOT NULL DEFAULT 0, "			
						//+ "`is_batt1_under_vol`  tinyint(1) NOT NULL DEFAULT 0, "
						//+ "`is_batt2_under_vol`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_battgroup1_state`  tinyint(1) NOT NULL DEFAULT 0, "			
						+ "`is_battgroup2_state`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_battgroup2_down`  tinyint(1) NOT NULL DEFAULT 0, "				
						+ "`is_battgroup1_overChgCurr`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_battgroup2_overChgCurr`  tinyint(1) NOT NULL DEFAULT 0, ";	
						for(int i=0;i<PowerDev_acdcData.AC_DC_NUM_IN_SYS;i++)
						{
							tmpstr = "`is_acdcMod"+(i+1)+"_overVol` "+" tinyint(1) NOT NULL DEFAULT 0, ";
							table_3 += tmpstr;
							tmpstr = "`is_acdcMod"+(i+1)+"_underVol` "+" tinyint(1) NOT NULL DEFAULT 0, ";
							table_3 += tmpstr;
							tmpstr = "`is_acdcMod"+(i+1)+"_overCurr` "+" tinyint(1) NOT NULL DEFAULT 0, ";
							table_3 += tmpstr;
							tmpstr = "`is_acdcMod"+(i+1)+"_acErr` "+" tinyint(1) NOT NULL DEFAULT 0, ";
							table_3 += tmpstr;
							tmpstr = "`is_acdcMod"+(i+1)+"_limitCurr` "+" tinyint(1) NOT NULL DEFAULT 0, ";
							table_3 += tmpstr;
						}
						
				table_3 += "`is_acIn1_fuse`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn2_fuse`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn1_unbanlance`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn2_unbanlance`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn1_freqerr`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn2_freqerr`  tinyint(1) NOT NULL DEFAULT 0, "					
						+ "`is_battgroup1_volLow`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_battgroup2_volLow`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_dcOut_total_alarm`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_acIn_total_alarm`  tinyint(1) NOT NULL DEFAULT 0, ";
						
				//1+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
				for(int i=0;i<PowerDev_acdcData.AC_DC_NUM_IN_SYS;i++){
					tmpstr = "`is_acdcMod"+(i+1)+"_junChg` "+" tinyint(1) NOT NULL DEFAULT 0, ";
					table_3 += tmpstr;
				}
				
				table_3 +=" `is_powerdev_commErr`  tinyint(1) NOT NULL DEFAULT 0, ";
				
				table_3 += "`userAcIn1_volA`  float NOT NULL DEFAULT 0 ,"
						+ "`userAcIn1_volB`  float NOT NULL DEFAULT 0 ,"
						+ "`userAcIn1_volC`  float NOT NULL DEFAULT 0 ,"
						+ "`userAcIn1_currA`  float NOT NULL DEFAULT 0 ,"
						+ "`userAcIn1_currB`  float NOT NULL DEFAULT 0 ,"
						+ "`userAcIn1_currC`  float NOT NULL DEFAULT 0 ,"
						+ "`userAcIn1_freq`  float NOT NULL DEFAULT 0 ,"
						+ "`userAcIn2_volA`  float NOT NULL DEFAULT 0 ,"
						+ "`userAcIn2_volB`  float NOT NULL DEFAULT 0 ,"
						+ "`userAcIn2_volC`  float NOT NULL DEFAULT 0 ,"
						+ "`userAcIn2_currA`  float NOT NULL DEFAULT 0 ,"
						+ "`userAcIn2_currB`  float NOT NULL DEFAULT 0 ,"
						+ "`userAcIn2_currC`  float NOT NULL DEFAULT 0 ,"
						+ "`userAcIn2_freq`  float NOT NULL DEFAULT 0 ,";
				
				for(int i=0;i<EnvmDev_Data.ENVM_TEMP_CNT_MAX;i++)
				{
					tmpstr = "`m_temper"+(i+1)+"` "+" float NOT NULL DEFAULT 0 ,";
					table_3 += tmpstr;
				}
				
				for(int i=0;i<EnvmDev_Data.ENVM_HUMI_CNT_MAX;i++)
				{
					tmpstr = "`m_humidity"+(i+1)+"` "+" float NOT NULL DEFAULT 0 ,";
					table_3 += tmpstr;
				}
				
				table_3 +=" `userAcIn1_PowerDown`  tinyint(1) NOT NULL DEFAULT 0, "
						+ " `userAcIn1_CommErr`  tinyint(1) NOT NULL DEFAULT 0, "
						+ " `userAcIn2_PowerDown`  tinyint(1) NOT NULL DEFAULT 0, "
						+ " `userAcIn2_CommErr`  tinyint(1) NOT NULL DEFAULT 0, ";
				
				for(int i=0;i<EnvmDev_Data.ENVM_TEMP_CNT_MAX;i++)
				{
					//tmpstr = "`is_TempH_Alarm"+(i+1)+"` "+" tinyint(1) NOT NULL DEFAULT 0, ";
					//table_3 += tmpstr;
					//tmpstr = "`is_TempL_Alarm"+(i+1)+"` "+" tinyint(1) NOT NULL DEFAULT 0, ";
					//table_3 += tmpstr;
					tmpstr = "`is_Temp_CommErr"+(i+1)+"` "+" tinyint(1) NOT NULL DEFAULT 0, ";
					table_3 += tmpstr;
				}
				
				for(int i=0;i<EnvmDev_Data.ENVM_HUMI_CNT_MAX;i++)
				{
					//tmpstr = "`is_HumiH_Alarm"+(i+1)+"` "+" tinyint(1) NOT NULL DEFAULT 0, ";
					//table_3 += tmpstr;
					//tmpstr = "`is_HumiL_Alarm"+(i+1)+"` "+" tinyint(1) NOT NULL DEFAULT 0, ";
					//table_3 += tmpstr;
					tmpstr = "`is_Humi_CommErr"+(i+1)+"` "+" tinyint(1) NOT NULL DEFAULT 0, ";
					table_3 += tmpstr;
				}
				
				for(int i=0;i<EnvmDev_Data.ENVM_SMOKE_CNT_MAX;i++)
				{
					tmpstr = "`is_Smoke_Alarm"+(i+1)+"` "+" tinyint(1) NOT NULL DEFAULT 0, ";
					table_3 += tmpstr;
					tmpstr = "`is_Smoke_CommErr"+(i+1)+"` "+" tinyint(1) NOT NULL DEFAULT 0, ";
					table_3 += tmpstr;
				}
				
				table_3 += "`chargLimitCurr`  float NOT NULL DEFAULT 0 ,"
						+ "`junChargeVol`  float NOT NULL DEFAULT 0 ,"
						+ "`floatChargeVol`  float NOT NULL DEFAULT 0 ,"
						+ "`acVolH_Limit`  float NOT NULL DEFAULT 0 ,"
						+ "`acVolL_Limit`  float NOT NULL DEFAULT 0 ,"
						+ "`dcOutVolH_Limit`  float NOT NULL DEFAULT 0 ,"
						+ "`dcOutVolL_Limit`  float NOT NULL DEFAULT 0 ,"
						+ "`acInUseCount`  tinyint NOT NULL DEFAULT 0 , ";
				
				table_3 +=" INDEX index_powerdev_id (`PowerDeviceId`), "
						+ "PRIMARY KEY (`num`)) "
						+ "ENGINE=InnoDB DEFAULT CHARSET=utf8;";
		
				String table_4_0 = "DROP TABLE IF EXISTS " + PWRDEV_DCDATA_TABLE;
				String table_4 = "CREATE TABLE IF NOT EXISTS " + PWRDEV_DCDATA_TABLE
						+ "( `num`  bigint NOT NULL AUTO_INCREMENT ,"
						+ "`PowerDeviceId`  bigint NOT NULL DEFAULT 0 ,"
						+ "`record_datetime`  datetime NOT NULL DEFAULT  '2005-1-1 00:00:00' ,"
						+ "`dcIn1_vol`  float NOT NULL DEFAULT 0 ,"
						+ "`dcIn2_vol`  float NOT NULL DEFAULT 0 ,"
						+ "`dcOut1_vol`  float NOT NULL DEFAULT 0 ,"
						+ "`dcOut1_curr`  float NOT NULL DEFAULT 0 ,"
						+ "`dcOut2_vol`  float NOT NULL DEFAULT 0 ,"
						+ "`dcOut2_curr`  float NOT NULL DEFAULT 0 ,"
						+ "`temprature`  float NOT NULL DEFAULT 0 ,"
						+ "`dcVolH_Limit`  float NOT NULL DEFAULT 0 ,"
						+ "`dcVolL_Limit`  float NOT NULL DEFAULT 0 ,"
						
						+ "`is_dc1_over_vol`  tinyint(1) NOT NULL DEFAULT 0 ,"
						+ "`is_dc1_under_vol`  tinyint(1) NOT NULL DEFAULT 0 ,"
						+ "`is_dc2_over_vol`  tinyint(1) NOT NULL DEFAULT 0 ,"
						+ "`is_dc2_under_vol`  tinyint(1) NOT NULL DEFAULT 0 ,"
						+ "`is_in1_swtrip`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`is_in2_swtrip`  tinyint(1) NOT NULL DEFAULT 0, ";
					
						String ssdc;
						for(int i=0;i<PowerDev_dcData.DC_SW_COUNT_AT_FSW;i++)
						{
							ssdc = "`is_fsw1_sw"+(i+1)+"_trip` "+" tinyint(1) NOT NULL DEFAULT 0, ";
							table_4 += ssdc;
						}
						for(int i=0;i<PowerDev_dcData.DC_SW_COUNT_AT_FSW;i++)
						{
							ssdc = "`is_fsw2_sw"+(i+1)+"_trip` "+" tinyint(1) NOT NULL DEFAULT 0, ";
							table_4 += ssdc;
						}
						
				table_4 += "`is_tempalarm`  tinyint(1) NOT NULL DEFAULT 0, "	
						+ "`is_dc_monitorerr`  tinyint(1) NOT NULL DEFAULT 0,"
						+ "`is_total_alarm`  tinyint(1) NOT NULL DEFAULT 0, "						
						+ "INDEX index_powerdev_id (`PowerDeviceId`), "
						+ "PRIMARY KEY (`num`)) "
						+ "ENGINE=InnoDB DEFAULT CHARSET=utf8;";
		
		String table_6 = "CREATE TABLE IF NOT EXISTS " + PWRDEV_ALARM_TABLE
						+ "( `num` BIGINT NOT NULL AUTO_INCREMENT, "
						+ "`record_id` BIGINT NOT NULL DEFAULT 0, "
						+ "`PowerDeviceId` BIGINT NOT NULL DEFAULT 0, "
						+ "`alm_type` INT NOT NULL DEFAULT 0, "
						+ "`alm_level` INT NOT NULL DEFAULT 0, "
						+ "`alm_source` INT NOT NULL DEFAULT 0, "
						+ "`alm_index` INT NOT NULL DEFAULT 0, "
						+ "`alm_start_time` DATETIME NOT NULL DEFAULT '1982-01-01 00:00:00', "
						+ "`alm_end_time` DATETIME NOT NULL DEFAULT '1982-01-01 00:00:00', "
						+ "`alm_value` float NOT NULL DEFAULT '0',"
						+ "`alm_is_confirmed` tinyint(1) NOT NULL DEFAULT false, "
						+ "`alm_confirmed_time` DATETIME NOT NULL DEFAULT '1982-01-01 00:00:00', "
						+ "`alm_cleared_type` INT NOT NULL DEFAULT 0, "
						+ "`usr_Id` INT NOT NULL DEFAULT 0, "
						+ "INDEX index_record_id (`record_id`), "
						+ "INDEX index_pwrdev_id (`PowerDeviceId`), "
						+ "INDEX index_alm_type (`alm_type`), "
						+ "INDEX index_alm_start_time (`alm_start_time`), "
						+ "INDEX index_alm_cleared_type (`alm_cleared_type`), "
						+ "PRIMARY KEY (`num`)) "
						+ "ENGINE=InnoDB DEFAULT CHARSET=utf8;";
		
		String table_7 = "CREATE TABLE IF NOT EXISTS " + PWRDEV_ALARM_HISTORY_TABLE
						+ "( `num` BIGINT NOT NULL AUTO_INCREMENT, "
						+ "`record_id` BIGINT NOT NULL DEFAULT 0, "
						+ "`PowerDeviceId` BIGINT NOT NULL DEFAULT 0, "
						+ "`alm_type` INT NOT NULL DEFAULT 0, "
						+ "`alm_level` INT NOT NULL DEFAULT 0, "
						+ "`alm_source` INT NOT NULL DEFAULT 0, "
						+ "`alm_index` INT NOT NULL DEFAULT 0, "
						+ "`alm_start_time` DATETIME NOT NULL DEFAULT '1982-01-01 00:00:00', "
						+ "`alm_end_time` DATETIME NOT NULL DEFAULT '1982-01-01 00:00:00', "
						+ "`alm_value` float NOT NULL DEFAULT '0',"
						+ "`alm_is_confirmed` tinyint(1) NOT NULL DEFAULT false, "
						+ "`alm_confirmed_time` DATETIME NOT NULL DEFAULT '1982-01-01 00:00:00', "
						+ "`alm_cleared_type` INT NOT NULL DEFAULT 0, "
						+ "`usr_Id` INT NOT NULL DEFAULT 0, "
						+ "INDEX index_record_id (`record_id`), "
						+ "INDEX index_pwrdev_id (`PowerDeviceId`), "
						+ "INDEX index_alm_type (`alm_type`), "
						+ "INDEX index_alm_start_time (`alm_start_time`), "
						+ "INDEX index_alm_cleared_type (`alm_cleared_type`), "
						+ "PRIMARY KEY (`num`)) "
						+ "ENGINE=InnoDB DEFAULT CHARSET=utf8;";
		
		String table_8 = "CREATE TABLE IF NOT EXISTS " + PWRDEV_STAINF_TABLE
				+ "( `num` BIGINT NOT NULL AUTO_INCREMENT, "
				+ "`PowerDeviceId` BIGINT NOT NULL DEFAULT 0, "
				+ "`RunCompany` VARCHAR(100) NOT NULL DEFAULT ' ',"  //运维单位
				+ "`HistoryAlarmRelatRecord` VARCHAR(100) NOT NULL DEFAULT ' ',"  //历史告警关联统计"
				+ "INDEX index_pwrdev_id (`PowerDeviceId`), "
				+ "PRIMARY KEY (`num`)) "
				+ "ENGINE=InnoDB DEFAULT CHARSET=utf8;";
		
		String table_9 = "CREATE TABLE IF NOT EXISTS " + PWRDEV_ACINF_TABLE
				+ "( `num` BIGINT NOT NULL AUTO_INCREMENT, "
				+ "`PowerDeviceId` BIGINT NOT NULL DEFAULT 0, "
				+ "`InputSWCount` INT NOT NULL DEFAULT 0, "  //输入开关数量
				+ "`OutputSWCount` INT NOT NULL DEFAULT 0, " //输出开关数量
				+ "`Cap` INT NOT NULL DEFAULT 0, "  //容量
				+ "`UsePurPose` VARCHAR(100) NOT NULL DEFAULT ' ',"  //用途
				+ "INDEX index_pwrdev_id (`PowerDeviceId`), "
				+ "PRIMARY KEY (`num`)) "
				+ "ENGINE=InnoDB DEFAULT CHARSET=utf8;";
		
		String table_10 = "CREATE TABLE IF NOT EXISTS " + PWRDEV_ACDCINF_TABLE
				+ "( `num` BIGINT NOT NULL AUTO_INCREMENT, "
				+ "`PowerDeviceId` BIGINT NOT NULL DEFAULT 0, "
				+ "`ModuleInUseCount` INT NOT NULL DEFAULT 0, " //在用模块数量
				+ "`ModuleCap` INT NOT NULL DEFAULT 0, "  		//模块额定容量容量
				+ "`ModuleSlotCount` INT NOT NULL DEFAULT 0, " 	//模块总插槽数
				+ "INDEX index_pwrdev_id (`PowerDeviceId`), "
				+ "PRIMARY KEY (`num`)) "
				+ "ENGINE=InnoDB DEFAULT CHARSET=utf8;";
		
		String table_11 = "CREATE TABLE IF NOT EXISTS " + PWRDEV_DCINF_TABLE
				+ "( `num` BIGINT NOT NULL AUTO_INCREMENT, "
				+ "`PowerDeviceId` BIGINT NOT NULL DEFAULT 0, "
				+ "`InputSWCount` INT NOT NULL DEFAULT 0, "  //输入开关数量
				+ "`OutputSWCount` INT NOT NULL DEFAULT 0, " //输出开关数量
				+ "`Cap` INT NOT NULL DEFAULT 0, "  //容量
				+ "`UsePurPose` VARCHAR(100) NOT NULL DEFAULT ' ',"  //用途
				+ "INDEX index_pwrdev_id (`PowerDeviceId`), "
				+ "PRIMARY KEY (`num`)) "
				+ "ENGINE=InnoDB DEFAULT CHARSET=utf8;";
		
		String table_12_0 = "DROP TABLE IF EXISTS " + PWRDEV_RT_INFO_TABLE;
		String table_12 = "CREATE TABLE IF NOT EXISTS " + PWRDEV_RT_INFO_TABLE
						+ "( `num`  bigint NOT NULL AUTO_INCREMENT ,"
						+ "`PowerDeviceId`  bigint NOT NULL DEFAULT 0 ,"
						+ "`record_datetime`  datetime NOT NULL DEFAULT  '2005-1-1 00:00:00' ,"
						+ "`CommTxCount`  INT NOT NULL DEFAULT 0 ,"
						+ "`CommSuccessCount`  INT NOT NULL DEFAULT 0 ,"					
						+ "INDEX index_powerdev_id (`PowerDeviceId`), "
						+ "PRIMARY KEY (`num`)) "
						+ "ENGINE=InnoDB DEFAULT CHARSET=utf8;";
		
		String table_13 = "CREATE TABLE IF NOT EXISTS " + PWRDEV_ALARM_CONFIG_TABLE
						+ " ( `num`  bigint NOT NULL AUTO_INCREMENT ,"
						+ "`SMS_CommPort` VARCHAR(10) NOT NULL DEFAULT ' ',"
						+ "`SMS_CommPort_ReInit`  tinyint(1) NOT NULL DEFAULT 0,"
						+ "`Beeper_CommPort` VARCHAR(10) NOT NULL DEFAULT ' ',"
						+ "`Beeper_CommPort_ReInit`  tinyint(1) NOT NULL DEFAULT 0,"
						+ "`SMS_Alarm_Text` VARCHAR(100) NOT NULL DEFAULT ' ',"
						+ "`SMS_Alarm_EN`  tinyint(1) NOT NULL DEFAULT 0,"
						+ "`Beeper_Alarm_EN`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`Beeper_Sound_OFF`  tinyint(1) NOT NULL DEFAULT 0, "
						+ "`AlarmDevIP`  VARCHAR(30) NOT NULL DEFAULT '192.168.10.223',"
						+ "`SMS_Alarm_ipPort`  INT NOT NULL DEFAULT 26,"
						+ "`Beeper_Alarm_ipPort`  INT NOT NULL DEFAULT 27,"
						+ "PRIMARY KEY (`num`)) "
						+ "ENGINE=InnoDB DEFAULT CHARSET=utf8;";
		
		String table_14_0 = "DROP TABLE IF EXISTS " + PWRDEV_ALARM_TIMEADJ_TABLE;
		String table_14 = "CREATE TABLE IF NOT EXISTS " + PWRDEV_ALARM_TIMEADJ_TABLE
						+ "( `num`  bigint NOT NULL AUTO_INCREMENT ,"
						+ "`PowerDeviceId`  bigint NOT NULL DEFAULT 0 ,"
						+ "`alarm_typeId`  INT NOT NULL DEFAULT 0 ,"
						+ "`detect_datetime`  datetime NOT NULL DEFAULT  '2005-1-1 00:00:00' ,"
						+ "`record_datetime`  datetime NOT NULL DEFAULT  '2005-1-1 00:00:00' ,"
						+ "INDEX index_powerdev_id (`PowerDeviceId`), "
						+ "PRIMARY KEY (`num`)) "
						+ "ENGINE=InnoDB DEFAULT CHARSET=utf8;";
		
		String table_15_0 = "DROP TABLE IF EXISTS " + PWRDEV_ALARM_TIMEOUT_TABLE;
		String table_15 = "CREATE TABLE IF NOT EXISTS " + PWRDEV_ALARM_TIMEOUT_TABLE
						+ "( `num`  bigint NOT NULL AUTO_INCREMENT ,"
						+ "`PowerDeviceId`  bigint NOT NULL DEFAULT 0 ,"
						+ "`alarm_typeId`  INT NOT NULL DEFAULT 0 ,"
						+ "`alarm_index`  INT NOT NULL DEFAULT 0 ,"
						+ "`timeout_tag`  INT NOT NULL DEFAULT 0 ,"
						+ "`read_datetime`  datetime NOT NULL DEFAULT  '2005-1-1 00:00:00' ,"
						+ "`system_datetime`  datetime NOT NULL DEFAULT  '2005-1-1 00:00:00' ,"
						+ "`resume_datetime`  datetime NOT NULL DEFAULT  '2005-1-1 00:00:00' ,"
						+ "INDEX index_powerdev_id (`PowerDeviceId`), "
						+ "PRIMARY KEY (`num`)) "
						+ "ENGINE=InnoDB DEFAULT CHARSET=utf8;";
		
		String table_16 = "CREATE TABLE IF NOT EXISTS" + Sql_Mysql.PWRDEV_ALARM_PARAM_MB_TABLE+" "
				+ "( `num` BIGINT NOT NULL AUTO_INCREMENT, "
				+ "`alarm_id` BIGINT NOT NULL DEFAULT 0, "
				+ "`alarm_limitH` float NOT NULL DEFAULT 0, "
				+ "`alarm_limitL` float NOT NULL DEFAULT 0, "
				+ "`alarm_limitEn` INT NOT NULL DEFAULT 0, "
				+ "`UserAlarm_EN` INT NOT NULL DEFAULT 1, "
				+ "`alarm_level` INT NOT NULL DEFAULT 0, "
				+ "`alarm_devtype` INT NOT NULL DEFAULT 0, "
				+ "`alarm_name` VARCHAR(100) NOT NULL DEFAULT '0', "

				+ "INDEX index_alarm_id (`alarm_id`), "
				+ "UNIQUE KEY `unique_alarm_id` (`alarm_id`), "
				+ "PRIMARY KEY (`num`)) "
				+ "ENGINE=InnoDB DEFAULT CHARSET=utf8;";

		//logger.info(table_1);
		//logger.info(table_2);
		//logger.info(table_3);
		//logger.info(table_13);
		
		//sqlMysqlExecute(table_2_0);
		//sqlMysqlExecute(table_3_0);
		//sqlMysqlExecute(table_4_0);
		sqlMysqlExecute(table_12_0);
		sqlMysqlExecute(table_14_0);
		sqlMysqlExecute(table_15_0);
		
		sqlMysqlExecute(table_1);
		sqlMysqlExecute(table_5);
		sqlMysqlExecute(table_2);
		sqlMysqlExecute(table_3);
		sqlMysqlExecute(table_4);
		sqlMysqlExecute(table_6);
		sqlMysqlExecute(table_7);
		sqlMysqlExecute(table_8);
		sqlMysqlExecute(table_9);
		sqlMysqlExecute(table_10);
		sqlMysqlExecute(table_11);
		sqlMysqlExecute(table_12);
		sqlMysqlExecute(table_13);
		sqlMysqlExecute(table_14);
		sqlMysqlExecute(table_15);
		sqlMysqlExecute(table_16);
	}
	
	//使用db数据库
	public void sqlMysqlUseDB(String db) throws SQLException
	{
		sqlMysqlExecute("USE " + db);
	}
	
	/**
	 * 检查tb表是否存在
	 * @param tb
	 * @return
	 * @throws SQLException
	 */
	public boolean sqlMysqlCheckIfTableExist(String tb) throws SQLException
	{
		String sql_str = "SHOW TABLES LIKE '" + tb + "'";
		ResultSet res = sqlMysqlQuery(sql_str);
		boolean exist = false;
		while(res.next())
		{
			exist = true;
			break;
		}
		
		return exist;
	}
	
	//执行sql语句
	public void sqlMysqlExecute(String sql_str) throws SQLException
	{
		Statement sql = mysql_con.createStatement();
		sql.setQueryTimeout(30);
		sql.execute(sql_str);
	}
	
	//执行sql语句
	public void sqlMysqlTotalExecute(String sql_str) throws SQLException
	{
		Statement sql = mysql_con.createStatement();
		sql.setQueryTimeout(5*60);
		sql.execute(sql_str);
	}
	
	
	//在事物中执行多条sql语句
	public boolean makeManualCommit(ArrayList<String> al_sql_strs) 
	{
		boolean exe_res = true;
		try {
			mysql_con.setAutoCommit(false);
			
			for(int n=0; n<al_sql_strs.size(); n++) {
				sqlMysqlExecute(al_sql_strs.get(n));
			}
			
			if(true == exe_res) {
				mysql_con.commit();
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			exe_res = false;
		} finally {
			try {
				if(false == exe_res) {
					mysql_con.rollback();
				}
				mysql_con.setAutoCommit(true);
			} catch (SQLException e1) {
				// TODO Auto-generated catch block
				e1.printStackTrace();
			}
		}
		
		return exe_res;
	}
	
	//根据sql语句执行sql查询语句
	public ResultSet sqlMysqlQuery(String sql_str)
	{
		ResultSet res = null;
		try
    	{
			Statement sql = mysql_con.createStatement();
			sql.setQueryTimeout(30);
			String query = sql_str;
			res =  sql.executeQuery(query);
    	}
    	catch(SQLException ex)
		{
			//System.err.println("SQLException:" + ex.getMessage());
    		logger.error(ex.toString(), ex);
		}
		
		return res;
	}
	
	//根据sql语句执行sql查询语句
	public ResultSet sqlMysqlTotalQuery(String sql_str)
	{
		ResultSet res = null;
		try
    	{
			Statement sql = mysql_con.createStatement();
			sql.setQueryTimeout(5*60);
			String query = sql_str;
			res =  sql.executeQuery(query);
    	}
    	catch(SQLException ex)
		{
			//System.err.println("SQLException:" + ex.getMessage());
    		logger.error(ex.toString(), ex);
		}
		
		return res;
	}
	
	//根据sql语句执行sql更新语句
	public void sqlMysqlUpdate(String sql_str)
	{
		try
    	{
			Statement sql = mysql_con.createStatement();
			sql.setQueryTimeout(30);
			String query = sql_str;
			sql.execute(query);
    	}
    	catch(SQLException ex)
		{
			//System.out.println("SQLException:" + ex.getMessage());
    		logger.error(ex.toString(), ex);
		}
	}
}