企业🤖AI智能体构建引擎,智能编排和调试,一键部署,支持私有化部署方案 广告
[TOC] # 简介 实际开发中“获得连接”或“释放资源”是非常消耗系统资源的两个过程,为了解决此类性能问题,通常情况我们采用连接池技术,来共享连接Connection。这样我们就不需要每次都创建连接、释放连接了,这些操作都交给了连接池 用池来管理Connection,这样可以重复使用Connection。有了池,所以我们就不用自己来创建Connection,而是通过池来获取Connection对象。当使用完Connection后,调用Connection的close()方法也不会真的关闭Connection,而是把Connection“归还”给池。池就可以再利用这个Connection对象了。 Java为数据库连接池提供了公共的接口:javax.sql.DataSource,各个厂商需要让自己的连接池实现这个接口。这样应用程序可以方便的切换不同厂商的连接池! 常见的连接池:DBCP、C3P0。 # DBCP连接池 DBCP也是一个开源的连接池,是Apache Common成员之一,tomcat内置的连接池。 ## 导入jar包 dbcp和pool,当然之前的包还是要的mysql和dbutils ## 编写工具类 连接数据库表的工具类, 采用DBCP连接池的方式来完成,Java中提供了一个连接池的规则接口 : DataSource : 它是java中提供的连接池,作为 DriverManager 工具的替代项。在DBCP包中提供了DataSource接口的实现类,我们要用的具体的连接池 BasicDataSource类 ~~~ public class JDBCUtils { public static final String DRIVER = "com.mysql.jdbc.Driver"; public static final String URL = "jdbc:mysql://localhost:3306/daydb"; public static final String USERNAME = "root"; public static final String PASSWORD = "root"; /* * 创建连接池BasicDataSource */ public static BasicDataSource dataSource = new BasicDataSource(); //静态代码块 static { //对连接池对象 进行基本的配置 dataSource.setDriverClassName(DRIVER); // 这是要连接的数据库的驱动 dataSource.setUrl(URL); //指定要连接的数据库地址 dataSource.setUsername(USERNAME); //指定要连接数据的用户名 dataSource.setPassword(PASSWORD); //指定要连接数据的密码 } /* * 返回连接池对象 */ public static DataSource getDataSource(){ return dataSource; } } ~~~ ## 工具类的使用 ~~~ // 插入功能 @Test public void insert(){ try { //获取一个用来执行SQL语句的对象 QueryRunner QueryRunner qr = new QueryRunner(JDBCUtils.getDataSource()); String sql = "INSERT INTO zhangwu(name,money,parent) VALUES(?,?,?)"; Object[] params = {"股票收入", 5500, "收入"}; int line = qr.update(sql,params); //结果集处理 System.out.println("line = " + line); } catch (SQLException e) { throw new RuntimeException(e); } } //删除功能 @Test public void delete(){ try { //创建一个QueryRunner对象,用来完成SQL语句的执行 QueryRunner qr = new QueryRunner(JDBCUtils.getDataSource()); //执行SQL语句 String sql = "DELETE FROM zhangwu WHERE name = ?"; Object[] params = {"股票收入"}; int line = qr.update(sql, params); //结果集的处理 System.out.println("line="+line); } catch (SQLException e) { throw new RuntimeException(e); } } //查询功能,将结果集中第一条记录封装到一个指定的javaBean中。 @Test public void search(){ try{ //获取QueryRunner QueryRunner qr = new QueryRunner(JDBCUtils.getDataSource()); //执行SQL语句 String sql = "SELECT * FROM zhangwu"; Object[] params = {}; Product p = qr.query(sql, new BeanHandler<Product>(Product.class), params); //结果集处理 System.out.println(p); } catch(SQLException e){ throw new RuntimeException(e); } } ~~~ # 常见配置项 ![](https://box.kancloud.cn/388f551c9db6029dfde1efeb388ef88f_1520x670.jpg) 参考文档:http://commons.apache.org/proper/commons-dbcp/configuration.html