package DAO;
import java.sql.*;

public class OperateDB {
	Connection conn=null;
	Statement smt=null;
	ResultSet rs=null;	
	
	   //連接數據庫
	    public void getConnection()
	    {
	      try {
	    	  Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
	    	  //conn=DriverManager.getConnection("jdbc:odbc:Driver={SQL Server};Server=(Local)\\DB2005;DateBase=DB_Food;uid=sa;pwd=sasa");
	    	  conn=DriverManager.getConnection("jdbc:odbc:test");	         
	      } catch (Exception ex) {
	          System.out.println("數據庫連接失敗"+ex.toString());
	      }
	    }
	    //查詢方法
	    public ResultSet GetQuery(String sql) {	    	
	    	try { 	    		
	    		 this.getConnection();
		    	 smt=conn.createStatement();
		    	 rs=smt.executeQuery(sql);
		         
		      } catch (Exception ex) {
		          System.out.println("查詢數據失敗"+ex.toString());
		      }
		      return rs; 	
	    
	    }
	    //關閉連接	    
	    public void CloseConn()
	    {
	    	try{
	    		this.getConnection();
	    		if(conn.isClosed()==false)
	    		{
	    			rs.close();
		    		conn.close();	    		
	    		}
	    	
	    	}catch(Exception ex){
	    		System.out.println("關閉連接異常！"+ex.toString());   		
	    		
	    	}    	
	    }  
	    
	   //增。刪。改
	    public int ReturnLine(String sql)
	    {
	    	int count=0;
	    	try {
	    		this.getConnection();
	    		smt=conn.createStatement();
	    		count=smt.executeUpdate(sql);
		    	  
		      } catch (Exception ex) {
		    	  System.out.println("增。刪。改數據庫失敗！"+ex.toString());
		          
		      }
		      return count;	     
	    	
	    }
	

}