BasicDataSource bds = new BasicDataSource();

// 设置连接数据库需要的配置信息

bds.setDriverClassName("com.mysql.jdbc.Driver");

bds.setUrl("jdbc:mysql://localhost:3306/jdbc3");

bds.setUsername("root");

bds.setPassword("root");

// 设置连接池的参数

bds.setInitialSize(5);

bds.setMaxActive(10);

ds = bds

try {

Properties prop =new Properties();

// 读配置文件

InputStream in =

JdbcUtils.class.getClassLoader().getResourceAsStream("dbcpconfig.properties");

prop.load(in);

ds =BasicDataSourceFactory.createDataSource(prop);

}catch (Exception e) {

throw newExceptionInInitializerError(e);

}

#连接设置

driverClassName=com.mysql.jdbc.Driver

url=jdbc:mysql://localhost:3306/jdbc3

username=root

password=root

#<!-- 初始化连接 -->

initialSize=5

#最大连接数量

maxActive=10

#<!-- 最大空闲连接 -->

maxIdle=10

#<!-- 超时等待时间以毫秒为单位 6000毫秒/1000等于60秒 -->

maxWait=60000

#JDBC驱动建立连接时附带的连接属性属性的格式必须为这样：[属性名=property;]

#注意："user" 与"password" 两个属性会被明确地传递，因此这里不需要包含他们。

connectionProperties=useUnicode=true;characterEncoding=gbk

#指定由连接池所创建的连接的自动提交（auto-commit）状态。

defaultAutoCommit=true

#driver default 指定由连接池所创建的连接的只读（read-only）状态。

#如果没有设置该值，则“setReadOnly”方法将不被调用。（某些驱动并不支持只读模式，如：Informix）

defaultReadOnly=

#driver default 指定由连接池所创建的连接的事务级别（TransactionIsolation）。

#可用值为下列之一：（详情可见javadoc。）NONE,READ_UNCOMMITTED, READ_COMMITTED,REPEATABLE_READ, SERIALIZABLE

defaultTransactionIsolation=READ_UNCOMMITTED

ComboPooledDataSource cpds = new ComboPooledDataSource();

cpds.setDriverClass("com.mysql.jdbc.Driver");

cpds.setJdbcUrl("jdbc:mysql://localhost:3306/jdbc3");

cpds.setUser("root");

cpds.setPassword("root");

cpds.setInitialPoolSize(5);

cpds.setMaxPoolSize(15);

ComboPooledDataSource cpds = newComboPooledDataSource("itcast");

<c3p0-config>

<default-config>

<!—- 默认配置 –->

<propertyname="initialPoolSize">5</property>

<propertyname="maxPoolSize">15</property>

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

<propertyname="jdbcUrl">jdbc:mysql://localhost:3306/jdbc3</property>

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

<propertyname="password">root</property>

</default-config>

<named-configname="xwh">

<propertyname="initialPoolSize">5</property>

<propertyname="maxPoolSize">15</property>

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

<propertyname="jdbcUrl">jdbc:mysql://localhost:3306/jdbc3</property>

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

<propertyname="password">root</property>

</named-config>

</c3p0-config>

// 通用的增删改方法

public static int update(String sql, Object[] params) throws SQLException {

Connection conn =null;

PreparedStatementpstmt = null;

ResultSet rs = null;

try {

// 获得连接

conn =getConnection();

// 预编译sql

pstmt =conn.prepareStatement(sql);

// 将参数设置进去

for(int i=0; params!=null&&i<params.length; i++) {

pstmt.setObject(i+1,params[i]);

}

// 发送sql

int num = pstmt.executeUpdate();

return num;

} finally {

// 释放资源

release(conn,pstmt, rs);

}

}

// 优化查询

public static Object query(String sql, Object[] params,ResultSetHandler rsh) throws SQLException {

Connection conn =null;

PreparedStatementpstmt = null;

ResultSet rs = null;

try {

// 获得连接

conn =getConnection();

// 预编译sql

pstmt =conn.prepareStatement(sql);

// 将参数设置进去

for(int i=0; params!=null&&i<params.length;i++) {

pstmt.setObject(i+1,params[i]);

}

// 发送sql

rs =pstmt.executeQuery();

// 不知道别人想如何处理结果集

// 干脆想别人所要一个结果集的处理器

// 为了让当前代码继续，定义一个结果集处理器接口

// 策略模式，规定算法，具体的算法留给将来的调用者实现

Object obj =rsh.handle(rs);

return obj;

} finally {

// 释放资源

release(conn,pstmt, rs);

}

}

public interface ResultSetHandler {

// 处理结果集的方法

public Objecthandle(ResultSet rs);

}

public class BeanListHandler implements ResultSetHandler{

private Classclazz;

publicBeanListHandler(Class clazz) {

this.clazz =clazz;

}

public Objecthandle(ResultSet rs) {

try {

// 取出结果集所有的记录，封装到bean，存入list返回

List list= new ArrayList();

while(rs.next()) {

Objectbean = clazz.newInstance();

// 获得元数据

ResultSetMetaDatametaData = rs.getMetaData();

// 获得列的数量

intcount = metaData.getColumnCount();

// 遍历列

for(inti=1; i<=count; i++) {

// 取列名

StringcolumnName = metaData.getColumnName(i);

// 取这列的值

Objectvalue = rs.getObject(columnName);

// 反射出属性

Fieldfield = clazz.getDeclaredField(columnName);

// 设置属性

field.setAccessible(true);

field.set(bean,value);

}

// 加入list

list.add(bean);

}

returnlist;

} catch(Exception e) {

throw newRuntimeException(e);

}

}

}

public class BeanHandler implements ResultSetHandler {

private Classclazz;

publicBeanHandler(Class clazz) {

this.clazz =clazz;

}

public Objecthandle(ResultSet rs) {

// 不知道有几列数据，不知道列名，不知道封装到什么样的bean

// 表的列明和javabean的字段名一致

try {

if(rs.next()){

// 创建bean

Objectbean = clazz.newInstance();

// 封装数据

// 获得结果集的元数据

ResultSetMetaDatametaData = rs.getMetaData();

intcount = metaData.getColumnCount();

// 迭代取每一列的数据

for(inti=1; i<=count; i++) {

// 获得列名  username

StringcolumnName = metaData.getColumnName(i);

// 获得数据ddd

Objectvalue = rs.getObject(columnName);

// 根据列名反射出映射的属性 username

Fieldfield = clazz.getDeclaredField(columnName);

// 为属性赋值

field.setAccessible(true);

field.set(bean,value);

}

returnbean;

}

return null;

} catch(Exception e) {

throw newRuntimeException(e);

}

}

}

// 取出第一行的所有记录存入一个Object数组

public class ArrayHandler implements ResultSetHandler {

public Objecthandle(ResultSet rs) {

try {

if(rs.next()) {

// 指向了第一行的记录

// 获得元数据

ResultSetMetaDatametaData = rs.getMetaData();

// 获得列数

intcount = metaData.getColumnCount();

// 创建数组

Object[]arr = new Object[count];

// 迭代所有列的值，存入数组

for(inti=1; i<=count; i++) {

Objectvalue = rs.getObject(i); // 获得指定列的值

arr[i-1]= value;

}

returnarr;

}

return null;

} catch(Exception e) {

throw newRuntimeException(e);

}

}

}