package com.yxq.toolsbean;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class DB {
    private final String url = "jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=db_Blog";
    private final String userName = "sa";
    private final String password = "sa";
    private Connection con = null;
    private Statement stm=null;
    
    /* 通過構造方法加載數(shù)據(jù)庫驅動 */
    public DB(){
    	try {
    		Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver").newInstance(); 
    	} catch (Exception e) {
    		e.printStackTrace();
    		System.out.println("加載數(shù)據(jù)庫驅動失敗！");
    	}    	
    }
    /* 創(chuàng)建數(shù)據(jù)庫連接 */
    public void createCon() {
        try {
            con = DriverManager.getConnection(url, userName, password);
        } catch (Exception e) {
            e.printStackTrace();
            System.out.println("獲取數(shù)據(jù)庫連接失敗！");
        }
    }
    /* 獲取Statement對象 */
    public void getStm(){
   		createCon();
    	try {
			stm=con.createStatement();
		} catch (SQLException e) {
			e.printStackTrace();
			System.out.println("創(chuàng)建Statement對象失敗！");
		}
    }
    /** 
     * @功能 對數(shù)據(jù)庫的增加、修改和刪除的操作
     * @參數(shù) sql為要執(zhí)行的SQL語句
     * @返回值 boolean型值 
     */
    public boolean executeUpdate(String sql) {
    	System.out.println(sql);
        boolean mark=false;
    	try {
    		getStm();
            int iCount = stm.executeUpdate(sql);
            if(iCount>0)            	
            	mark=true;            
            else
            	mark=false;
        } catch (Exception e) {
            e.printStackTrace();
		    mark=false;
        }
        return mark;
    }
    /* 查詢數(shù)據(jù)庫 */
    public ResultSet executeQuery(String sql) {
        ResultSet rs=null;
        try {
            getStm();
            try {
                rs = stm.executeQuery(sql);
            } catch (Exception e) {
            	e.printStackTrace();
                System.out.println("查詢數(shù)據(jù)庫失敗！");
            }
        } catch (Exception e) {
            e.printStackTrace();          
        }
        return rs;
    }
    /* 關閉數(shù)據(jù)庫的操作 */
    public void closed() {
    	if(stm!=null)
			try {
				stm.close();
			} catch (SQLException e) {
				e.printStackTrace();
				System.out.println("關閉stm對象失敗！");
			}
    	if(con!=null)
			try {
				con.close();
			} catch (SQLException e) {
				e.printStackTrace();
				System.out.println("關閉con對象失敗！");
			}
    }
}