最全面的jdbcUtils，总有一种适合你

附加jar包,TxQueryRunner.java文件,dbconfig.properties配置文件(点击链接下载):

　　http://files.cnblogs.com/files/xiaoming0601/jdbcUtils%E7%9B%B8%E5%85%B3jar%E5%8C%85.zip

1.普通的连接数据库,读取dbconfig.properties配置文件

package cn.itcast.jdbcUtils;

import java.io.IOException;

import java.io.InputStream;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.SQLException;

import java.util.Properties;

public class JdbcUtils {

    private static final String dbconfig = "dbconfig.properties";

    private static Properties prop = new Properties();

    static {

        try {

            InputStream in = Thread.currentThread().getContextClassLoader().getResourceAsStream(dbconfig);

            prop.load(in);

            Class.forName(prop.getProperty("driverClassName"));

        } catch (Exception e) {

            throw new RuntimeException(e);

        }

    }

    public static Connection getConnection(){

        try {

            return DriverManager.getConnection(prop.getProperty("url"),prop.getProperty("username"),prop.getProperty("password"));

        } catch (SQLException e) {

            throw new RuntimeException(e);

        }

    }

}

2.使用简单的连接池,给出c3p0-config.xml配置文件

　　1.c3p0-config.xml配置文件:

   <?xml version="1.0" encoding="UTF-8" ?>

 - <c3p0-config>

 - <!--  这是默认配置信息

   -->

 - <default-config>

 - <!--  连接四大参数配置

   -->

   <property name="jdbcUrl">jdbc:mysql://localhost:3306/mydb1</property>

   <property name="driverClass">com.mysql.jdbc.Driver</property>

   <property name="user">root</property>

   <property name="password">123</property>

 - <!--  池参数配置

   -->

   <property name="acquireIncrement">3</property>

   <property name="initialPoolSize">10</property>

   <property name="minPoolSize">2</property>

   <property name="maxPoolSize">10</property>

   </default-config>

 - <!--  专门为oracle提供的配置信息

   -->

 - <named-config name="oracle-config">

   <property name="jdbcUrl">jdbc:mysql://localhost:3306/mydb1</property>

   <property name="driverClass">com.mysql.jdbc.Driver</property>

   <property name="user">root</property>

   <property name="password">123</property>

   <property name="acquireIncrement">3</property>

   <property name="initialPoolSize">10</property>

   <property name="minPoolSize">2</property>

   <property name="maxPoolSize">10</property>

   </named-config>

   </c3p0-config>

　　2.代码

package cn.itcast.jdbcUtils;

import java.sql.Connection;

import java.sql.SQLException;

import javax.sql.DataSource;

import com.mchange.v2.c3p0.ComboPooledDataSource;

public class JdbcUtils2 {

    // 配置文件的默认配置！要求你必须给出c3p0-config.xml！！！

    private static ComboPooledDataSource dataSource = new ComboPooledDataSource();

    public static Connection getConnection() throws SQLException {

        return dataSource.getConnection();

    }

    public static DataSource getDataSource() {

        return dataSource;

    }

}

3.使用连接池,最全面的获取dataSource,connection以及释放connection的方法,并提供开启,提交回滚事务的方法

package cn.itcast.jdbcUtils;

import java.sql.Connection;

import java.sql.SQLException;

import javax.sql.DataSource;

import com.mchange.v2.c3p0.ComboPooledDataSource;

public class JdbcUtils3 {

    private static DataSource dataSource = new ComboPooledDataSource();

    private static ThreadLocal<Connection> tl = new ThreadLocal<Connection>();

    //获取数据源

    public static DataSource getDataSource(){

        return dataSource;

    }

    //获取连接

    public static Connection getConnection() throws SQLException{

        Connection conn = tl.get();

        if(conn==null){

            return dataSource.getConnection();

        }

        return conn;

    }

    //开启事物

    public static void beginTransaction() throws SQLException{

        Connection conn = tl.get();

        if(conn!=null){

            throw new SQLException("您已经开启了事务，在没有结束当前事务时，不能再开启事务");

        }

        conn = dataSource.getConnection();

        conn.setAutoCommit(false);

        tl.set(conn);//把当前线程的连接保存起来！

    }

    //提交事务

    public static void commitTransaction() throws SQLException{

        Connection conn = tl.get();

        if(conn==null){

            throw new SQLException("当前没有事务，所以不能提交");

        }

        conn.commit();

        conn.close();

        tl.remove();

    }

    //回滚事务

    public static void rollbackTransaction() throws SQLException{

        Connection conn = tl.get();

        if(conn==null){

            throw new SQLException("当前没有事务，所以不能回滚");

        }

        conn.rollback();

        conn.close();

        tl.remove();

    }

    //释放连接

    public static void releaseConnection(Connection connection) throws SQLException {

        Connection con = tl.get();

        /*

         * 判断它是不是事务专用，如果是，就不关闭！

         * 如果不是事务专用，那么就要关闭！

         */

        // 如果con == null，说明现在没有事务，那么connection一定不是事务专用的！

        if(con == null) connection.close();

        // 如果con != null，说明有事务，那么需要判断参数连接是否与con相等，若不等，说明参数连接不是事务专用连接

        if(con != connection) connection.close();

    }

}

~~~~~~~~~~~~~~~~~~相互学习~~~~~~~~~~~~~~~~~~~~

巴特西

最全面的jdbcUtils，总有一种适合你

最新文章

热门文章