JavaSE-数据库连接池

本文主要是介绍JavaSE-数据库连接池，对大家解决编程问题具有一定的参考价值，需要的程序猿们随着小编来一起学习吧！

1.1 连接池

1.1.1 连接池基本特点

1) 什么是连接池

实际开发中“获得连接”或“释放资源”是非常消耗系统资源的两个过程，为了解决此类性能问题，通常情况采用连接池技术，来共享连接Connection。
这样就不需要每次都创建连接、释放连接了，这些操作都交给了连接池。

2) 连接池的好处

用池来管理Connection，这样可以重复使用Connection。当使用完Connection后，调用Connection的
close()方法也不会真的关闭Connection，而是把Connection“归还”给池。

1.1.2 JDBC方式与连接池方式

普通 JDBC方式

连接池方式

1.1.3 如何使用数据库连接池

Java为数据库连接池提供了公共的接口：javax.sql.DataSource，各个厂商需要让自己的连接池实现这个接口。
这样应用程序可以方便的切换不同厂商的连接池。

1.1.4 SQL语句

## 创建员工表
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');

-- 查询数据
select * from employee;

1.2 DBCP连接池

1.2.1 添加依赖

<!--dbcp连接池-->
<dependency>
    <groupId>org.apache.commons</groupId>
    <artifactId>commons-dbcp2</artifactId>
    <version>2.7.0</version>
</dependency>

1.2.2 编写工具类

连接数据库表的工具类, 采用DBCP连接池的方式来完成

Java中提供了一个连接池的规则接口： DataSource , 它是java中提供的连接池。
在DBCP包中提供了DataSource接口的实现类，我们要用的具体的连接池 BasicDataSource 类。

package cn.guardwhy.utils;

import org.apache.commons.dbcp2.BasicDataSource;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class DBCPUtils {
    //1. 定义字符串常量, 获取连接所需要的信息
    public static final String DRIVERNAME = "com.mysql.jdbc.Driver";
    public static final String URL = "jdbc:mysql://localhost:3306/db_jdbc?
    characterEncoding=UTF-8";
    public static final String USERNAME = "root";
    public static final String PASSWORD = "root";

    // 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 {
        // 4.1 从连接池中获取连接
        Connection connection = dataSource.getConnection();
        return connection;
    }
    // 5.释放资源
    public static void close(Connection connection, Statement statement){
        // 5.1 条件判断
        if(connection != null && statement != null){
            try {
                statement.close();
                // 5.2 归还连接
                connection.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
    // 6.关闭连接
    public static void close(Connection connection, Statement statement, 
    ResultSet resultSet){
        // 6.1 条件判断
        if(connection != null && statement != null && resultSet != null){
            try {
                resultSet.close();
                statement.close();
                // 6.1 归还连接
                connection.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

1.2.3 测试工具类

需求: 查询所有员工的姓名

package cn.guardwhy.test;

import cn.guardwhy.utils.DBCPUtils;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

/*
* 测试dbcp连接池
*/
public class TestDbcp {
    public static void main(String[] args) throws SQLException {
        // 1.从dbcp连接池中拿到连接对象
        Connection connection = DBCPUtils.getConnection();
        // 2. 获取statement对象
        Statement statement = connection.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);
        }
        // 5.释放资源
        DBCPUtils.close(connection, statement, resultSet);
    }
}

1) 执行结果

1.3 Druid连接池

Druid（德鲁伊）是阿里巴巴开发的号称为监控而生的数据库连接池，Druid是目前最好的数据库连接池。在功能、性能、扩展性方面，都超过其他数据库连接池，同时加入了日志监控，可以很好的监控DB池连接和SQL的执行情况。

1.3.1 添加依赖

<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid</artifactId>
    <version>1.1.10</version>
</dependency>

1.3.2 导入配置文件

driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://127.0.0.1:3306/db_jdbc?characterEncoding=
UTF-8&rewriteBatchedStatements=true
username=root
password=root
initialSize=5
maxActive=10
maxWait=3000

1.3.3 编写Druid工具类

获取数据库连接池对象

通过工厂来来获取 DruidDataSourceFactory类的createDataSource方法。
createDataSource(Properties p) 方法参数可以是一个属性集对象。

package cn.guardwhy.utils;

import com.alibaba.druid.pool.DruidDataSourceFactory;

import javax.sql.DataSource;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

public class DruidUtils {
    //1.定义成员变量
    public static DataSource dataSource;

    //2.静态代码块
    static{
        try {
            //3.创建属性集对象
            Properties p = new Properties();

            //4.加载配置文件 Druid 连接池不能够主动加载配置文件 ,需要指定文件
            InputStream inputStream = DruidUtils.class.getClassLoader().
            getResourceAsStream("druid.properties");

            //5. 使用Properties对象的 load方法 从字节流中读取配置信息
            p.load(inputStream);

            //6. 通过工厂类获取连接池对象
            dataSource = DruidDataSourceFactory.createDataSource(p);

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

    //获取连接的方法
    public static Connection getConnection(){

        try {
            return dataSource.getConnection();

        } catch (SQLException e) {
            e.printStackTrace();
            return null;
        }
    }

    //获取Druid连接池对象的方法
    public static DataSource getDataSource(){
        return dataSource;
    }
    
    //释放资源
    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();
            }
        }

    }
}

1.3.4 测试工具类

需求: 查询薪资在3000 - 5000元之间的员工姓名

package cn.guardwhy.test;

import cn.guardwhy.utils.DruidUtils;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class TestDruid {
    // 需求 查询 薪资在3000 到 5000之间的员工的姓名
    public static void main(String[] args) throws SQLException {

        //1.获取连接
        Connection con = DruidUtils.getConnection();

        //2.获取Statement对象
        Statement statement = con.createStatement();

        //3.执行查询
        ResultSet resultSet = statement.executeQuery
        ("select ename from employee where salary between 3000 and 5000");

        //4.处理结果集
        while(resultSet.next()){
            String ename = resultSet.getString("ename");
            System.out.println(ename);
        }

        //5.释放资源
        DruidUtils.close(con,statement,resultSet);
    }
}

这篇关于JavaSE-数据库连接池的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！

Java教程

JavaSE-数据库连接池

1.1 连接池

1.1.1 连接池基本特点

1.1.2 JDBC方式与连接池方式

1.1.3 如何使用数据库连接池

1.1.4 SQL语句

1.2 DBCP连接池

1.2.1 添加依赖

1.2.2 编写工具类

1.2.3 测试工具类

1.3 Druid连接池

1.3.1 添加依赖

1.3.2 导入配置文件

1.3.3 编写Druid工具类

1.3.4 测试工具类

前端开发

后端开发

移动端开发

数据库

服务器运维

人工智能

区块链

游戏开发

网站运营

大数据/云计算

软件工程

软件/开发工具使用

资讯