前面的博客:https://blog.csdn.net/Marshallren/article/details/106874531
之前的案例中,每个类写好后都需要获取一个连接,而获取连接是获取资源的一个过程,非常耗时。你用完就释放,效率很低。好比你要吃饭,然后你拿来一双筷子,吃完了,你把筷子扔了。所以为了提高效率,我们引出了今天要说的内容:数据库连接池
数据库连接池
数据库连接池是一个容器(集合),用于存放数据库连接(Connection)。当系统初始化好后,创建一个容器,容器中会申请一些连接对象,当用户来访问数据库时,从容器中获取连接对象,用户访问完数据库后,不是将资源还给底层,而是还给容器,这样做的优点就算节约资源、用户访问的效率高
数据库连接池的实现
通过实现DataSource接口来完成
*DataSource接口:是Spring的一个接口,可以用来获取数据库的Connection(连接)
用到的方法:
Connection getConnection():获取连接
Connection.close():归还连接
*由数据库厂商来实现,不需要我们来实现
数据库连接池实现技术
1.C3P0
C3P0技术使用步骤:
1.导入驱动jar包:mysql-connector-java-5.1.37-bin.jar
2.导入两个jar包:c3p0-0.9.5.2.jar、mchange-commons-java-0.2.12.jar
3.定义配置文件:
文件名称:c3p0.properties 或者 c3p0-config.xml
路径:直接将文件放在src目录下即可
*c3p0-config.xml文件内配置了连接池的初始化连接数量、最大连接数量等
4.创建数据库连接池对象:数据库连接池对象 ComboPooledDataSource
5.获取连接:getConnection();
E.G:
-
package cn.itcast.datasource.c3p0;
-
-
import com.mchange.v2.c3p0.ComboPooledDataSource;
-
import javax.sql.DataSource;
-
import java.sql.Connection;
-
import java.sql.SQLException;
-
-
/**
-
* c3p0的演示
-
*/
-
public
class c3p0Demo1
-
{
-
public static void main(String[] args) throws SQLException {
-
//1.创建数据库连接池对象
-
DataSource ds =
new ComboPooledDataSource();
-
//2.获取连接对象
-
Connection conn = ds.getConnection();
-
//3.打印
-
System.out.println(conn);
-
}
-
}
结果:可以看到此时已经获得了连接对象
*注意:红色的内容不是错误信息,而是日志。一定要慢慢学会看日志内容!
2.Druid
Druid使用步骤:
1.导入驱动jar包:druid-1.0.9.jar
2.定义配置文件:
路径:直接将文件放在src目录下即可(理论上可以放在任意目录下,不过和C3P0相比,Druid多了一个加载配置文件的过程)
3.加载配置文件
-
Properties pro =
new Properties();
-
InputStream is = DruidDemo1.class.getClassLoader().getResourceAsStream(
"druid.properties");
-
pro.load(is);
4.获取数据库连接池对象:通过工厂类获取,DruidDataSourceFactory()
5.获取连接:getConnection();
E.G:
-
package cn.itcast.datasource.druid;
-
-
import com.alibaba.druid.pool.DruidDataSourceFactory;
-
import javax.sql.DataSource;
-
import java.io.IOException;
-
import java.io.InputStream;
-
import java.sql.Connection;
-
import java.util.Properties;
-
-
public
class DruidDemo1 {
-
public static void main(String[] args) throws Exception {
-
//1.加载配置文件
-
Properties pro =
new Properties();
-
InputStream is = DruidDemo1.class.getClassLoader().getResourceAsStream(
"druid.properties");
-
pro.load(is);
-
//2.获取连接池对象
-
DataSource ds = DruidDataSourceFactory.createDataSource(pro);
-
//3.获取连接
-
Connection conn = ds.getConnection();
-
//4.打印结果
-
System.out.println(conn);
-
}
-
}
结果:
Druid配合工具类来完成实例
上述的工作只是如何通过数据连接池获取连接,而如果在实际操作中每进行一次连接操作就要创建新对象,实在是太麻烦了,而且也不专业,小心日后被专业团队给抬走了(黑人抬棺),所以我们需要创建一个工具类来减少冗余,提高复用性
1.建立一个util包,内部创建一个jdbcUtils类
-
package cn.itcast.datasource.utils;
-
-
import cn.itcast.datasource.druid.DruidDemo1;
-
import com.alibaba.druid.pool.DruidDataSourceFactory;
-
import com.sun.xml.internal.bind.v2.model.core.PropertyInfo;
-
import javax.sql.DataSource;
-
import java.io.IOException;
-
import java.sql.Connection;
-
import java.sql.ResultSet;
-
import java.sql.SQLException;
-
import java.sql.Statement;
-
import java.util.Properties;
-
-
public
class JDBCUtils {
-
//1.定义成员变量DataSource
-
private
static DataSource ds;
-
-
/**
-
*配置文件的读取,只需要读取一次即可。使用静态代码块
-
*/
-
static {
-
try {
-
//1.加载配置文件
-
Properties pro =
new Properties();
-
pro.load(JDBCUtils.class.getClassLoader().getResourceAsStream(
"druid.properties"));
-
-
//2.获取连接池对象
-
ds = DruidDataSourceFactory.createDataSource(pro);
-
}
catch (IOException e) {
-
e.printStackTrace();
-
}
catch (Exception e) {
-
e.printStackTrace();
-
}
-
}
-
-
/**
-
*获取连接
-
*/
-
public static Connection getConnection() throws SQLException {
-
return ds.getConnection();
-
}
-
-
/**
-
*归还连接
-
*/
-
public static void close(Statement stmt, Connection conn) {
-
close(
null, stmt, conn);
//减少代码量
-
}
-
-
/**
-
*归还连接重载
-
*/
-
public static void close(ResultSet rs, Statement stmt, Connection conn) {
-
if (rs !=
null) {
-
try {
-
rs.close();
//归还连接
-
}
catch (SQLException e) {
-
e.printStackTrace();
-
}
-
}
-
-
if (stmt !=
null) {
-
try {
-
stmt.close();
//归还连接
-
}
catch (SQLException e) {
-
e.printStackTrace();
-
}
-
}
-
-
if (conn !=
null) {
-
try {
-
conn.close();
//归还连接
-
}
catch (SQLException e) {
-
e.printStackTrace();
-
}
-
}
-
}
-
-
/**
-
*获取连接池方法(本例子用不到,先写这儿)
-
*/
-
public static DataSource getDataSource(){
-
return ds;
-
}
-
}
2.main函数
-
package cn.itcast.datasource.druid;
-
-
import cn.itcast.datasource.utils.JDBCUtils;
-
import java.sql.Connection;
-
import java.sql.PreparedStatement;
-
import java.sql.SQLException;
-
-
public
class DruidDemo2 {
-
public static void main (String[] args) {
-
//0.抽取变量,复用
-
Connection conn =
null;
-
PreparedStatement pstmt =
null;
-
try {
-
//1.获取连接
-
conn = JDBCUtils.getConnection();
-
//2.定义sql
-
String sql =
"insert into account values(null, ?, ?)";
-
//3.获取pstmt对象
-
pstmt = conn.prepareStatement(sql);
-
//4.给?赋值
-
pstmt.setString(
1,
"王五");
-
pstmt.setDouble(
2,
3000);
-
//5.执行sql
-
int count = pstmt.executeUpdate();
-
System.out.println(count);
-
}
catch (SQLExceptione) {
-
e.printStackTrace();
-
}
finally {
-
//6.归还资源
-
JDBCUtils.close(pstmt, conn);
-
}
-
}
-
}
转载:https://blog.csdn.net/Marshallren/article/details/106888346