C3P0是一个开源的JDBC连接池，它实现了数据源和JNDI绑定，支持JDBC3规范和JDBC2的标准扩展。目前使用它的开源项目有Hibernate，Spring等。

如果你不知道什么是连接池，可以先去百度一下。我理解的呢，就是一个大水池，里面有很多鱼，每条鱼对应一个数据库连接，你拿到一条鱼你就获得一个连接，当然，这鱼不能吃，你摸完了还要放回去的。这例子有点变态哈哈，能理解就行。

好！下面我们开始了。

一、首先我们从最最基本的开始，就是如何用java代码实现用c3p0连接数据库，并且执行查询操作。

首先我们新建一个项目：it_xiaorenwu

我们要做c3p0那就要先导入c3p0的包：

1.c3p0-0.9.2.1.jar

2.mchange-commons-java-0.2.3.4.jar

3.mysql-connector-java-5.1.7-bin.jar

4.commons-io-2.0.1.jar

5.junit-4.5.jar

二、我们先准备数据库和数据

 

/*SQLyog Ultimate v11.24 (32 bit)MySQL - 5.5.24 : Database - test**********************************************************************//*!40101 SET NAMES utf8 */;
/*!40101 SET SQL_MODE='
'
*/;
/*!40014 SET @OLD_UNIQUE_CHECKS=@@UNIQUE_CHECKS, UNIQUE_CHECKS=0 */;
/*!40014 SET @OLD_FOREIGN_KEY_CHECKS=@@FOREIGN_KEY_CHECKS, FOREIGN_KEY_CHECKS=0 */;
/*!40101 SET @OLD_SQL_MODE=@@SQL_MODE, SQL_MODE='
NO_AUTO_VALUE_ON_ZERO'
*/;
/*!40111 SET @OLD_SQL_NOTES=@@SQL_NOTES, SQL_NOTES=0 */;
CREATE DATABASE /*!32312 IF NOT EXISTS*/`test` /*!40100 DEFAULT CHARACTER SET latin1 */;
USE `test`;
/*Table structure for table `user` */DROP TABLE IF EXISTS `user`;
CREATE TABLE `user` ( `id` int(10) NOT NULL AUTO_INCREMENT, `user_name` varchar(20) CHARACTER SET latin1 DEFAULT NULL, `password` varchar(100) CHARACTER SET latin1 DEFAULT NULL, `address` varchar(100) CHARACTER SET latin1 DEFAULT NULL, `phone_number` varchar(20) CHARACTER SET latin1 DEFAULT NULL, `create_time` datetime DEFAULT NULL, `update_time` datetime DEFAULT NULL, PRIMARY KEY (`id`)) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8;
/*Data for the table `user` */insert into `user`(`id`,`user_name`,`password`,`address`,`phone_number`,`create_time`,`update_time`) values (1,'
test'
,'
CY9rzUYh03PK3k6DJie09g=='
,'
test'
,'
test'
,'
2014-03-29 00:48:14'
,'
2014-03-29 00:48:17'
),(2,'
te2'
,'
CY9rzUYh03PK3k6DJie09g=='
,'
asdfk'
,'
4156434885'
,'
2015-08-05 11:09:29'
,'
2015-08-20 11:09:33'
);
/*!40101 SET SQL_MODE=@OLD_SQL_MODE */;
/*!40014 SET FOREIGN_KEY_CHECKS=@OLD_FOREIGN_KEY_CHECKS */;
/*!40014 SET UNIQUE_CHECKS=@OLD_UNIQUE_CHECKS */;
/*!40111 SET SQL_NOTES=@OLD_SQL_NOTES */;

 

我们开始第一个简单的java例子：通过读取properties配置文件。然后获取c3p0的连接。

首先我们准备一个db.properties ,根据自己所需要，修改用户名和密码。

 

jdbcdriver=com.mysql.jdbc.Driverurl=jdbc:mysql://localhost:3306/testusername=rootpassword=root

 

新建一个类：C3p0Demo1

 

package day12;
import java.beans.PropertyVetoException;
import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Properties;
import javax.sql.DataSource;
import org.junit.Test;
import com.mchange.v2.c3p0.ComboPooledDataSource;
public class C3p0Demo1 {
@Test public void getConnection() throws IOException, PropertyVetoException, SQLException {

//首先读取配置文件信息，以供配置c3p0所用 Properties prop = new Properties();
InputStream in = C3p0Demo1.class.getClassLoader().getResourceAsStream("db.properties");
prop.load(in);
//加载信息 ComboPooledDataSource comb = new ComboPooledDataSource();
//下面就是开始配置 comb.setDriverClass(prop.getProperty("jdbcdriver"));
comb.setJdbcUrl(prop.getProperty("url"));
comb.setUser(prop.getProperty("jdbc:mysql://localhost:3306/test"));
comb.setPassword(prop.getProperty("root"));
Connection con = comb.getConnection();
//从c3p0拿一条鱼，啊呸！什么鱼啊，拿一条数据库连接 //执行查询语句 String sql = "select * from user";
PreparedStatement ps = con.prepareStatement(sql);
ResultSet rs = ps.executeQuery();
//打印数据库信息 while(rs.next()) {
System.out.println(rs.getString(1));
System.out.println(rs.getString(2));
System.out.println(rs.getString(3));
System.out.println(rs.getString(5));
System.out.println(rs.getString(6));
System.out.println(rs.getString(7));
}
//关闭连接

con.close();//这是啥，这是把连接还给连接池，而不是关闭连接in.close();comb.close();rs.close();ps.close();} }

 

 

第二种方法：（类似于，但更简洁）

我们需要新建一个配置文件：c3p0.properties （注意：名字是固定的。c3p0默认只认识这个名字）
 

 

c3p0.driverClass=com.mysql.jdbc.Driverc3p0.jdbcUrl=jdbc:mysql://localhost:3306/testc3p0.user=rootc3p0.password=root

OK!我们新建一个类：C3p0Demo2

 

 

package day12;
import java.beans.PropertyVetoException;
import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Properties;
import javax.sql.DataSource;
import org.junit.Test;
import com.mchange.v2.c3p0.ComboPooledDataSource;
public class C3p0Demo2 {
@Test public void getConByC3P0() throws SQLException {
DataSource ds = new ComboPooledDataSource();
//c3p0自己去读配置文件了，我们啥也不干 Connection con = ds.getConnection();
//我们直接拿一条鱼 System.out.println("con:"+con);
String sql = "select * from user";
PreparedStatement ps = con.prepareStatement(sql);
ResultSet rs = ps.executeQuery();
while(rs.next()) {
System.out.println(rs.getString(1));
System.out.println(rs.getString(2));
System.out.println(rs.getString(3));
System.out.println(rs.getString(5));
System.out.println(rs.getString(6));
System.out.println(rs.getString(7));
}
//关闭连接 con.close();
//这是啥，这是把连接还给连接池，而不是关闭连接 rs.close();
ps.close();
}
}