欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识！
您现在的位置是： 首页

DBCP和C3P0数据源

程序员文章站 2022-05-24 11:07:31
...

数据库连接池

DBCP---------C3P0连接池

什么是连接池

数据库连接—执行完毕—释放

连接—释放 十分浪费系统资源

池化技术:准备一些预先的资源,过来就连接预先准备好的

比如银行柜台:

开门—服务一个人—关门 浪费

开门—业务员:等待—服务—关门 池子

那么一个银行到底需要多少个业务员?(最小连接数)

**最小连接数:**如果常用连接数在一百个左右,最小连接数设置为100;

最大连接数: 业务最高承载上限;

**等待超时:**100ms

开源数据源实现

编写连接池,需要实现一个接口DataSource

DBCP

C3P0

Druid:阿里

使用了这些数据库连接池之后,我们在项目开发中就不需要编写连接数据库的代码了

在并发情况下,使用数据源能提高程序的性能

开源实现:导入JAR包,拿来即用

使用DBCP

先配置Maven环境

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.otwb</groupId>
    <artifactId>MavenMysqlJDBC</artifactId>
    <version>1.0-SNAPSHOT</version>
    <dependencies>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.48</version>
        </dependency>

        <dependency>
            <groupId>commons-dbcp</groupId>
            <artifactId>commons-dbcp</artifactId>
            <version>1.4</version>
        </dependency>

        <dependency>
            <groupId>commons-pool</groupId>
            <artifactId>commons-pool</artifactId>
            <version>1.5.4</version>
        </dependency>
    </dependencies>
    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
    </properties>

</project>

创建配置文件

#连接设置 这里面的名字是DBCP数据源中定义好的,不能自己起名字
driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/jdbcstudy?useUnicode=true&characterEncoding=utf8&useSSL=true
username=root
password=root

#<!-- 初始化连接 -->
initialSize=10

#最大连接数量
maxActive=50

#<!-- 最大空闲连接 -->
maxIdle=20

#<!-- 最小空闲连接 -->
minIdle=5

#<!-- 超时等待时间以毫秒为单位 6000毫秒/1000等于60秒 -->
maxWait=60000
#JDBC驱动建立连接时附带的连接属性属性的格式必须为这样：【属性名=property;】
#注意：user 与 password 两个属性会被明确地传递，因此这里不需要包含他们。
connectionProperties=useUnicode=true;characterEncoding=UTF8

#指定由连接池所创建的连接的自动提交（auto-commit）状态。
defaultAutoCommit=true

#driver default 指定由连接池所创建的连接的只读（read-only）状态。
#如果没有设置该值，则“setReadOnly”方法将不被调用。（某些驱动并不支持只读模式，如：Informix）
defaultReadOnly=

#driver default 指定由连接池所创建的连接的事务级别（TransactionIsolation）。
#可用值为下列之一：（详情可见javadoc。）NONE,READ_UNCOMMITTED, READ_COMMITTED, REPEATABLE_READ, SERIALIZABLE
defaultTransactionIsolation=READ_UNCOMMITTED

使用DBCP获取连接,写工具类

package demo6.utils;

import org.apache.commons.dbcp.BasicDataSourceFactory;

import javax.sql.DataSource;
import java.io.InputStream;
import java.sql.*;
import java.util.Properties;


public class JdbcUtils_DBCP {

    private static DataSource dataSource = null;

