数据库连接池
连接池的简介
- 实际开发中“获得连接”或“释放资源”是非常消耗系统资源的两个过程,为了解决此类性能问题,通常情况我们采用连接池技术,来共享连接Connection。这样我们就不需要每次都创建连接、释放连接了,这些操作都交给了连接池
- 当使用完Connection后,调用Connection的close()方法也不会真的关闭(销毁)Connection,而是把Connection“归还”给池
- 连接池技术可管理数据库连接,可以重复的使用连接
实际上是把从数据库获取连接改成从连接池获取连接。使用以后再归还
连接池的具体使用
Java为数据库连接池提供了公共的接口:javax.sql.DataSource(接口是规范)
常见的连接池有 DBCP连接池, C3P0连接池, Druid连接池
数据准备
#创建数据库
CREATE DATABASE db5 CHARACTER SET utf8;
USE db5;
#创建员工表
CREATE TABLE employee (
eid INT PRIMARY KEY AUTO_INCREMENT ,
ename VARCHAR (20), -- 员工姓名
age INT , -- 员工年龄
sex VARCHAR (6), -- 员工性别
salary DOUBLE , -- 薪水
empdate DATE -- 入职日期
);
#插入数据
INSERT INTO employee (eid, ename, age, sex, salary, empdate) VALUES(NULL,'李清 照',22,'女',4000,'2018-11-12');
INSERT INTO employee (eid, ename, age, sex, salary, empdate) VALUES(NULL,'林黛 玉',20,'女',5000,'2019-03-14');
INSERT INTO employee (eid, ename, age, sex, salary, empdate) VALUES(NULL,'杜 甫',40,'男',6000,'2020-01-01');
INSERT INTO employee (eid, ename, age, sex, salary, empdate) VALUES(NULL,'李白',25,'男',3000,'2017-10-01');
DBCP连接池
Tomcat使用的连接池就是DBCP
在DBCP包中提供了DataSource接口的实现类,我们要用的具体的连接池 BasicDataSource 类
编写工具类从连接池中获取连接
public class DBCPUtils {
//1.定义常量,保存数据库连接的相关信息 一下四个常量是必须设置的
public static final String DRIVERNAME= "com.mysql.jdbc.Driver";
public static final String URL= "jdbc:mysql://localhost:3306/db5?characterEncoding=UTF-8";
public static final String USERNAME = "root";
public static final String PASSWORD = "hmyhmy";
//2.创建连接池对象 由DBCP提供的实现类
public static BasicDataSource dataSource = new BasicDataSource();
//3.使用静态代码块进行配置
static {
dataSource.setDriverClassName(DRIVERNAME);
dataSource.setUrl(URL);
dataSource.setUsername(USERNAME);
dataSource.setPassword(PASSWORD);
}
//4.获取连接的方法
public static Connection getConnection() throws SQLException {
//从连接池中获取连接
Connection connection = dataSource.getConnection();
return connection;
}
//5.释放资源的方法
public static void close(Connection con, Statement statement){
if(con!=null && statement!=null){
try {
statement.close();
//归还连接
con.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
//重载
public static void close(Connection con, Statement statement, ResultSet resultSet){
if(con!=null && statement!=null && resultSet!=null){
try {
resultSet.close();
statement.close();
//归还连接
con.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
测试一下
public class TestDBCP {
//测试DBCP连接池
public static void main(String[] args) throws SQLException {
//1.从DBCP连接池中拿到连接
Connection con = DBCPUtils.getConnection();
//2.获取语句执行对象statement对象
Statement statement=con.createStatement();
//3.对数据库进行查询:查询所有员工的姓名
String sql = "select ename from employee";
ResultSet resultSet = statement.executeQuery(sql);
//4.处理结果集
while(resultSet.next()){
String ename = resultSet.getString("ename");
System.out.println("员工姓名:"+ename);
}
//释放资源
DBCPUtils.close(con,statement,resultSet);
}
}