通过JDBC使用连接池的操作

一、C3P0连接池

1.通过JDBC使用C3P0连接池
C3P0是一个开源的JDBC连接池，它实现了数据源和JNDI绑定，支持JDBC3规范和JDBC2的标准扩展。目前使用它的开源项目有Hibernate、Spring等。
例如：

create table t_user(
user_id int primary key auto_increment,
user_name varchar(20),
user_age int,
user_sex bit,
user_address varchar(30),
user_day datetime
);

2.创建Java项目
3.导入依赖包
c3p0-0.9.5.2.jar
mchange-commons-java-0.2.15.jar
mysql-connector-java-5.1.38.jar
4.在ser下创建c3p0的配置文件【c3p0-config.xml】

<?xml version="1.0" encoding="UTF-8"?> com.mysql.jdbc.Driver jdbc:mysql://localhost:3306/test root 123456 5 20 com.mysql.jdbc.Driver jdbc:mysql://localhost:3306/test root 123456 25 200

5.创建javabean

package com.wangxing.bean;
/*** 保存用户信息的java实体类* @author Administrator**/import java.sql.Date;public class UserBean {private int userid;private String username;private int userage;private boolean usersex;private String useraddress;private Date userday;public int getUserid() {return userid;}public void setUserid(int userid) {this.userid = userid;}public String getUsername() {return username;}public void setUsername(String username) {this.username = username;}public int getUserage() {return userage;}public void setUserage(int userage) {this.userage = userage;}public boolean isUsersex() {return usersex;}public void setUsersex(boolean usersex) {this.usersex = usersex;}public String getUseraddress() {return useraddress;}public void setUseraddress(String useraddress) {this.useraddress = useraddress;}public Date getUserday() {return userday;}public void setUserday(Date userday) {this.userday = userday;}
}

6.创建数据库访问类

package com.wamgxing.dbacsess;
import java.sql.Connection;
import java.sql.Date;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import com.mchange.v2.c3p0.ComboPooledDataSource;
import com.wangxing.bean.UserBean;
public class UserAcsess {//定义保存c3p0数据源对象private ComboPooledDataSource dataSource=null;//定义数据库连接对象private  Connection  conn=null;//定义PreparedStatement private PreparedStatement ps=null;public UserAcsess() {//加载c3p0-config.xml文件中默认的config//初始化数据源//dataSource =new ComboPooledDataSource();//初始化数据源,加载的是自定义的数据库表配置项dataSource =new ComboPooledDataSource("test");//初始化数据源try {conn=dataSource.getConnection();} catch (SQLException e) {e.printStackTrace();}}public  void  insertUser(UserBean  userbean) {try {String insertsql="insert into t_user values(null,?,?,?,?,?);";ps=conn.prepareStatement(insertsql);ps.setString(1,userbean.getUsername());ps.setInt(2,userbean.getUserage());ps.setBoolean(3,userbean.isUsersex());ps.setString(4,userbean.getUseraddress());ps.setDate(5,new Date(System.currentTimeMillis()));int temp=ps.executeUpdate();if(temp>0)  System.out.println("添加成功");}catch(Exception e) {e.printStackTrace();}finally {try {ps.close();conn.close();} catch (SQLException e) {e.printStackTrace();}}}public  void  updateUser(UserBean  userbean) {try {String insertsql="update t_user set user_name=?,"+ "user_age=?,user_sex=?,user_address=?,user_day=?"+ " where user_id=?";ps=conn.prepareStatement(insertsql);ps.setString(1,userbean.getUsername());ps.setInt(2,userbean.getUserage());ps.setBoolean(3,userbean.isUsersex());ps.setString(4,userbean.getUseraddress());ps.setDate(5,new Date(System.currentTimeMillis()));ps.setInt(6,userbean.getUserid());int temp=ps.executeUpdate();if(temp>0)  System.out.println("修改成功");}catch(Exception e) {e.printStackTrace();}finally {try {ps.close();conn.close();} catch (SQLException e) {e.printStackTrace();}}}public  void  deleteUser(int userid) {try {String insertsql="delete from t_user where user_id=?";ps=conn.prepareStatement(insertsql);ps.setInt(1,userid);int temp=ps.executeUpdate();if(temp>0)  System.out.println("删除成功");}catch(Exception e) {e.printStackTrace();}finally {try {ps.close();conn.close();} catch (SQLException e) {e.printStackTrace();}}}public  void  selectUser() {try {String selectsql="select* from t_user;";ps=conn.prepareStatement(selectsql);ResultSet temp=ps.executeQuery();while(temp.next()) {int userid=temp.getInt("user_id");String username=temp.getString("user_name");int userage=temp.getInt("user_age");boolean usersex=temp.getBoolean("user_sex");String useraddress=temp.getString("user_address");Date userday=temp.getDate("user_day");System.out.println(userid+"\t"+username);}}catch(Exception e) {e.printStackTrace();}finally {try {ps.close();conn.close();} catch (SQLException e) {e.printStackTrace();}}}
}

