IDEA中使用Druid数据库连接池连接数据库
-
数据库连接池其实就是一个容器(集合),存放数据库连接的容器。
当系统初始化好后,容器被创建,容器中会申请一些连接对象,当用户来访问数据库时,从容器中获取连接对象,用户访问之后,会将连接对象归还给容器。
-
好处:
- 节约资源
- 用户访问高效
-
实现
-
标准接口:DataSource javax.sql包下的
- 方法:
- 获取连接:getConnection()
- 归还连接:Connection.close() 。如果连接对象Connection是从连接池中获取的,那么调用Connection.close() 方法则不会再关闭连接了。而是归还连接
- 方法:
-
一般我们不去实现它,有数据库厂商来实现
- C3P0:数据库连接池技术(这个比较老了)
- Druid:数据库连接池实现技术,由阿里巴巴提供,最好的。
-
-
C3P0:数据库连接池技术
-
步骤:
-
导入jar包(三个)(不要忘了自己导入连接数据库的jar包):
-
链接:https://pan.baidu.com/s/1IZtZA5_EkwhHJ4U9Ohy9Mw
提取码:hxl0 -
定义配置文件:
-
名称:文件名一定要是:c3p0.properties 或者 c3p0-config.xml
-
路径:直接将文件放在src目录下即可
-
<!-- 这个配置文件的文件名为:c3p0-config.xml --> <c3p0-config> <!-- 使用默认的配置读取连接池对象 --> <default-config> <!-- 连接参数 --> <property name="driverClass">com.mysql.cj.jdbc.Driver</property> <property name="jdbcUrl">jdbc:mysql://localhost:3306/test</property> <property name="user">root</property> <property name="password">123456</property> <!-- 连接池参数 --> <!-- 初始化申请的连接数量 --> <property name="initialPoolSize">5</property> <!-- 最大的连接数量 --> <property name="maxPoolSize">10</property> <!-- 超时时间 --> <property name="checkoutTimeout">3000</property> </default-config> <!-- 创建数据库连接池对象时,ComboPooledDataSource()不传参使用默认的配置,即上面的配置,如果传入otherc3p0参数ComboPooledDataSource("otherc3p0"),则使用下面这段设置了属性为name="otherc3p0"的配置 --> <name-config name="otherc3p0"> <!-- 连接参数 --> <property name="driverClass">com.mysql.cj.jdbc.Driver</property> <property name="jdbcUrl">jdbc:mysql://localhost:3306/test</property> <property name="user">root</property> <property name="password">123456</property> <!-- 连接池参数 --> <property name="initialPoolSize">5</property> <property name="maxPoolSize">8</property> <property name="checkoutTimeout">1000</property> </name-config> </c3p0-config>
-
-
创建核心对象,数据库连接池对象 ComboPooledDataSource
-
获取连接:getConnection
-
package jdbc.dataSource.c3p0; import com.mchange.v2.c3p0.ComboPooledDataSource; import javax.sql.DataSource; import java.sql.Connection; import java.sql.SQLException; public class C3P0Demo { public static void main(String[] args) throws SQLException { // 创建数据库连接池对象,不传参使用默认配置 DataSource ds = new ComboPooledDataSource(); // 创建连接对象 for (int i = 0; i < 11; i++) { Connection connection = ds.getConnection(); System.out.println(connection); // 这里创建11个连接对象,但是配置文件中设置的最大连接数量为10,所以如果我没写下面这行connection.close();将会报错 // 这里连接是由连接池创建的,所以连接调用的close()方法是将连接还给连接池,而不是关闭连接 connection.close(); } } }
-
结果:红色的是日志信息,最下面那行才是输出的连接对象,@后面的是哈希值
-
-
-
Druid:数据库连接池实现技术,由阿里巴巴提供的
- 步骤:
-
导入jar包 druid-1.2.8.jar
-
链接:https://pan.baidu.com/s/1ftYEfU8d4wml13kpxsDjuA
提取码:o814 -
定义配置文件:
- 是properties形式的
- 可以叫任意名称,可以放在任意目录下
url=jdbc:mysql://127.0.0.1:3306/test username=root password=123456 initialSize=5 maxActive=10 maxWat=3000
-
加载配置文件:Properties
-
获取数据库连接池对象:通过工厂来获取:DruidDataSourceFactory
-
获取连接:getConnection()
-
- 步骤:
package jdbc.dataSource.druid;
import com.alibaba.druid.pool.DruidDataSourceFactory;
import javax.sql.DataSource;
import java.io.InputStream;
import java.sql.Connection;
import java.util.Properties;
public class DruidDemo {
public static void main(String[] args) throws Exception {
// 加载配置文件
Properties pro = new Properties();
InputStream is = DruidDemo.class.getClassLoader().getResourceAsStream("druid.properties");
BufferedReader br = new BufferedReader(new InputStreamReader(is));
pro.load(br);
// 获取连接池对象
DataSource ds = DruidDataSourceFactory.createDataSource(pro);
// 获取连接
Connection connection = ds.getConnection();
System.out.println(connection);
}
}
- 通过Druid线程池来创建连接也不是很简单,步骤还是比较多的,我们可以创建一个工具类来帮助我们
-
定义一个类 JDBCUtils
-
提供静态代码块加载配置文件,初始化连接池对象
-
提供方法
-
获取连接方法:通过数据库连接池获取连接
-
释放资源
-
获取连接池的方法
-
-
package jdbc.dataSource.jdbcutils;
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;
/**
* Druid连接池工具类
*/
public class JDBCUtils {
// 定义成员变量-连接池对象DataSource
private static DataSource dataSource;
private JDBCUtils() {}
// 通过静态代码块初始化连接池对象
static {
try {
// 加载配置文件
Properties properties = new Properties();
InputStream is = JDBCUtils.class.getClassLoader().getResourceAsStream("druid.properties");
BufferedReader br = new BufferedReader(new InputStreamReader(is));
properties.load(br);
// 获取DataSource
dataSource = DruidDataSourceFactory.createDataSource(properties);
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 获取连接对象
* @return 连接对象
* @throws SQLException 异常
*/
public static Connection getConnection() throws SQLException {
return dataSource.getConnection();
}
/**
* 释放资源
* @param statement sql执行对象
* @param connection 连接对象
*/
public static void close(Statement statement, Connection connection) {
close(null, statement, connection);
}
/**
* 释放资源
* @param resultSet 查询结果对象
* @param statement sql执行对象
* @param connection 连接对象
*/
public static void close(ResultSet resultSet, Statement statement, Connection connection) {
if (resultSet != null) {
try {
resultSet.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (statement != null) {
try {
statement.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (connection != null) {
try {
connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
/**
* 获取连接池对象
* @return 连接池对象
*/
public static DataSource getDataSource() {
return dataSource;
}
}