程式師世界 >> 數據庫知識 >> DB2數據庫 >> DB2教程 >> 初學者很實用：數據庫連接池之c3p0入門

初學者很實用：數據庫連接池之c3p0入門

編輯：DB2教程

初學者很實用：數據庫連接池之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
	{

	//首先讀取配置文件信息，以供配置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.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)); 
		}
		
		//關閉連接
		 
		con.close();//這是啥，這是把連接還給連接池，而不是關閉連接
		rs.close();
		ps.close();
	}
}