package mypackage;

import java.io.*; 
import java.sql.*; 

public class ConnectionDB{
  public Connection conn; 
  public ResultSet rs;
  public int num = 0;
  private String driver="sun.jdbc.odbc.JdbcOdbcDriver"; 
  private String url="jdbc:odbc:MyDB";
	
	//加載數(shù)據(jù)庫(kù)驅(qū)動(dòng)
	public ConnectionDB(){
		try{ 
			Class.forName(driver); 
		} 
		catch(Exception e){ 
			System.err.println("加載驅(qū)動(dòng)器有錯(cuò)誤:"+e.getMessage());
		} 
	} 

	//插入方法                 
	public int executeInsert(String sql){ 
		try{ 
			conn = DriverManager.getConnection(url);
			Statement stmt = conn.createStatement(); 
			num = stmt.executeUpdate(sql); 
		} 
		catch(SQLException e){ 
      System.err.println("執(zhí)行插入有錯(cuò)誤:"+e.getMessage()); 
		}
		finally{
			CloseDataBase();
		}
		return num;
	} 
	
	//查詢方法
	public ResultSet executeQuery(String sql){ 
		try{ 
			conn = DriverManager.getConnection(url);
			Statement stmt = conn.createStatement(); 
			rs = stmt.executeQuery(sql);
		} 
		catch(SQLException e){ 
			System.err.println("執(zhí)行查詢有錯(cuò)誤:"+e.getMessage()); 
		}
		return rs; 
	} 
  
  //更新方法
  public int executeUpdate(String sql){
    try{
      conn = DriverManager.getConnection(url);
      Statement stmt = conn.createStatement();
      num = stmt.executeUpdate(sql);
    }
    catch(SQLException e){
      System.err.println("執(zhí)行更新有錯(cuò)誤:"+e.getMessage()); 
    }
    finally{
      CloseDataBase();
    }
    return num;
  }
	
	//刪除方法
	public int executeDelete(String sql){ 
		try{ 
			conn = DriverManager.getConnection(url);
			Statement stmt = conn.createStatement(); 
			num = stmt.executeUpdate(sql); 
		} 
		catch(SQLException e){ 
			System.err.println("執(zhí)行刪除有錯(cuò)誤:"+e.getMessage());  
		} 
		finally{
			CloseDataBase();
		}
		return num;
	} 
 
	//關(guān)閉數(shù)據(jù)庫(kù)連接
	public void CloseDataBase(){ 
		try{ 
			conn.close(); 
		} 
		catch(Exception e){ 
			System.err.println("執(zhí)行關(guān)閉Connection對(duì)象有錯(cuò)誤："+e.getMessage());
		}
	} 
}