文章目录
- 1、druid连接MySQL
- 2、编写JDBCUtils 工具类
1、druid连接MySQL
初学JDBC时，连接数据库是先建立连接，用完直接关闭。这就需要不断的创建和销毁连接，会消耗系统的资源。
借鉴线程池的思想，数据连接池就这么被设计出来了。
什么是连接池？
连接池是在程序初始化的时候，预先创建好指定数量的数据库连接对象，存储与连接池中，需要用的时候就去取，用完还回来。数据库连接池就是为数据库的连接建立一个“缓冲区”，预先在“缓冲池”中放入一定数量的连接，当需要建立数据库连接时，只需从“缓冲区”中取出，使用完毕后再放回去，这样就不会有频繁的创建和销毁，从而节省系统的资源。
数据库连接池负责分配、管理和释放数据库连接，它允许应用程序重复使用一个现有的数据库连接，而不是重新建立一个。
对比传统的数据库连接，有以下缺点：
- 普通JDBC使用DriverManager来获取，每次向数据库建立连接都将Connection加载到内存，执行完毕后再断开，这样会消耗大量的时间和资源，数据库的连接资源并没有被很好的利用，若同时几百人甚至几千人在线，频繁的进行数据库连接操作会占用很多资源，严重甚至会造成服务器的崩溃。
- 每一次连接后都要断开，否则，程序会出现异常没能及时关闭会导致数据库系统中的内存泄露（java 内存泄露）
- 不能控制被创建的连接对象，系统资源会毫无顾忌的分配出去，如连接过多，可能会导致服务器崩溃。
数据库连接池有以下优点：
- 提高程序响应速度，减少创建连接的响应时间
- 减低资源的消耗，可以重复使用以及提供数据库的连接
- 便于管理
连接池市面上有很多，有druid（德鲁伊）、c3p0、dbcp……
其中 c3p0 和 dbcp 是国外的，druid 是国内常用的，是阿里巴巴做的一个开源技术，性能很好，如今全世界的Java程序员都可以使用。
使用步骤：
1、导入druid.jar包！！！；
2、创建一个 Properties 形式的配置文件，可以放在 src 目录下；
3、获取数据库连接池对象，通过工程的一个类来获取：DruidDataSourceFactory；
4、获取连接；
例程1 —— druid 数据线程池连接数据库，并遍历数据库的数据：
package com.test;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.Properties;
import javax.sql.DataSource;
import com.alibaba.druid.pool.DruidDataSourceFactory;
public class Test {
public static void main(String[] args) throws Exception {
//加载配置文件
Properties pro = new Properties();
InputStream is = Test.class.getClassLoader().getResourceAsStream("druid.properties");
pro.load(is);
//获取连接池对象
DataSource ds = DruidDataSourceFactory.createDataSource(pro);
//获取连接
Connection con = ds.getConnection();
//遍历数据库
Statement stmt = con.createStatement();
ResultSet res = stmt.executeQuery("SELECT * FROM tb_student");
try {
while(res.next()) {
int id = res.getInt("id");
String studentNumber = res.getString("studentNumber");
String name = res.getString("name");
String gender = res.getString("gender");
String classAndGrade = res.getString("classAndGrade");
String politicsStatus = res.getString("politicsStatus");
String dateOfBirth = res.getString("dateOfBirth");
String phone = res.getString("phone");
String homeAddress = res.getString("homeAddress");
System.out.print("序号：" + id + " ");
System.out.print("学号：" + studentNumber + " ");
System.out.print("姓名：" + name + " ");
System.out.print("性别：" + gender + " ");
System.out.print("班级：" + classAndGrade + " ");
System.out.print("政治面貌：" + politicsStatus + " ");
System.out.print("出生日期：" + dateOfBirth + " ");
System.out.print("电话：" + phone + " ");
System.out.print("家庭地址：" + homeAddress + " ");
System.out.println();
}
}catch (Exception e) {
System.out.println("遍历数据库失败，原因：");
e.printStackTrace();
}
}
}
# druid.Properties文件配置备份
# 加载驱动
driverClassName = com.mysql.cj.jdbc.Driver
# url
url = jdbc:mysql://localhost:3306/test1?serverTimezone=GMT%2B8&useSSL=false&characterEncoding=utf-8
# 用户名
username = root
# 密码
password = 123456
# 初始连接数
initialSize = 10
# 最小连接
minIdle = 5
# 最大连接
maxActive = 50
# 超时时间
maxWait = 5000
工程配置如下：
运行结果中，7月 12, 2024 8:46:46 下午 com.alibaba.druid.pool.DruidDataSource info
信息: {dataSource-1} inited解释如下：
成功使用 druid 连接 MySQL 后，为了方便数据库连接池的连接，可以定义一个 Druid 的工具类，该工具封装了获取连接，关闭连接的方法。
2、编写JDBCUtils 工具类
成功使用 druid 连接 MySQL 后，为了方便数据库连接池的连接，可以定义一个 Druid 的工具类，该工具封装了获取连接，关闭连接的方法。
JDBCUtils.java
package com.test;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;
import javax.sql.DataSource;
import com.alibaba.druid.pool.DruidDataSourceFactory;
//Druid 连接池的工具类
public class JDBCUtils {
//定义成员变量
@SuppressWarnings("unused")
private static DataSource ds;
static {
try {
//加载配置文件
Properties pro = new Properties();
pro.load(JDBCUtils.class.getClassLoader().getResourceAsStream("druid.properties"));
//获取DataSource
ds = DruidDataSourceFactory.createDataSource(pro);
} catch (Exception e) {
e.printStackTrace();
}
}
//获取连接
public static Connection getConnection() throws SQLException{
return ds.getConnection();
}
//释放资源
public static void close(ResultSet rs, Statement stmt, Connection conn) {
if(rs != null) {
try {
rs.close();
}catch (Exception e) {
e.printStackTrace();
}
}
if(stmt != null) {
try {
stmt.close();
}catch (Exception e) {
e.printStackTrace();
}
}
if(conn != null) {
try {
conn.close();
}catch (Exception e) {
e.printStackTrace();
}
}
}
public static void close(Statement stmt, Connection conn) {
close(null, stmt, conn);
}
}
主方法：
package com.test;
import java.sql.*;
public class Test {
public static void main(String[] args) throws Exception {
Connection conn = null;
Statement stmt = null;
ResultSet res = null;
try {
//获取连接
conn = JDBCUtils.getConnection();
//查询遍历数据库
stmt = conn.createStatement();
res = stmt.executeQuery("SELECT * FROM tb_student");
while(res.next()) {
int id = res.getInt("id");
String studentNumber = res.getString("studentNumber");
String name = res.getString("name");
String gender = res.getString("gender");
String classAndGrade = res.getString("classAndGrade");
String politicsStatus = res.getString("politicsStatus");
String dateOfBirth = res.getString("dateOfBirth");
String phone = res.getString("phone");
String homeAddress = res.getString("homeAddress");
System.out.print("序号：" + id + " ");
System.out.print("学号：" + studentNumber + " ");
System.out.print("姓名：" + name + " ");
System.out.print("性别：" + gender + " ");
System.out.print("班级：" + classAndGrade + " ");
System.out.print("政治面貌：" + politicsStatus + " ");
System.out.print("出生日期：" + dateOfBirth + " ");
System.out.print("电话：" + phone + " ");
System.out.print("家庭地址：" + homeAddress + " ");
System.out.println();
}
}catch (Exception e) {
e.printStackTrace();
}finally {
JDBCUtils.close(res, stmt, conn);
}
}
}
工程结构：