优点:不用手动编写创建数据库连接对象的操作，因为c3p0的数据库连接池的配置中已经配置初始化成功。提供程序的执行效率。日后切换数据库的时候不需要修改源代码，只需要修改c3p0的数据库连接池的配置。

二、通过JDBC使用dbcp连接池

create table t_user(
user_id int primary key auto_increment,
user_name varchar(20),
user_age int,
user_sex bit,
user_address varchar(30),
user_day datetime
);

1.创建java项目
2.导入jar包
【commons-dbcp-1.4.jar
commons-dbutils-1.6.jar
commons-pool-1.6.jar】
3.在src下创建数据库连接配置文件【xxxxxxxx.properties】
driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=utf8
username=root
password=123456
maxActive=50
maxIdle=20
maxWait=60000
4.创建javabean
5.创建数据库访问类

 public UserAscess() {try {Properties pro=new Properties();InputStream inStream=this.getClass().getResourceAsStream("/jdbcdbcp.properties");pro.load(inStream);DataSource ds=BasicDataSourceFactory.createDataSource(pro);conn=ds.getConnection();}catch(Exception e) {e.printStackTrace();}}

三、JDBC访问Druid
Druid首先是一个数据库连接池。Druid是目前最好的数据库连接池，在功能、性能、扩展性方面，都超过其他数据库连接池，包括DBCP、C3P0、BoneCP、Proxool、JBoss DataSource。Druid已经在阿里巴巴部署了超过600个应用，经过一年多生产环境大规模部署的严苛考验。Druid是阿里巴巴开发的号称为监控而生的数据库连接池！
同时Druid不仅仅是一个数据库连接池，它包括四个部分：
Druid是一个JDBC组件，它包括三个部分：
基于Filter－Chain模式的插件体系。
DruidDataSource 高效可管理的数据库连接池。
SQLParser

Druid的功能
1、替换DBCP和C3P0。Druid提供了一个高效、功能强大、可扩展性好的数据库连接池。
2、可以监控数据库访问性能，Druid内置提供了一个功能强大的StatFilter插件，能够详细统计SQL的执行性能，这对于线上分析数据库访问性能有帮助。
3、数据库密码加密。直接把数据库密码写在配置文件中，这是不好的行为，容易导致安全问题。DruidDruiver和DruidDataSource都支持PasswordCallback。
4、SQL执行日志，Druid提供了不同的LogFilter，能够支持Common-Logging、Log4j和JdkLog，你可以按需要选择相应的LogFilter，监控你应用的数据库访问情况。
5、扩展JDBC，如果你要对JDBC层有编程的需求，可以通过Druid提供的Filter机制，很方便编写JDBC层的扩展插件。

所以Druid可以：
1、充当数据库连接池。
2、可以监控数据库访问性能
3、获得SQL执行日志

例如：

create table t_user(
user_id int primary key auto_increment,
user_name varchar(20),
user_age int,
user_sex bit,
user_address varchar(30),
user_day datetime
);

1.创建java项目
2.导入jar包【druid-1.1.10.jar】
3.在src下创建数据库连接配置文件【xxxxxxxx.properties】
driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=UTF-8
username=root
password=123456
initialSize=100
maxActive=300
maxWait=60000
Druid配置详解
https://blog.csdn.net/zhangjinwei417/article/details/92823438
4.创建javabean
5.创建数据库访问类

  private Connection conn=null;private PreparedStatement ps=null;public UserAscess() {try {Properties pro=new Properties();InputStream inStream=this.getClass().getResourceAsStream("/druid.properties");pro.load(inStream);DataSource ds=DruidDataSourceFactory.createDataSource(pro);conn=ds.getConnection();}catch(Exception e) {e.printStackTrace();}}