自定义数据库连接工具类

这是一个代码质量比较高的Util。这里写了两种，一种是原始的，一种是使用C3P0的。数据库使用的是MySQL5.7。
使用框架开发的时候根本不需要写这些东西。其实框架也是这样封装的，但提供的功能会很丰富。这里展现的是思路，供参考。
功能齐全的Dao工具类

DriverManager获取连接的Util：

package util;

import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

public class DBUtil {

//连接URL
private static String jdbcUrl;
//登录用户，配置文件中key不要命名为username或者userName，可能会出现冲突情况
private static String userName;
//登录密码
private static String password;
//实例化本地线程对象
private static ThreadLocal<Connection> thread = new ThreadLocal<Connection>();

static{
try {
//获取配置文件中的jdbc数据库连接信息
Properties props = new Properties();
props.load(DBUtil.class.getResourceAsStream("/conf/dbinfo.properties"));
String driverClass = props.getProperty("driverClass");
jdbcUrl = props.getProperty("jdbcUrl");
userName = props.getProperty("user");
password = props.getProperty("password");
//加载驱动
Class.forName(driverClass);
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}

/**
* 获取数据库连接
* @return 数据库连接Connection对象
* @throws SQLException
*/
public static Connection getConnection() throws SQLException{

if(thread.get() == null){
Connection conn = DriverManager.getConnection(jdbcUrl, userName, password);
thread.set(conn);
}
return thread.get();
//不需要使用本地线程时，可以去掉上面代码
//		return DriverManager.getConnection(jdbcUrl, userName, password);
}

/**
* 关闭连接，释放资源
* @param conn Connection对象
* @param stmt Statement对象，可接收子类PreparedStatement对象
* @param rs ResultSet对象
*/
public static void closeAll(
Connection conn,Statement stmt,ResultSet rs){

if(rs != null){
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if(stmt != null){
try {
stmt.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if(conn != null){
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
thread.remove();		//移除本地线程中的Connection对象
}

public static void main(String[] args) throws SQLException {
System.out.println(getConnection());
}
}

使用C3P0连接池的Util：

package com.sourong.util;

import java.beans.PropertyVetoException;
import java.io.IOException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

import com.mchange.v2.c3p0.ComboPooledDataSource;

/**
* c3p0连接池工具类
*
*/
public class C3p0DBUtil {

//实例化c3p0连接池对象
private static ComboPooledDataSource c3p0 = new ComboPooledDataSource();
//实例化本地线程对象
private static ThreadLocal<Connection> thread = new ThreadLocal<Connection>();

static{
//给c3p0配置参数
try {
Properties props = new Properties();
props.load(C3p0DBUtil.class.getResourceAsStream("/dataSource.properties"));

//设定数据库连接驱动类
c3p0.setDriverClass(props.getProperty("driverClass"));
//设定jdbc连接URL
c3p0.setJdbcUrl(props.getProperty("jdbcUrl"));
//设定连接登录用户名
c3p0.setUser(props.getProperty("user"));
//设定连接登录密码
c3p0.setPassword(props.getProperty("password"));
//设定当连接池中的连接耗尽的时候c3p0一次同时获取的连接数
c3p0.setAcquireIncrement(Integer.valueOf(props.getProperty("acquireIncrement")));
//设定初始化时获取十个连接，取值应在minPoolSize与maxPoolSize之间
c3p0.setInitialPoolSize(Integer.valueOf(props.getProperty("initialPoolSize")));
//设定连接池中保留的最小连接数
c3p0.setMinPoolSize(Integer.valueOf(props.getProperty("minPoolSize")));
//设定连接池中保留的最大连接数
c3p0.setMaxPoolSize(Integer.valueOf(props.getProperty("maxPoolSize")));
} catch (PropertyVetoException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}

/**
* 通过C3p0连接池，获取数据库连接
* @return 数据库连接Connection对象
* @throws SQLException
*/
public static Connection getConnection() throws SQLException{

if(thread.get() == null){
Connection conn = c3p0.getConnection();
thread.set(conn);
}
return thread.get();
}

/**
* 关闭连接，释放资源
* @param conn Connection对象
* @param stmt Statement对象，可接收子类PreparedStatement对象
* @param rs ResultSet对象
*/
public static void closeAll(
Connection conn,Statement stmt,ResultSet rs){

if(rs != null){
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if(stmt != null){
try {
stmt.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if(conn != null){
try {
conn.close();	//将连接对象放入连接池中，并标记为空闲
} catch (SQLException e) {
e.printStackTrace();
}
}
thread.remove();		//移除本地线程中的Connection对象
}

public static void main(String[] args) throws SQLException {
System.out.println(getConnection());
}
}