數(shù)據(jù)庫連接池之c3p0入門
C3P0是一個開源的JDBC連接池,它實現(xiàn)了數(shù)據(jù)源和JNDI綁定,支持JDBC3規(guī)范和JDBC2的標(biāo)準(zhǔn)擴展。目前使用它的開源項目有Hibernate,Spring等。
如果你不知道什么是連接池,可以先去百度一下。我理解的呢,就是一個大水池,里面有很多魚,每條魚對應(yīng)一個數(shù)據(jù)庫連接,你拿到一條魚你就獲得一個連接,當(dāng)然,這魚不能吃,你摸完了還要放回去的。這例子有點變態(tài)哈哈,能理解就行。
好!下面我們開始了。
一、首先我們從最最基本的開始,就是如何用java代碼實現(xiàn)用c3p0連接數(shù)據(jù)庫,并且執(zhí)行查詢操作。
首先我們新建一個項目:it_xiaorenwu
我們要做c3p0那就要先導(dǎo)入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
二、我們先準(zhǔn)備數(shù)據(jù)庫和數(shù)據(jù)
- /*
- 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的連接。
首先我們準(zhǔn)備一個db.properties ,根據(jù)自己所需要,修改用戶名和密碼。
- 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拿一條魚,啊呸!什么魚啊,拿一條數(shù)據(jù)庫連接
- //執(zhí)行查詢語句
- String sql = "select * from user";
- PreparedStatement ps = con.prepareStatement(sql);
- ResultSet rs = ps.executeQuery();
- //打印數(shù)據(jù)庫信息
- 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));
- }
- //關(guān)閉連接
con.close();//這是啥,這是把連接還給連接池,而不是關(guān)閉連接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
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));
- }
- //關(guān)閉連接
- con.close();//這是啥,這是把連接還給連接池,而不是關(guān)閉連接
- rs.close();
- ps.close();
- }
- }