标签:c3p0
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.Driver url=jdbc:mysql://localhost:3306/test username=root password=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 {
<span style="white-space:pre"> </span>//首先读取配置文件信息,以供配置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)); } //关闭连接
<span style="white-space:pre"></span><pre name="code" class="java" style="color: rgb(51, 51, 51); font-size: 14px; line-height: 24px; text-indent: 28px;">con.close();//这是啥,这是把连接还给连接池,而不是关闭连接in.close();comb.close();rs.close();ps.close();} }
我们需要新建一个配置文件:c3p0.properties
(注意:名字是固定的。c3p0默认只认识这个名字)
c3p0.driverClass=com.mysql.jdbc.Driver c3p0.jdbcUrl=jdbc:mysql://localhost:3306/test c3p0.user=root c3p0.password=root
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(); } }
版权声明:本文为博主原创文章,未经博主允许不得转载。
标签:c3p0
原文地址:http://blog.csdn.net/a403071690/article/details/47274495