java实现数据库连接的工具类

第一种 (带事务)

package com.china.util;

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


public class BaseDao {

    protected Connection conn = null;
    
    
    /**
     * 创建数据库连接
     * @throws ClassNotFoundException
     * @throws SQLException
     */
    protected void openconnection() throws ClassNotFoundException,SQLException{        
        try {
            if( conn == null || conn.isClosed() ){
                Class.forName("oracle.jdbc.driver.OracleDriver");
                conn = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:xe","xx","xx");
                //mysql
                 //Class.forName("com.mysql.jdbc.Driver");
                 // conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/xe", "root", "root");
            }            
        } catch (ClassNotFoundException e) {            
        
            throw e;
        } catch (SQLException e) {    
            
            throw e;
        }
    }    
    
    
    /**
     * 手动提交事务
     * @throws Exception
     */
    public void beginTransaction() throws Exception{
    
        this.openconnection();        
        conn.setAutoCommit(false);        
    }
    /**
     * 事务回滚
     * @throws Exception
     */
    public void rollback() throws Exception{
        
        if(conn != null){            
                conn.rollback();            
        }        
    }
    /**
     * 事务提交
     * @throws Exception
     */
    public void commit() throws Exception{
        if(conn != null){            
            conn.commit();                
        }    
    }

    /**
     * 关闭数据库
     * @throws Exception
     */
    public void closeResource() throws Exception{        
        if(conn != null){
            conn.close();
        }            
        
    }
    
        
    
    
}

第二种(mysql和oracle无事务)推荐！

package com.smn.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:mysql://127.0.0.1:3306/blog";
    private final String userName = "root";
    private final String password = "toor";
    private Connection con = null;
    private Statement stm=null;
    
    /* 通过构造方法加载数据库驱动 */
    public DB(){
        try {
            Class.forName("com.mysql.jdbc.Driver"); 
        } catch (Exception e) {
            e.printStackTrace();
            System.out.println("加载数据库驱动失败！");
        }        
    }
    /* 创建数据库连接 */
    public void createCon() {
        try {
            con = DriverManager.getConnection(url, userName, password);
        } catch (Exception e) {
            e.printStackTrace();
            System.out.println("获取数据库连接失败！");
        }
    }
    /* 获取Statement对象 */
    public void getStm(){
           createCon();
        try {
            stm=con.createStatement();
        } catch (SQLException e) {
            e.printStackTrace();
            System.out.println("创建Statement对象失败！");
        }
    }
    /** 
     * @功能 对数据库的增加、修改和删除的操作
     * @参数 sql为要执行的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;
    }
    /* 查询数据库 */
    public ResultSet executeQuery(String sql) {
        ResultSet rs=null;
        try {
            getStm();
            try {
                rs = stm.executeQuery(sql);
            } catch (Exception e) {
                e.printStackTrace();
                System.out.println("查询数据库失败！");
            }
        } catch (Exception e) {
            e.printStackTrace();          
        }
        return rs;
    }
    /* 关闭数据库的操作 */
    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对象失败！");
            }
    }
}