当前位置： 首页 > news >正文

Druid连接池和Apache的DBUtils

news 2025/6/21 13:56:46

背景

jdbc连接数据库存在着大批量用户进行短时间的SQL连接操作的 需求，而普通用户连接后直接断开与数据库的连接，下次连接需要重新建立桥梁，再频繁访问时。这是很消耗性能的一个操作，因此诞生了数据库连接池技术。提前创建 一些连接，避免频繁的创建连接，并且可以管理程序和数据库之间的连接，动态分配桥梁给申请连接的应用程序。

Druid连接池

  • Druid（德鲁伊）连接池是阿里开发的，据说是集DBCP、C3P0、Proxool优点于一身的数据库连接池。

一、如何使用Druid连接池

  1. 引入德鲁伊连接池jar包和jdbc驱动jar包（网上搜索一下，很容易找到下载，注意是.jar文件）
  2. 代码步骤：
    • 第一步：建立一个数据库连接池对象
    • 第二步：设置连接池的参数
    • 第三步：从连接池中获取连接对象来使用
  3. 代码示例
@Testpublic void test1() throws SQLException {DruidDataSource ds = new DruidDataSource();//设置基本参数ds.setDriverClassName("com.mysql.cj.jdbc.Driver");ds.setUrl("jdbc:mysql://localhost:3306/atguigu");ds.setUsername("root");ds.setPassword("123456");//设置其他连接参数ds.setInitialSize(10);//初始化连接数ds.setMaxActive(11);//最大活动连接数ds.setMaxWait(1000);//最大等待时间ds.setMinIdle(5);//最小连接数for (int i = 0; i < 30; i++) {DruidPooledConnection conn = ds.getConnection();System.out.println("conn = " + conn);conn.close();//释放连接到连接池中}}

二、封装Druid连接池

1.配置文件参数批量导入

Druid连接池提供了一个createDataSource(Properties prop)的方法来统一设置连接池的参数，由于底层是采用硬编码编写的，所以配置文件的变量名称必须与代码一致，否则无法将配置读取到项目中。

具体步骤：

  1. 读取配置文件的参数信息
  2. 使用工厂设计模式批量给参数赋值
  3. 创建线程池ds
  4. 调用线程的getConnection方法来获取一个连接
public class JdbcTool2 {private static DataSource ds;static {//1.注册驱动Properties prop = new Properties();try {//加载配置文件中的数据到Properties中//配置文件要放到src目录下prop.load(JdbcTools.class.getClassLoader().getResourceAsStream("jdbc.properties"));//批量设置参数的大小ds = DruidDataSourceFactory.createDataSource(prop);//Class.forName(className);} catch (IOException e) {throw new RuntimeException(e);} catch (Exception e) {throw new RuntimeException(e);}}public static Connection getConnection() throws SQLException {//获取连接return ds.getConnection();}
}

2.绑定连接对象

在MVC分层模型中，如果我们在DAO层中使用jdbc技术建立连接修改了账号表的数据，而在业务层中为了模拟转账的需求又再次获取了一个Connection对象来实现该事务。该写法会导致我们重复创建了不同的连接，并且当代码出现异常执行事务回滚时会发现不能恢复到原有的状态。这是由于两层代码中的连接对象并不是同一个。

解决方案如下：

  1. 在jdbc工具类中定义一个ThreadLocal对象
  2. 在静态代码块中将其实例化
  3. 获取连接时使用类似单例模式的写法来将连接与线程绑定在一起
public class JdbcTool3 {private static DataSource ds;private static ThreadLocal<Connection> threadLocal;static {//1.注册驱动Properties prop = new Properties();try {//加载配置文件中的数据到Properties中prop.load(JdbcTools.class.getClassLoader().getResourceAsStream("jdbc.properties"));//配置文件要放到src目录下//批量设置参数的大小ds = DruidDataSourceFactory.createDataSource(prop);//Class.forName(className);//3.创建线程threadLocal = new ThreadLocal<>();} catch (IOException e) {throw new RuntimeException(e);} catch (Exception e) {throw new RuntimeException(e);}}public static Connection getConnection() throws SQLException {//获取连接Connection conn = threadLocal.get();if(conn==null){conn = ds.getConnection();threadLocal.set(conn);}return conn;}public static void closeAll(ResultSet rs, Statement st, Connection conn){try {if(rs!=null){rs.close();}if(st!=null){st.close();}if(conn!=null){conn.close();//将连接还给连接池threadLocal.remove();//把连接对象从当前线程移除}} catch (SQLException e) {throw new RuntimeException(e);}}public static DataSource getDs(){return ds;}
}

示例代码

三、Apche的DBUtils

一个已经封装好了的工具类，可以简化我们在编写DAO层代码的复杂度。主要分两个方面来介绍一下该工具类，分别是增删改和查询操作。

1.update操作

简化之前的代码：

//添加用户public int addUser(User user) throws SQLException {Connection conn = JdbcTool3.getConnection();PreparedStatement pst = conn.prepareStatement("insert into users(username, password) values(?,?)");pst.setObject(1,user.getUsername());pst.setObject(2,user.getPassword());int i = pst.executeUpdate();JdbcTool3.closeAll(null,pst,conn);return i;}

使用DBUtils后的代码：

//添加用户public int addUser(User user) throws SQLException {String sql = "insert into users(username, password) values(?,?)";int update = qr.update(sql, user.getUsername(), user.getPassword());return update;}

2. query操作

简化之前的代码：

//根据id查询用户public User getUserById(int id) throws SQLException {Connection conn = JdbcTool3.getConnection();PreparedStatement pst = conn.prepareStatement("select id, username, password from users where id = ?");pst.setObject(1,id);ResultSet rs = pst.executeQuery();User user = null;if(rs.next()){int ID = rs.getInt("id");String username = rs.getString("username");String password = rs.getString("password");System.out.print("ID = " + ID);System.out.print(",username = " + username);System.out.println(",password = " + password);user = new User(ID, username, password);}JdbcTool3.closeAll(null,pst,conn);return user;}

使用DBUtils后的代码：

public User getUserById2(int id) throws SQLException {String sql = "select id, username, password from users where id = ?";return qr.query(sql,new BeanHandler<>(User.class),id);}

其中query方法中的BeanHandler对象底层是通过反射的方式来动态的将对象创建出来，可以选择相应容器来包装，如果是单个字段的话，可以使用相应的Handle对象来处理。

http://www.lryc.cn/news/144251.html

相关文章：

  • 怎样快速选择正确的可视化图表？
  • 6路液体水位检测芯片VK36W6D SOP16 抗电源干扰及手机干扰特性好
  • 【设备树笔记整理6】中断系统中的设备树
  • 微信小程序下载后端返回的文件流
  • Autoware.universe部署04：universe传感器ROS2驱动
  • Spring boot如何工作
  • 代码随想录打卡—day45—【DP】— 8.29 完全背包应用
  • 2023.8.28日论文阅读
  • HAproxy（四十七）
  • Java实战场景下的ElasticSearch
  • 拓世科技集团 | “书剑人生”李步云学术思想研讨会暨李步云先生九十华诞志庆
  • 前端须知名词解释
  • React性能优化之memo缓存函数
  • 2023年高教社杯 国赛数学建模思路 - 案例：ID3-决策树分类算法
  • C# Emgu.CV 条码检测
  • VueRouter的基本使用
  • 网工笔记：快速认识7类逻辑接口
  • MySQL中的free链表，flush链表，LRU链表
  • mac使用VsCode远程连接服务器总是自动断开并要求输入密码的解决办法
  • Python爬虫分布式架构 - Redis/RabbitMQ工作流程介绍
  • 【ES】笔记-集合介绍与API
  • Spring Boot(Vue3+ElementPlus+Axios+MyBatisPlus+Spring Boot 前后端分离)【五】
  • 二、Tomcat 安装集
  • CentOS 上通过 NFS 挂载远程服务器硬盘
  • 微信小程序中的 广播监听事件
  • Quickstart: MinIO for Linux
  • Java中word转Pdf工具类
  • 【conda install】网络慢导致报错CondaHTTPError: HTTP 000 CONNECTION FAILED for url
  • 2023-8-28 图中点的层次(树与图的广度优先遍历)
  • 设计模式（一）