數(shù)據(jù)庫連接池之c3p0入門

作者：挨踢界小人物 2015-10-29 16:59:47

　　C3P0是一個開源的JDBC連接池，它實現(xiàn)了數(shù)據(jù)源和JNDI綁定，支持JDBC3規(guī)范和JDBC2的標(biāo)準(zhǔn)擴(kuò)展。目前使用它的開源項目有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默認(rèn)只認(rèn)識這個名字)

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(); 
    } 
}

責(zé)任編輯：honglu 來源：紅黑聯(lián)盟/c3p0

數(shù)據(jù)庫