    static {
        try {
            /*以下读取DBCP的配置文件*/
            //用Properties 类获取配置文件
            InputStream in = JdbcUtils_DBCP.class.getClassLoader().getResourceAsStream("dbcpconfig.properties");
            Properties properties = new Properties();
            properties.load(in);
            //创建数据源  工厂模式-->创建对象的
            dataSource = BasicDataSourceFactory.createDataSource(properties);

        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    //获取连接
    public static Connection getConnection() throws SQLException {
        return dataSource.getConnection(); //从数据源中获取连接  --池化技术  提高性能
    }


    //释放连接资源
    public static void release(Connection conn, Statement st, ResultSet rs) {
        if (rs != null) {
            try {
                rs.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }
        if (st != null) {
            try {
                st.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }
        if (conn != null) {
            try {
                conn.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }
//        if (in != null) {
//            try {
//                in.close();
//            } catch (IOException e) {
//                e.printStackTrace();
//            }
//        }
    }
}

测试

package demo6;

import demo2.utils.JdbcUtils;
import demo6.utils.JdbcUtils_DBCP;

import java.util.Date;// new Data();报错  需要导入这个包
import java.sql.*;

public class TestDBCP {
    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement st = null;
        ResultSet re = null;
        try {
            conn = JdbcUtils_DBCP.getConnection();
            //与Statement区别
            //使用?占位符  代替参数
            //prepareStatement  防止SQL注入的本质,把传递进来的参数当做字符
            //假设其中存在转义字符,比如  '  会被直接转义
            //MyBatis里面的参数都是这样写的
            String sql = "insert into users(id,`NAME`,`PASSWORD`,`email`,`birthday`)values(?,?,?,?,?)";
            st = conn.prepareStatement(sql);//需要一个预编译SQL,先写SQL然后不执行
            //手动给参数赋值
            st.setInt(1,4);//id
            st.setString(2,"leakli");//NAME
            st.setString(3,"1234567");//password
            st.setString(4,"[email protected]");//password
            //注意点: sql.Date    数据库
            //       util.Date   java       new Date().getTime()  获得时间戳
            st.setDate(5,new java.sql.Date(new Date().getTime()));//birthday
            //执行
            int i = st.executeUpdate();
            if(i>0){
                System.out.println("插入成功");
            }
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        } finally {
            JdbcUtils_DBCP.release(conn,st,null);
        }
    }
}

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-69Ryfwo3-1625391309669)(C:\Users\hang.li\AppData\Roaming\Typora\typora-user-images\image-20210704163051943.png)]

暂时看不出效果,但是在并发的情况下,使用数据源,程序的性能有所提高

使用C3P0

需要使用的Jar包:

  • c3p0-0.9.55.jar
  • mchange-commons-java-0.2.19.jar

配置Maven环境

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.otwb</groupId>
    <artifactId>MavenMysqlJDBC</artifactId>
    <version>1.0-SNAPSHOT</version>
    <dependencies>

        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.48</version>
        </dependency>

        <dependency>
            <groupId>commons-dbcp</groupId>
            <artifactId>commons-dbcp</artifactId>
            <version>1.4</version>
        </dependency>

        <dependency>
            <groupId>commons-pool</groupId>
            <artifactId>commons-pool</artifactId>
            <version>1.5.4</version>
        </dependency>

        <dependency>
            <groupId>com.mchange</groupId>
            <artifactId>c3p0</artifactId>
            <version>0.9.5.2</version>
        </dependency>

        <dependency>
            <groupId>com.mchange</groupId>
            <artifactId>mchange-commons-java</artifactId>
            <version>0.2.11</version>
        </dependency>

    </dependencies>
    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
    </properties>

</project>

创建配置文件

<?xml version="1.0" encoding="UTF-8"?>
<c3p0-config>
    <!-- 默认配置，如果没有指定则使用这个配置 -->
    <!--C3P0的缺省(默认)配置
    如果在代码中"ComboPooledDataSource ds = new ComboPooledDataSource();
    这样写就表示使用的是C3P0的缺省(默认)"-->
    <default-config>
        <property name="user">root</property>
        <property name="password">root</property>
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/jdbcstudy?useUnicode=true&amp;
            characterEncoding=utf8&amp;useSSL=true</property>
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="checkoutTimeout">30000</property>
        <property name="idleConnectionTestPeriod">30</property>
        <property name="initialPoolSize">10</property>
        <property name="maxIdleTime">30</property>
        <property name="maxPoolSize">100</property>
        <property name="minPoolSize">2</property>
        <property name="maxStatements">200</property>
    </default-config>
    <!-- 命名的配置,可以通过方法调用实现 -->
    <!-- 如果在代码中ComboPooledDataSource ds=new ComboPooledDataSource(MySQL);
    这样写就表示使用的是mysql的缺省（默认）-->
    <named-config name="MySQL">
        <property name="user">root</property>
        <property name="password">root</property>
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/jdbcstudy?useUnicode=true&amp;
            characterEncoding=utf8&amp;useSSL=true</property>
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <!-- 如果池中数据连接不够时一次增长多少个 -->
        <property name="acquireIncrement">5</property>
        <!-- 初始化数据库连接池时连接的数量 -->
        <property name="initialPoolSize">20</property>
        <!-- 数据库连接池中的最大的数据库连接数 -->
        <property name="maxPoolSize">25</property>
        <!-- 数据库连接池中的最小的数据库连接数 -->
        <property name="minPoolSize">5</property>
    </named-config>
</c3p0-config>

写工具类

package demo6.utils;

import com.mchange.v2.c3p0.ComboPooledDataSource;

import java.sql.*;


public class JdbcUtils_C3P0 {

    private static ComboPooledDataSource dataSource = null;

    static {
        try {
//            //代码实现
//            dataSource = new ComboPooledDataSource();
//            dataSource.setDriverClass();
//            dataSource.setUser();
//            dataSource.setPassword();
//            dataSource.setJdbcUrl();
//
//            dataSource.setMaxPoolSize();
//            dataSource.setMinPoolSize();
            /*以下读取DBCP的配置文件,且C3P0的配置文件类型是xml类型,会自动读取*/
            //创建数据源  工厂模式-->创建对象的
            dataSource = new ComboPooledDataSource("MySQL");//配置文件写法

        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    //获取连接
    public static Connection getConnection() throws SQLException {
        return dataSource.getConnection(); //从数据源中获取连接  --池化技术  提高性能
    }


    //释放连接资源
    public static void release(Connection conn, Statement st, ResultSet rs) {
        if (rs != null) {
            try {
                rs.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }
        if (st != null) {
            try {
                st.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }
        if (conn != null) {
            try {
                conn.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }
//        if (in != null) {
//            try {
//                in.close();
//            } catch (IOException e) {
//                e.printStackTrace();
//            }
//        }
    }
}

测试

package demo6;

import demo6.utils.JdbcUtils_C3P0;
import java.util.Date;// new Data();报错  需要导入这个包
import java.sql.*;

public class TestC3P0 {
    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement st = null;
        ResultSet re = null;
        try {
            conn = JdbcUtils_C3P0.getConnection(); //原来是自己实现的,现在用别人实现的
            //与Statement区别
            //使用?占位符  代替参数
            //prepareStatement  防止SQL注入的本质,把传递进来的参数当做字符
            //假设其中存在转义字符,比如  '  会被直接转义
            //MyBatis里面的参数都是这样写的
            String sql = "insert into users(id,`NAME`,`PASSWORD`,`email`,`birthday`)values(?,?,?,?,?)";
            st = conn.prepareStatement(sql);//需要一个预编译SQL,先写SQL然后不执行
            //手动给参数赋值
            st.setInt(1,8);//id
            st.setString(2,"leakli");//NAME
            st.setString(3,"1234567");//password
            st.setString(4,"[email protected]");//password
            //注意点: sql.Date    数据库
            //       util.Date   java       new Date().getTime()  获得时间戳
            st.setDate(5,new java.sql.Date(new Date().getTime()));//birthday
            //执行
            int i = st.executeUpdate();
            if(i>0){
                System.out.println("插入成功");
            }
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        } finally {
            JdbcUtils_C3P0.release(conn,st,null);
        }
    }
}

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-zhw71a4C-1625391309670)(C:\Users\hang.li\AppData\Roaming\Typora\typora-user-images\image-20210704172136304.png)]

结论

无论使用什么数据源,本质还是一样的,DataSource接口不会变,方法就不会变;只需要更改几点

Druid(数据源,主要)

apache 阿帕奇基金会

www.apache.rog

DBCP和C3P0数据源

tomcat/maven 等等工具,开源

DBCP和C3P0数据源
相关标签： dbcp c3p0

上一篇： 十大摇篮品牌排行榜：妈咪宝上榜，好孩子最受欢迎

下一篇： 开发颠覆者SpringBoot实战---------SpringBoot的Web学习

推荐阅读