java數據庫連接類，已經把數據庫操作的方法都封裝好了

　　在這里分享一個已經封裝好了的java數據庫連接類，只要創建對象就可以實現數據庫的增刪改查操作，用過都說好。其實這個不是我自己寫的，是一個理解和學習能力超高的朋友寫的，他也很樂於分享交流，本人也深受他的影響和幫助。

　　不說了，直接上代碼。

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

public class DB {
    private String className; //驅動名
    private String url; //連接數據庫的URL地址
    private String username; //數據庫的用戶名
    private String password; //數據庫的密碼
    private Connection con; //數據庫連接對象
    private PreparedStatement pstm; //數據庫預編譯處理對象
    
    public DB(){
        className="com.mysql.jdbc.Driver";
        url="jdbc:mysql://localhost:3306/test";
        username="root";
        password="201321173083";
        try{
            Class.forName(className);
        }catch(ClassNotFoundException e){
            System.out.println("加載數據庫驅動程序失敗！");
            e.printStackTrace();
        }
    }

    public void getCon(){
        try {
            con=DriverManager.getConnection(url,username,password);
        } catch (SQLException e) {
            System.out.println("獲取數據庫連接失敗！");
            e.printStackTrace();
        }
    }
    //對象數組。如：String[] obj = new String[]{"賓桀鋒","201321173083"};
    public void doPstm(String sql,Object[] params){
        if(sql!=null && !sql.equals("")){
            System.out.println(sql);
            if(con==null)
                getCon();
            try {
                pstm=con.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
                if(params==null){
                    params=new Object[0];
                }
                for(int i=0;i<params.length;i++){
                    pstm.setObject(i+1,params[i]);
                }
                pstm.execute();
            } catch (SQLException e) {
                System.out.println("調用DB類中doPstm方法時出錯！");
                e.printStackTrace();
            }
        }
    }
    
    public ResultSet getRs(){
        try {            
            return pstm.getResultSet();
        } catch (SQLException e) {
            System.out.println("DB類中的getRs()方法出錯！");
            e.printStackTrace();
            return null;
        }
    }    
    
    public int getUpdate(){
        try {
            return pstm.getUpdateCount();
        } catch (SQLException e) {            
            e.printStackTrace();
            return -1;
        }
    }
    
    public void closed(){
        try{
            if(pstm!=null)
                pstm.close();
        }catch(Exception e){
            System.out.println("關閉pstm對象失敗！");
        }
        try{
            if(con!=null)
                con.close();
        }catch(Exception e){
            System.out.println("關閉con對象失敗！");
        }
    }
    

}

有問題或不懂的請聯系QQ：409169399。備注一下哦，要不然不加陌生人。