数据库连接JDBC和数据库连接池C3P0自定义的java封装类
使用以下的包装类都需要自己有JDBC的驱动jar包：
如 mysql-connector-java-5.1.26-bin.jar（5.1.26代表的是版本序列号）
一、JDBC的封装：（java连接MySQL）
import java.sql.*;
import utils.GlobalConstant;
public class JDBCUtil {
private JDBCUtil() {
}
/**
* 获取JDBC的数据库连接
*/
public static Connection getConnection() {
Connection conn = null;
try {
Class.forName(GlobalConstant.CONNECTION_DRIVER);
conn = DriverManager.getConnection(GlobalConstant.CONNECTION_URL, GlobalConstant.CONNECTION_USER,
GlobalConstant.CONNECTION_PASSWORD);
} catch (Exception e) {
e.printStackTrace();
}
/*
* try { conn = DataSourceService.getConnection(); } catch (SQLException
* e) { e.printStackTrace(); }
*/
return conn;
}
private static void close(ResultSet rs, Statement sm, Connection conn) {
try {
if (rs != null)
rs.close();
if (sm != null)
sm.close();
if (conn != null)
conn.close();
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 关闭数据库的结果集
*
* @param rs
* 需要关闭的结果集
*/
public static void close(ResultSet rs) {
try {
if (rs != null)
rs.close();
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 将一个标准的sql查询语句在数据库中查询,并且返回一个对应的结果集。
*
* @param sql
* 标准的sql查询语句
*/
public static ResultSet doQuery(String sql) {
Connection conn = getConnection();
if (conn == null)
return null;
Statement sm = null;
ResultSet rs = null;
try {
sm = conn.createStatement();
rs = sm.executeQuery(sql);
return rs;
} catch (SQLException e) {
e.printStackTrace();
} finally {
if (rs == null && sm != null) {
close(null, sm, conn);
}
// close(null, sm, conn);这句肯定不行
}
return rs;
}
/**
* 将一个更新语句和对应的参数进行查询,并返回一个整形结果
*
* @param sql
* 数据库中的更新语句
* @param paras
* sql中对应的参数
*/
public static int doUpdate(String sql, String[] paras) {
Connection conn = getConnection();
if (conn == null)
return 0;
PreparedStatement psm = null;
int result = 0;
try {
psm = conn.prepareStatement(sql);
for (int i = 0; i < paras.length; i++) {
psm.setString(i + 1, paras[i]);
}
result = psm.executeUpdate();
} catch (Exception e) {
e.printStackTrace();
} finally {
close(null, psm, conn);
}
return result;
}
}
JDBCUtils
以下的C3P0的数据库连接池除了需要以上的JDBC的驱动包，还需以下jar包：
如 c3p0-0.9.1.2.jar (0.9.1.2代表的是版本序列号)
为了方便使用，可以用其他的jar包进行辅助封装（dbUtils的jar）
如 commons-dbutils-1.3.jar （1.3代表的是版本序列号）
二、C3P0数据库连接池的封装：（java连接MySQL）
----------------不需要xml的配置文件
import java.beans.PropertyVetoException;
import java.sql.Connection;
import javax.sql.DataSource;
import com.mchange.v2.c3p0.ComboPooledDataSource; import utils.GlobalConstant; public class DataSourceUtils {
private static DataSource ds; static {
/*
* 从配置文件读取配置信息 <?xml version="1.0" encoding="UTF-8"?> <c3p0-config> <!--
* 默认配置，如果没有指定则使用这个配置 --> <default-config> <property
* name="checkoutTimeout">30000</property> <property
* name="idleConnectionTestPeriod">30</property> <property
* name="initialPoolSize">3</property> <property
* name="maxIdleTime">30</property> <property
* name="maxPoolSize">10</property> <property
* name="minPoolSize">3</property> <property
* name="maxStatements">50</property> <property
* name="acquireIncrement">3</property><!-- 如果池中数据连接不够时一次增长多少个 -->
* <property name="driverClass">com.mysql.jdbc.Driver</property>
* <property name="jdbcUrl">
* <![CDATA[jdbc:mysql://127.0.0.1:3306/project?useUnicode=true&
* characterEncoding=UTF-8]]> </property> <property
* name="user">root</property> <property
* name="password">789123</property> </default-config> </c3p0-config>
*
* ds = // 默认的读取c3p0-config.xml中默认配置 new ComboPooledDataSource();
*/
ComboPooledDataSource cpds = null;
try {
cpds = new ComboPooledDataSource();
cpds.setCheckoutTimeout(30000);
cpds.setIdleConnectionTestPeriod(30);
cpds.setInitialPoolSize(3);
cpds.setMaxIdleTime(30);
cpds.setMaxPoolSize(70);
cpds.setMaxStatementsPerConnection(100);
cpds.setMinPoolSize(3);
cpds.setMaxStatements(75);
cpds.setAcquireIncrement(3);
cpds.setDriverClass(GlobalConstant.CONNECTION_DRIVER);
cpds.setJdbcUrl(GlobalConstant.CONNECTION_URL);
cpds.setUser(GlobalConstant.CONNECTION_USER);
cpds.setPassword(GlobalConstant.CONNECTION_PASSWORD);
ds = cpds;
} catch (PropertyVetoException e) {
System.out.println("与MySQL数据库连接失败！");
}
} private DataSourceUtils() { } public static DataSource getDatasSource() {
return ds;
} public static Connection getConnection() {
Connection con = null;
try {
con = ds.getConnection();// 每一次从ds中获取一个新的连接
} catch (Exception e) {
e.printStackTrace();
}
return con;
}
}
DataSourceUtils
如果要验证其可用性，你们可以修改下以上的用户名，密码，数据库名
之后在自己的MySQL建立自己相应的数据库即可测试。