博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
c3p0数据库连接池+mysql数据库基本使用方法
阅读量:6070 次
发布时间:2019-06-20

本文共 3035 字,大约阅读时间需要 10 分钟。

       一般我们在项目中操作数据库时,都是每次需要操作数据库就建立一个连接,操作完成后释放连接。因为jdbc没有保持连接的能力,一旦超过一定时间没有使用(大约几百毫秒),

连接就会被自动释放掉。而每次新建连接都需要140毫秒左右的时间,所以耗费时间比较多。若使用C3P0连接池来池化连接,随时取用,则平均每次取用只需要10-20毫秒。

这在高并发随机访问数据库的时候对效率的提升有很大帮助。

      C3P0连接池会根据你的配置来初始化N个数据库连接,空闲T时间后连接过期又会自动新建K个连接使得连接池总有空闲的数据库连接等待被取用。我们只需通过dataSourse.getConnection()

即可从线程池中取用一个已经连接好的空闲连接,执行数据库操作。然后“断开”(放回)这个连接,把这个连接的使用权放回连接池。真正的数据库连接的创建与释放是由C3P0在后台自动完成的

,我们花的只是取用与释放占用权的时间。全程耗时10+毫秒,比原来提高了几十倍。

 

下面我使用idea举例

首先需要三个jar包:

 

整体的项目结构如下;

 

这里的xml文件默认只能放在src文件下才能识别,且名字不能改

c3p0-config.xml代码如下:

10
30
100
10
200
com.mysql.jdbc.Driver
jdbc:mysql://localhost:3306/customer
root
1234
10
30
100
10
200

 

在Test.java中测试

package main;import com.mchange.v2.c3p0.ComboPooledDataSource;import java.sql.*;import java.sql.PreparedStatement;import java.sql.SQLException;/** * Created by Administrator on 2017/8/4. */public class Test {    static ComboPooledDataSource cpds=null;    static{        //这里有个优点,写好配置文件,想换数据库,简单        //cpds = new ComboPooledDataSource("oracle");//这是oracle数据库        cpds = new ComboPooledDataSource("mysql");//这是mysql数据库    }    /**     * 获得数据库连接     * @return   Connection     */    public static Connection getConnection(){        try {            return cpds.getConnection();        } catch (SQLException e) {            e.printStackTrace();            return null;        }    }    /**     * 数据库关闭操作     * @param conn     * @param pst     * @param rs     */    public static void close(Connection conn, PreparedStatement pst, ResultSet rs){        if(rs!=null){            try {                rs.close();            } catch (SQLException e) {                e.printStackTrace();            }        }        if(pst!=null){            try {                pst.close();            } catch (SQLException e) {                e.printStackTrace();            }        }        if(conn!=null){            try {                conn.close();            } catch (SQLException e) {                e.printStackTrace();            }        }    }    /**     * 测试DBUtil类     * @param args     */    public static void main(String[] args) {        Connection conn=getConnection();        try {            PreparedStatement pst=conn.prepareStatement("SELECT * FROM t_customer");            ResultSet rs=pst.executeQuery();            while(rs.next()){                System.out.println(rs.getString(1)+" "+rs.getString(2)+" "+rs.getString(3));            }        } catch (SQLException e) {            e.printStackTrace();        }        close(conn,null,null);    }}

 

转载于:https://www.cnblogs.com/liushuncheng/p/7283671.html

你可能感兴趣的文章
[LeetCode]括号生成(Generate Parentheses)
查看>>
机器学习从业人员到底做什么?
查看>>
Laravel-Action 对代码的改造
查看>>
联调环境快速部署——基于docker-compose的CI/CD实践
查看>>
【跃迁之路】【498天】刻意练习系列257(2018.06.18)
查看>>
vue 解决addRoutes动态添加路由后,刷新失效问题
查看>>
Java多线程基础(十一)——Future模式
查看>>
解决Retrofit多BaseUrl及运行时动态改变BaseUrl(二)
查看>>
【深入浅出MyBatis笔记】插件
查看>>
sublime常用基础插件合集
查看>>
React 重温之Render Props
查看>>
聊聊JerseyEurekaHttpClient的参数
查看>>
js 粘贴图片的应用(clipboardData)
查看>>
5分钟解决小程序的微信支付
查看>>
SpringBoot里的@Import使用
查看>>
Mac 配置Apache服务器详解
查看>>
从Rancher 1.6到2.0:术语及概念变化对比
查看>>
一次线上问题的排查解决过程
查看>>
ES5与ES6字符串方法总结
查看>>
基于Django开发的简洁博客系统
查看>>