JAVA基础之利用C3P0实现JDBC连接池，提高数据库处理的能力，加快性能。一般情况下，操作数据库的过程都是连接数据库->执行操作->释放资源。这样的操作在一般情况下是没什么问题的，但是如果出现频繁的操作就会造成一些性能上的问题，因为频繁打开关闭连接是个耗时的操作，所以就Java目前用得最多的是C3P0实现JDBC连接池，由于刚入手Java希望各位小伙伴海涵。

使用C3P0先得引包：c3p0-0.9.1.2.jar和mysql-connector-java-5.1.39-bin.jar

编写C3P0配置文件c3p0-config.xml

<?xml version="1.0" encoding="UTF-8" ?>
<c3p0-config>
    <default-config>
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/test20180109</property>
        <property name="user">root</property>
        <property name="password">root</property>
        <property name="initialPoolSize">5</property>
        <property name="maxPoolSize">20</property>
    </default-config>
    <named-config name="lfriend">
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="jdbcUrl">jdbc:mysql:///test20180109</property>
        <property name="user">root</property>
        <property name="password">root</property>
    </named-config>
</c3p0-config>

编写c3p0工具类

package me.lfriend.jdbc.utils;

import com.mchange.v2.c3p0.ComboPooledDataSource;

import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.SQLException;

public class C3P0Utils {
    private static ComboPooledDataSource dataSource=new ComboPooledDataSource('lfriend');
    public static DataSource getDataSource(){
        return dataSource;
    }
    public static Connection getConnection(){
        try {
            return dataSource.getConnection();
        } catch (SQLException e) {
            throw new RuntimeException(e);
        }
    }
}

编写测试类TestC3P0.java

package me.lfriend.jdbc.test;

import com.mchange.v2.c3p0.ComboPooledDataSource;
import me.lfriend.jdbc.utils.C3P0Utils;
import me.lfriend.jdbc.utils.JDBCUtils_V3;
import org.junit.Test;
import java.sql.Connection;
import java.sql.PreparedStatement;

public class TestC3P0 {

    @Test
    public void testAddUser(){
        Connection conn=null;
        PreparedStatement pstmp=null;
        //1.创建自定义连接池对象
        ComboPooledDataSource dataSource=new ComboPooledDataSource();//加载默认配置
        //ComboPooledDataSource dataSource=new ComboPooledDataSource("lfriend");//加载有名称的配置

        try {
            //2.从池子中获取连接
            conn=dataSource.getConnection();
            //3.编写sql
            String sql="insert into user values(null,?,?)";
            //4.创建预处理对象
            pstmp=conn.prepareStatement(sql);
            //5.设置参数
            pstmp.setString(1,"piu");
            pstmp.setString(2,"123456");
            //6.执行查询
            int row=pstmp.executeUpdate();
            if(row>0){
                System.out.println("添加成功！");
            }else{
                System.out.println("添加失败！");
            }
        }catch (Exception e){
            throw new RuntimeException(e);
        }finally {
            JDBCUtils_V3.release(conn,pstmp,null);
        }
    }

    /**
     * 工具类使用C3P0
     */
    @Test
    public void testAddUser1(){
        Connection conn=null;
        PreparedStatement pstmp=null;
        try {
            conn= C3P0Utils.getConnection();
            //3.编写sql
            String sql="insert into user values(null,?,?)";
            //4.创建预处理对象
            pstmp=conn.prepareStatement(sql);
            //5.设置参数
            pstmp.setString(1,"piu");
            pstmp.setString(2,"123456");
            //6.执行查询
            int row=pstmp.executeUpdate();
            if(row>0){
                System.out.println("添加成功！");
            }else{
                System.out.println("添加失败！");
            }
        }catch (Exception e){
            throw new RuntimeException(e);
        }finally {
            JDBCUtils_V3.release(conn,pstmp,null);
        }
    }
}

C3P0的基本操作就是这样，欢迎各位大佬指出问题！

