C3p0數據庫連接池的使用

1：首先介紹c3p0的一般使用用法，這種用法練習使用，當然工作的時候使用第二種xml配置完成c3p0的使用。

c3p0的網址：http://www.mchange.com/projects/c3p0/

　　1.1：第一種方式使用c3p0：

　　　　使用編碼方式實現c3p0數據庫連接池，練習學習使用的方式

　　　　1.1.1：創建數據庫和數據表，省略。

　　　　1.1.2：引包，如下所示，因為需要連接數據庫，所以必須加上mysql的驅動包
　　　　　　 c3p0-0.9.1.2.jar
　　　　 　　mysql-connector-java-5.1.12-bin.jar

　　　　1.1.3：創建實體類，例如User.java，源碼如下所示：

package com.bie.po;
/** 
* @author BieHongLi 
* @version 創建時間：2017年3月11日 下午12:55:21 
* 
*/
public class User {

    private int id;
    private String name;
    private String password;
    private String email;
    private String phone;
    public int getId() {
        return id;
    }
    public void setId(int id) {
        this.id = id;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public String getPassword() {
        return password;
    }
    public void setPassword(String password) {
        this.password = password;
    }
    public String getEmail() {
        return email;
    }
    public void setEmail(String email) {
        this.email = email;
    }
    public String getPhone() {
        return phone;
    }
    public void setPhone(String phone) {
        this.phone = phone;
    }
    @Override
    public String toString() {
        return "User [id=" + id + ", name=" + name + ", password=" + password + ", email=" + email + ", phone=" + phone
                + "]";
    }
    
    
}

　　　　1.1.4：創建好實體類之后就可以進行測試c3p0了，這里使用junit進行測試；源碼如下所示：

package com.bie.test;

import java.beans.PropertyVetoException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import org.junit.Test;

import com.bie.po.User;
import com.mchange.v2.c3p0.ComboPooledDataSource;

/** 
* @author BieHongLi 
* @version 創建時間：2017年3月11日 下午12:40:11 
* 
*/
public class C3p0Test {

    //使用編碼方式實現c3p0數據庫連接池
    @Test
    public void TestC3p0() throws PropertyVetoException, SQLException{
        //第一步：創建連接池核心工具類
        ComboPooledDataSource dataSource=new ComboPooledDataSource();
        //第二步：連接池，url，驅動，賬號，密碼，初始連接數，最大連接數
        dataSource.setJdbcUrl("jdbc:mysql:///test");//設置url
        dataSource.setDriverClass("com.mysql.jdbc.Driver");//設置驅動
        dataSource.setUser("root");//mysql的賬號
        dataSource.setPassword("123456");//mysql的密碼
        dataSource.setInitialPoolSize(6);//初始連接數，即初始化6個連接
        dataSource.setMaxPoolSize(50);//最大連接數，即最大的連接數是50
        dataSource.setMaxIdleTime(60);//最大空閑時間
        
        //第三步：從連接池對象中獲取數據庫連接
        Connection con=dataSource.getConnection();
        String sql="select * from user ";
        PreparedStatement ps=con.prepareStatement(sql);
        ResultSet rs=ps.executeQuery();
        
        List<User> list=new ArrayList<User>();
        while(rs.next()){
            User user=new User();
            user.setId(rs.getInt("id"));
            user.setName(rs.getString("name"));
            user.setPassword(rs.getString("password"));
            user.setEmail(rs.getString("email"));
            user.setPhone(rs.getString("phone"));
            list.add(user);
        }
        
        System.out.println(list);
    }

}

　　1.2：第二種方式：

　　　　使用配置文件xml方式完成c3p0數據庫連接池的應用，是工作之后經常使用的方式：

　　　　1.2.1：在src目錄下面創建c3p0-config.xml這個文件名，文件名必須是這個。代碼如下所示：

<c3p0-config>
    
    <!-- c3p0默認配置，下面還可以配置多個數據庫 -->
    <default-config>
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/test
        </property>
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="user">root</property>
        <property name="password">123456</property>
        <property name="initialPoolSize">6</property>
        <property name="maxPoolSize">50</property>
        <property name="maxIdleTime">1000</property>
    </default-config>

</c3p0-config>

　　　　1.2.2：開始使用junit測試，源碼如下，自動讀取上面的配置文件c3p0-config.xml;所以切記這個配置文件c3p0-config.xml這個名稱必須寫成這個哦~~~

package com.bie.test;

import java.beans.PropertyVetoException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import org.junit.Test;

import com.bie.po.User;
import com.mchange.v2.c3p0.ComboPooledDataSource;

/** 
* @author BieHongLi 
* @version 創建時間：2017年3月11日 下午12:40:11 
* 
*/
public class C3p0Test2 {

    //使用編碼方式實現c3p0數據庫連接池
    @Test
    public void TestXml() throws PropertyVetoException, SQLException{
        //第一步：創建連接池核心工具類
        ComboPooledDataSource dataSource=new ComboPooledDataSource();
        
        //第三步：從連接池對象中獲取數據庫連接
        Connection con=dataSource.getConnection();
        String sql="select * from user ";
        PreparedStatement ps=con.prepareStatement(sql);
        ResultSet rs=ps.executeQuery();
        
        List<User> list=new ArrayList<User>();
        while(rs.next()){
            User user=new User();
            user.setId(rs.getInt("id"));
            user.setName(rs.getString("name"));
            user.setPassword(rs.getString("password"));
            user.setEmail(rs.getString("email"));
            user.setPhone(rs.getString("phone"));
            list.add(user);
        }
        
        System.out.println("~~~"+list);
    }

}

方式一和方式二都是使用一個數據庫和數據表，演示效果如下所示：

---

努力ing，校招開始咯，加油！！！~~~

下一篇，c3p0和QueryRunner的結合讓開發更加簡便~~~