package web158.com;
/**
 * @param 李建東
 * 
 * 聯系電話:0898-62925341
 * 
 * 聯系QQ:813751  657597  8912740
 * 
 * 網   址:
 * 			http://www.web156.com
 *			http://www.web158.com
 */
import java.sql.*;
import java.awt.*;
import javax.swing.*;
class Web158_Com_Server_DBConn{
	String sDBDriver = "com.microsoft.jdbc.sqlserver.SQLServerDriver";
	String sConnStr = "jdbc:microsoft:sqlserver://127.0.0.1:1433;DatabaseName=web158_com";
	String user="sa"; 
	String password=""; 
	Connection conn = null;
	Statement stmt = null;
	ResultSet rs = null;
	public Web158_Com_Server_DBConn ()
	{
		try{
			Class.forName(sDBDriver);
		} 
		catch(java.lang.ClassNotFoundException e){
			System.err.println( e.getMessage());
			JOptionPane.showMessageDialog(null, "數據庫驅動加載錯誤,請檢查!");
			Close();
			System.exit(0);
		}
	}
	//	返回數據庫連接對象
	public Connection Creatconn(){
			conn = null;
    		try{
    		    conn=DriverManager.getConnection(getConfig(),user,password);
    		    return conn;
    		}
    		catch(Exception fe){
    			System.err.println("連接數據庫 " + fe.getMessage());	
    			//JOptionPane.showMessageDialog(null, "服務器連接失敗");
    			JOptionPane.showMessageDialog(null, "連接數據庫失敗,請檢查!");
    			Close();
    			System.exit(0);
    			return null;
		}
    	
  	}
//	返回狀態集對象
	public Statement CreatStat(){ 
		stmt = null;
    	try{
    			conn=this.Creatconn();
      			stmt=conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
      			return stmt;
    		}
    	catch(Exception fe){
    			System.err.println("返回記錄集 " + fe.getMessage());	
    			//JOptionPane.showMessageDialog(null, "返回狀態集失敗");
    			JOptionPane.showMessageDialog(null, "返回狀態集時失敗,請檢查!");
    			Close();
    			return null;
		}
    		
  	}
//	返回記錄集對象
	public ResultSet getResult(String sql){
   		rs = null;
		try{
			stmt = this.CreatStat();
			rs = stmt.executeQuery(sql);
			return rs;
        	} 
		catch(SQLException ex){ 
			System.err.println("getResult: " + ex.getMessage());
			//JOptionPane.showMessageDialog(null, "返回記錄集失敗");
			JOptionPane.showMessageDialog(null, "返回記錄集失敗,請檢查!");
			Close();
			return null;
		}
    		
	}
	//執行更新 刪除語句
	public boolean executeSql(String sql)
	{
		try{
			stmt=this.CreatStat();
			stmt.executeUpdate(sql);
			conn.commit();
			return true;
		}
		catch(Exception e)
		{
			System.err.println("exectueSql: "+e.toString());
			//JOptionPane.showMessageDialog(null, "數據更新失敗");
			JOptionPane.showMessageDialog(null, "更新數據庫失敗,請檢查!");
			Close();
			return false;
		}
		
	}
	public void Close()
	{
		try
		{
			rs.close();
			stmt.close();
			conn.close();
		}
		catch(Exception ef)
		{}
	}
	public String getConfig()
	{
		return sConnStr;
	}
}