因不想继续在PHP花更多的时间，所以入手JAVA，从零学至此利用C3P0实现JDBC连接池，提高数据库处理的能力，加快性能。一般情况下，操作数据库的过程都是连接数据库->执行操作->释放资源。这样的操作在一般情况下是没什么问题的，但是如果出现频繁的操作就会造成一些性能上的问题，因为频繁打开关闭连接是个耗时的操作，所以就Java目前用得最多的是C3P0实现JDBC连接池，由于刚入手Java希望各位小伙伴海涵。
使用C3P0先得引包：c3p0-0.9.1.2.jar和mysql-connector-java-5.1.39-bin.jar
编写C3P0配置文件c3p0-config.xml<?xml  version="1.0" encoding="UTF-8" ?>            com.mysql.jdbc.Driver        jdbc:mysql://localhost:3306/test20180109        root        root        5        20                com.mysql.jdbc.Driver        jdbc:mysql:///test20180109        root        root    
编写c3p0工具类package me.lfriend.jdbc.utils;import com.mchange.v2.c3p0.ComboPooledDataSource;import javax.sql.DataSource;import java.sql.Connection;import java.sql.SQLException;public class C3P0Utils {    private static ComboPooledDataSource dataSource=new ComboPooledDataSource('lfriend');    public static DataSource getDataSource(){        return dataSource;    }    public static Connection getConnection(){        try {            return dataSource.getConnection();        } catch (SQLException e) {            throw new RuntimeException(e);        }    }}
编写测试类TestC3P0.javapackage me.lfriend.jdbc.test;import com.mchange.v2.c3p0.ComboPooledDataSource;import me.lfriend.jdbc.utils.C3P0Utils;import me.lfriend.jdbc.utils.JDBCUtils_V3;import org.junit.Test;import java.sql.Connection;import java.sql.PreparedStatement;public class TestC3P0 {    @Test    public void testAddUser(){        Connection conn=null;        PreparedStatement pstmp=null;        //1.创建自定义连接池对象        ComboPooledDataSource dataSource=new ComboPooledDataSource();//加载默认配置        //ComboPooledDataSource dataSource=new ComboPooledDataSource("lfriend");//加载有名称的配置        try {            //2.从池子中获取连接            conn=dataSource.getConnection();            //3.编写sql            String sql="insert into user values(null,?,?)";            //4.创建预处理对象            pstmp=conn.prepareStatement(sql);            //5.设置参数            pstmp.setString(1,"piu");            pstmp.setString(2,"123456");            //6.执行查询            int row=pstmp.executeUpdate();            if(row>0){                System.out.println("添加成功！");            }else{                System.out.println("添加失败！");            }        }catch (Exception e){            throw new RuntimeException(e);        }finally {            JDBCUtils_V3.release(conn,pstmp,null);        }    }    /**     * 工具类使用C3P0     */    @Test    public void testAddUser1(){        Connection conn=null;        PreparedStatement pstmp=null;        try {            conn= C3P0Utils.getConnection();            //3.编写sql            String sql="insert into user values(null,?,?)";            //4.创建预处理对象            pstmp=conn.prepareStatement(sql);            //5.设置参数            pstmp.setString(1,"piu");            pstmp.setString(2,"123456");            //6.执行查询            int row=pstmp.executeUpdate();            if(row>0){                System.out.println("添加成功！");            }else{                System.out.println("添加失败！");            }        }catch (Exception e){            throw new RuntimeException(e);        }finally {            JDBCUtils_V3.release(conn,pstmp,null);        }    }}
C3P0的基本操作就是这样，欢迎各位大佬指出问题！

这两天在对照几个典型的.net网站的时候，发现了一个小小的问题，大家在对数据库操作的时候经常会用到SqlDataReader，这个方法在调用完之后是要及时关闭的，问题就是什么时候关闭是合适的？
    为了这个问题我专门上微软的官方论坛找了点东西，我在这里和我平时用的稍微的对比了一下
      我们平时用方法一般是（至少我以前看到的是的，特别是很多.net书籍上）：
/// <summary>
/// 常见的获取SqlDataReader方法
/// 通常的数据访问层都会提供这个方法
/// </summary>
static SqlDataReader GetReader()
{
//通过连接字符串获取连接
SqlConnection con = new SqlConnection(conn_String);
try
{
//打开连接，执行查询
//并且返回SqlDataReader
con.Open();
SqlCommand cmd = con.CreateCommand();
cmd.CommandText = Sql;
SqlDataReader dr = cmd.ExecuteReader();
return dr;
}
finally
{
//这里的代码就是问题所在
//如果这里执行关闭：
con.Close();
//那返回的SqlDataReader将毫无用处，因为其
//依赖的连接已经关闭
//如果这里不执行con.Close();那返回后该连接将永远无法关闭，因为调用方无法
//得到连接对象
}
}
 
我在微软的官方实例petshop中看的方法却是：
static SqlDataReader GetReader_CloseConnection(SqlConnection con)
{
try
{
//打开连接，执行查询
//并且返回SqlDataReader
con.Open();
SqlCommand cmd = con.CreateCommand();
cmd.CommandText = Sql;
SqlDataReader dr = cmd.ExecuteReader
(CommandBehavior.CloseConnection);
return dr;
}
finally
{
//不需要使用con.Close();
}
}
我找了找CommandBehavior.CloseConnection的作用
CommandBehavior.CloseConnection的功能恰好就是为了避免类似的尴尬境地，它能够保证当SqlDataReader对象被关闭时，其依赖的连接也会被自动关闭。
只需要在使用DataReader对象之后的时候，将DataReader对象关闭即可，这样conn就自己关闭了。找了个小例子：
/// <summary>
/// 测试方法
/// </summary>
static void Main(string[] args)
{
//建立连接
SqlConnection con = new SqlConnection(conn_String);
try
{
//测试使用了CommandBehavior.CloseConnection的方法
Console.WriteLine("测试使用了CommandBehavior.
CloseConnection的方法：");
SqlDataReader sdr = GetReader_CloseConnection(con);
while (sdr.Read()) { }
sdr.Close();
Console.WriteLine("读取完毕后的连接状态：" + con.State.ToString());
//测试没有使用CommandBehavior.CloseConnection的方法
Console.WriteLine("测试没有使用CommandBehavior.
CloseConnection的方法：");
SqlDataReader sdr1 = GetReader_NoCloseConnection(con);
while (sdr1.Read()) { }
sdr1.Close();
Console.WriteLine("读取完毕后的连接状态：" + 
con.State.ToString());
Console.Read();
}
finally
{
//确保连接被关闭
if (con.State != ConnectionState.Closed)
con.Close();
}
}
 

读取完毕后的连接状态：Closed
测试没有使用CommandBehavior.CloseConnection的方法：
读取完毕后的连接状态：Open
正如读者所看到的，使用了CommandBehavior.CloseConnection得到的SqlDataReader对象，在关闭的同时会自动地关闭其依赖的数据库连接对象，这个特性解决了数据访问层编写中的困境。

2011年5月22日 这两天在对照几个典型的.net网站的时候，发现了一个小小的问题，大家在对数据库操作的时候经常会用到SqlDataReader，这个方法在调用完之后是要及时关闭的，问题就是什么时候关闭是合适的？
为了这个问题我专门上微软的官方论坛找了点东西，我在这里和我平时用的稍微的对比了一下

我们平时用方法一般是（至少我以前看到的是的，特别是很多.net书籍上）：






/// <summary>
/// 常见的获取SqlDataReader方法
/// 通常的数据访问层都会提供这个方法
/// </summary>
static SqlDataReader GetReader()

{

    //通过连接字符串获取连接
    SqlConnection con =
new SqlConnection(conn_String);

    try

    {

        //打开连接，执行查询

        //并且返回SqlDataReader
        con.Open();

        SqlCommand cmd = con.CreateCommand();

        cmd.CommandText = Sql;

        SqlDataReader dr = cmd.ExecuteReader();

        return dr;

    }

    finally

    {

        //这里的代码就是问题所在

        //如果这里执行关闭：


        con.Close();


        //那返回的SqlDataReader将毫无用处，因为其

        //依赖的连接已经关闭

        //如果这里不执行con.Close();那返回后该连接将永远无法关闭，因为调用方无法

        //得到连接对象
    }

}


我在微软的官方实例petshop中看的方法却是：




static SqlDataReader GetReader_CloseConnection(SqlConnection con)

    {

        try

        {

            //打开连接，执行查询

            //并且返回SqlDataReader
            con.Open();

            SqlCommand cmd = con.CreateCommand();

            cmd.CommandText = Sql;

            SqlDataReader dr = cmd.ExecuteReader(CommandBehavior.CloseConnection);

            return dr;

        }

        finally

        {

            //不需要使用con.Close();
        }

    }


我找了找CommandBehavior.CloseConnection的作用

CommandBehavior.CloseConnection的功能恰好就是为了避免类似的尴尬境地，它能够保证当SqlDataReader对象被关闭时，其依赖的连接也会被自动关闭。

只需要在使用DataReader对象之后的时候，将DataReader对象关闭即可，这样conn就自己关闭了。找了个小例子：







/// <summary>
/// 测试方法
/// </summary>
static 
void Main(string[] args)

{

    //建立连接
    SqlConnection con =
new SqlConnection(conn_String);

    try

    {

        //测试使用了CommandBehavior.CloseConnection的方法
        Console.WriteLine("测试使用了CommandBehavior.CloseConnection的方法：");

        SqlDataReader sdr = GetReader_CloseConnection(con);

        while (sdr.Read()) { }

        sdr.Close();

        Console.WriteLine("读取完毕后的连接状态："
+ con.State.ToString());

        //测试没有使用CommandBehavior.CloseConnection的方法
        Console.WriteLine("测试没有使用CommandBehavior.CloseConnection的方法：");

        SqlDataReader sdr1 = GetReader_NoCloseConnection(con);

        while (sdr1.Read()) { }

        sdr1.Close();

        Console.WriteLine("读取完毕后的连接状态："
+

        con.State.ToString());

        Console.Read();

    }

    finally

    {

        //确保连接被关闭
        if (con.State
!= ConnectionState.Closed)

            con.Close();

    }

}


读取完毕后的连接状态：Closed


测试没有使用CommandBehavior.CloseConnection的方法：

读取完毕后的连接状态：Open

正如读者所看到的，使用了CommandBehavior.CloseConnection得到的SqlDataReader对象，在关闭的同时会自动地关闭其依赖的数据库连接对象，这个特性解决了数据访问层编写中的困境。

转自：http://hi.baidu.com/516%D0%A1%C5%DA/blog/item/30a79ede7738d51962279808.html

我是指针，却丢失了目标地址！ 我是循环，却缺少了结束条件！ 我是函数，却没有人来调用！