连接池
以往的JDBC使用方式，每次操作sql从底层注册驱动获取连接是非常耗时和浪费资源的，sql实施后需要释放资源，有点类似于开酒店。客人来了，招了几个服务员。客人离开后，服务员被开除，新客人来了，不得不招新服务员。… 使用连接池时，当系统初始化时，数据库连接池会自动申请一些连接对象。当用户访问数据库时，他们会从连接池中获得连接对象。用户访问后，将连接对象返回连接池，节约资源，提高效率；
实现方式
- 标准接口: DataSource javax.sql;
- 一般来说，我们不实现它，一般由数据库制造商实现；
C3P0连接池
- Maven引入数据库驱动包和C3P0包
<dependency> <groupId>com.mchange</groupId> <artifactId>c3p0</artifactId> <version>0.9.5.2</version> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>8.0.18</version> </dependency> - 定义配置文件的名称必须称为c3p0.properties或者c3p0-config.xml,将文件放在src可以在目录下使用后者
<?xml version="1.0" encoding="UTF-8"?> <c3p0-config> <!--默认配置--> <default-config> <property name="initialPoolSize">10</property> <property name="maxIdleTime">30</property
>
<property name="maxPoolSize">100</property>
<property name="minPoolSize">10</property>
<property name="maxStatements">200</property>
</default-config>
<!--配置连接池mysql-->
<named-config name="mysql">
<property name="driverClass">com.mysql.jdbc.Driver</property>
<property name="jdbcUrl">jdbc:mysql://localhost:3306/test?characterEncoding=utf8&useSSL=false</property>
<property name="user">root</property>
<property name="password">root</property>
<property name="initialPoolSize">10</property>
<property name="maxIdleTime">30</property>
<property name="maxPoolSize">100</property>
<property name="minPoolSize">10</property>
<property name="maxStatements">200</property>
</named-config>
<!--配置连接池2-->
......
</c3p0-config>
- 创建数据库连接池对象 ComboPooledDataSource 获取连接 getConnection C3P0工具类
import com.mchange.v2.c3p0.ComboPooledDataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class C3p0Utils {
//通过标识名来创建相应连接池
static ComboPooledDataSource dataSource = new ComboPooledDataSource("mysql");
/** * //从连接池中取用一个连接 * @return */
public static Connection getConnection() {
try {
return dataSource.getConnection();
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
/** * 释放连接回连接池 */
public static void closeAll(Connection conn, PreparedStatement pst, ResultSet rs) {
if (rs != null) {
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (pst != null) {
try {
pst.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (conn != null) {
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
Druid连接池
- 导入jar包
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.38</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid</artifactId>
<version>1.1.14</version>
</dependency>
- 定义配置文件,任意名称的properties文件,可以放在任意位置
#驱动加载 driverClassName=com.mysql.jdbc.Driver #注册驱动 url=jdbc:mysql://127.0.0.1:3306/test?characterEncoding=utf-8 #连接数据库的用户名 username=root #连接数据库的密码 password=password #属性类型的字符串，通过别名的方式配置扩展插件,监控统计用的stat 日志用log4j 防御sql注入:wall filters=stat #初始化时池中建立的物理连接个数。 initialSize=2 #最大的可活跃的连接池数量 maxActive=300 #获取连接时最大等待时间，单位毫秒，超过连接就会失效。配置了maxWait之后，缺省启用公平锁，并发效率会有所下降， 如果需要可以通过配置useUnfairLock属性为true使用非公平锁。 maxWait=60000 #连接回收器的运行周期时间，时间到了清理池中空闲的连接，testWhileIdle根据这个判断 timeBetweenEvictionRunsMillis=60000 minEvictableIdleTimeMillis=300000 #用来检测连接是否有效的sql，要求是一个查询语句。 validationQuery=SELECT 1 #建议配置为true，不影响性能，并且保证安全性。 申请连接的时候检测，如果空闲时间大于timeBetweenEvictionRunsMillis， 执行validationQuery检测连接是否有效。 testWhileIdle=true #申请连接时执行validationQuery检测连接是否有效，做了这个配置会降低性能。设置为false testOnBorrow=false #归还连接时执行validationQuery检测连接是否有效，做了这个配置会降低性能,设置为flase testOnReturn=false #是否缓存preparedStatement，也就是PSCache。 poolPreparedStatements=false #池中能够缓冲的preparedStatements语句数量 maxPoolPreparedStatementPerConnectionSize=200
- 获取数据库连接池对象,通过工厂类获取,DruidDataSourceFactory 获取连接
import com.alibaba.druid.pool.DruidDataSourceFactory;
import javax.sql.DataSource;
import java.io.InputStream;
import java.sql.Connection;
import java.util.Properties;
public class demo {
public static void main(String[] args) throws Exception {
//加载配置文件
InputStream stream = demo.class.getClassLoader().getResourceAsStream("druid.properties");
Properties properties = new Properties();
properties.load(stream);
//获取数据库连接池对象
DataSource dataSource = DruidDataSourceFactory.createDataSource(properties);
//获取连接
Connection connection = dataSource.getConnection();
System.out.println(connection);
}
}
Druid工具类
import com.alibaba.druid.pool.DruidDataSourceFactory;
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;
public class DruidUtils {
private static DataSource dataSource;
static {
try {
//加载配置文件
Properties properties = new Properties();
properties.load(DruidUtils.class.getClassLoader().getResourceAsStream("druid.properties"));
//通过druid的工厂，创建连接池对象
dataSource = DruidDataSourceFactory.createDataSource(properties);
} catch (Exception e) {
e.printStackTrace();
}
}
/** * 获取连接池 * */
public static DataSource getDataSource(){
return dataSource;
}
/** *获取连接 */
public static Connection getConnection() throws SQLException {
return dataSource.getConnection();
}
/** * 释放资源 */
public static void close(Statement statement,Connection connection){
if (statement!=null){
try {
statement.close();
} catch (SQLException throwables) {
throwables.printStackTrace();
}
}
if (connection!=null){
try {
connection.close();
} catch (SQLException throwables) {
throwables.printStackTrace();
}
}
}
/** * 释放资源 */
public static void close(ResultSet resultSet, Statement statement, Connection connection){
if (resultSet!=null){
try {
resultSet.close();
} catch (SQLException throwables) {
throwables.printStackTrace();
}
}
if (statement!=null){
try {
statement.close();
} catch (SQLException throwables) {
throwables.printStackTrace();
}
}
if (connection!=null){
try {
connection.close();
} catch (SQLException throwables) {
throwables.printStackTrace();
}
}
}
}
测试
public static void main(String[] args) {
Connection connection = null;
PreparedStatement pstmt = null;
try {
//通过工具类获取连接
connection = DruidUtils.getConnection();
//定义sql
String sql = "insert into user values (null,?);";
//获取PreparedStatement的对象
pstmt = connection.prepareStatement(sql);
//给sql赋值,第一个问号赋值"张三"
pstmt.setString(1,"张三");
执行sql
int i = pstmt.executeUpdate();
System.out.println(i);
} catch (SQLException throwables) {
throwables.printStackTrace();
}finally {
DruidUtils.close(pstmt,connection);
}
}