版权声明:作者已开启版权声明,如转载请注明转载地址。 https://blog.csdn.net/qq_34829447/article/details/82193893
一.DBUtils
1.DButils工具类的介绍三个核心类
- 概述
- DBUtils是java编程中的数据库操作实用工具,小巧简单实用。
- DBUtils封装了对JDBC的操作,简化了JDBC操作,可以少写代码。
- DBUtils就是JDBC的简化开发工具包。需要项目导入commons-dbutils-1.6.jar才能够正常使用DBUtils工具。
- DBUtils三个核心功能介绍
- QueryRunner中提供对sql语句操作的API
update(Connection conn, String sql, Object... params)
,用来完成表数据的增加、删除、更新操作query(Connection conn, String sql, ResultSetHandler<T> rsh, Object... params)
用来完成表数据的查询操作- ResultSetHandler接口,用于定义select操作后,怎样封装结果集
- DbUtils类,它就是一个工具类,定义了关闭资源与事务处理的方法
2.事务的简单介绍
3.QueryRunner类的update方法介绍
update(Connection conn, String sql, Object... params)
,用来完成表数据的增加、删除、更新操作使用QueryRunner类,实现对数据表的insert delete update
调用QueryRunner类的方法
update (Connection con,String sql,Object...param)
- Object…param 可变参数,Object类型,SQL语句会出现?占位符
- 数据库连接对象,自定义的工具类传递
添加数据
public void insert(){ try { //获取一个用来执行SQL语句的对象 QueryRunner QueryRunner qr = new QueryRunner(); String sql = "INSERT INTO zhangwu(name,money,parent) VALUES(?,?,?)"; Object[] params = {"股票收入", 5500, "收入"}; Connection conn = JDBCUtils.getConnection(); int line = qr.update(conn,sql,params);// 用来完成表数据的增加、删除、更新操作 //结果集处理 System.out.println("line = " + line); } catch (SQLException e) { throw new RuntimeException(e); } }
更新数据
public void update(){ try { //创建一个QueryRunner对象,用来完成SQL语句的执行 QueryRunner qr = new QueryRunner(); //执行SQL语句 String sql = "UPDATE zhangwu SET money = money+1000 WHERE name=?"; Object[] params = {"股票收入"}; Connection conn = JDBCUtils.getConnection(); int line = qr.update(conn, sql, params); //结果集的处理 System.out.println("line="+line); } catch (SQLException e) { throw new RuntimeException(e); } }
删除数据
public void delete(){ try { //创建一个QueryRunner对象,用来完成SQL语句的执行 QueryRunner qr = new QueryRunner(); //执行SQL语句 String sql = "DELETE FROM zhangwu WHERE name = ?"; Object[] params = {"股票收入"}; Connection conn = JDBCUtils.getConnection(); int line = qr.update(conn, sql, params); //结果集的处理 System.out.println("line="+line); } catch (SQLException e) { throw new RuntimeException(e); } }
4. JavaBean类的特性
- JavaBean就是一个类,在开发中常用封装数据。
- 需要实现接口:java.io.Serializable ,通常实现接口这步骤省略了,不会影响程序。
- 提供私有字段:private 类型 字段名
- 提供getter/setter方法
- 提供无参构造
5.DBUtils工具类结果集处理的方式
- QueryRunner实现查询操作:
query(Connection conn, String sql, ResultSetHandler<T> rsh, Object... params)
,用来完成表数据的查询操作 - ResultSetHandler结果集处理类
- ArrayHandler将结果集中的第一条记录封装到一个Object[]数组中,数组中的每一个元素就是这条记录中的每一个字段的值
- ArrayListHandler将结果集中的每一条记录都封装到一个Object[]数组中,将这些数组在封装到List集合中
- BeanHandler将结果集中第一条记录封装到一个指定的javaBean中
- BeanListHandler将结果集中每一条记录封装到指定的javaBean中,将这些javaBean在封装到List集合中
- ColumnListHandler将结果集中指定的列的字段值,封装到一个List集合中
- ScalarHandler它是用于单数据。例如select count(*) from 表操作
- MapHandler将结果集第一行封装到Map集合中,Key 列名, Value 该列数据
- MapListHandler将结果集第一行封装到Map集合中,Key 列名, Value 该列数据,Map集合存储到List集合
6.QueryRunner类的方法query
- QueryRunner数据查询操作
- 调用QueryRunner类方法
query(Connection con,String sql,ResultSetHandler <T> r, Object..params)
- ResultSetHandler r 结果集的处理方式,传递ResultSetHandler接口实现类
- Object..params SQL语句中的?占位符
- 调用QueryRunner类方法
- 注意: query方法返回值,返回的是T泛型, 具体返回值类型,跟随结果集处理方式变化
7.结果集处理类案例
结果集处理ArrayHandler
public class QueryRunnerDemo1 { private static Connection con = JDBCUtilsConfig.getConnection(); public static void main(String[] args) throws SQLException{ arrayHandler(); } /* * 结果集第一种处理方法, ArrayHandler * 将结果集的第一行存储到对象数组中 Object[] */ public static void arrayHandler()throws SQLException{ QueryRunner qr = new QueryRunner(); String sql = "SELECT * FROM sort"; //调用方法query执行查询,传递连接对象,SQL语句,结果集处理方式的实现类 //返回对象数组 Object[] result = qr.query(con, sql, new ArrayHandler()); for(Object obj : result){ System.out.print(obj); } } }
结果集处理ArrayListHandler
public class QueryRunnerDemo1 { private static Connection con = JDBCUtilsConfig.getConnection(); public static void main(String[] args) throws SQLException{ arrayListHandler(); } /* * 结果集第二种处理方法,ArrayListHandler * 将结果集的每一行,封装到对象数组中, 出现很多对象数组 * 对象数组存储到List集合 */ public static void arrayListHandler()throws SQLException{ QueryRunner qr = new QueryRunner(); String sql = "SELECT * FROM sort"; //调用query方法,结果集处理的参数上,传递实现类ArrayListHandler //方法返回值 每行是一个对象数组,存储到List List<Object[]> result= qr.query(con, sql, new ArrayListHandler()); //集合的遍历 for( Object[] objs : result){ //遍历对象数组 for(Object obj : objs){ System.out.print(obj+" "); } System.out.println(); } } }
结果集处理BeanHandler
public class QueryRunnerDemo1 { private static Connection con = JDBCUtilsConfig.getConnection(); public static void main(String[] args) throws SQLException{ beanHandler(); } /* * 结果集第三种处理方法,BeanHandler * 将结果集的第一行数据,封装成JavaBean对象 * 注意: 被封装成数据到JavaBean对象, Sort类必须有空参数构造 */ public static void beanHandler()throws SQLException{ QueryRunner qr = new QueryRunner(); String sql = "SELECT * FROM sort "; //调用方法,传递结果集实现类BeanHandler //BeanHandler(Class<T> type) Sort s = qr.query(con, sql, new BeanHandler<Sort>(Sort.class)); System.out.println(s); } }
结果集处理BeanListHandler
扫描二维码关注公众号,回复: 3247331 查看本文章public class QueryRunnerDemo1 { private static Connection con = JDBCUtilsConfig.getConnection(); public static void main(String[] args) throws SQLException{ beanListHander(); } /* * 结果集第四种处理方法, BeanListHandler * 结果集每一行数据,封装JavaBean对象 * 多个JavaBean对象,存储到List集合 */ public static void beanListHander()throws SQLException{ QueryRunner qr = new QueryRunner(); String sql = "SELECT * FROM sort "; //调用方法query,传递结果集处理实现类BeanListHandler List<Sort> list = qr.query(con, sql, new BeanListHandler<Sort>(Sort.class)); for(Sort s : list){ System.out.println(s); } } }
结果集处理ColumnListHandler
public class QueryRunnerDemo1 { private static Connection con = JDBCUtilsConfig.getConnection(); public static void main(String[] args) throws SQLException{ columnListHandler(); } /* * 结果集第五种处理方法,ColumnListHandler * 结果集,指定列的数据,存储到List集合 * List<Object> 每个列数据类型不同 */ public static void columnListHandler()throws SQLException{ QueryRunner qr = new QueryRunner(); String sql = "SELECT * FROM sort "; //调用方法 query,传递结果集实现类ColumnListHandler //实现类构造方法中,使用字符串的列名 List<Object> list = qr.query(con, sql, new ColumnListHandler<Object>("sname")); for(Object obj : list){ System.out.println(obj); } } }
结果集处理ScalarHandler
public class QueryRunnerDemo1 { private static Connection con = JDBCUtilsConfig.getConnection(); public static void main(String[] args) throws SQLException{ scalarHandler(); } /* * 结果集第六种处理方法,ScalarHandler * 对于查询后,只有1个结果 */ public static void scalarHandler()throws SQLException{ QueryRunner qr = new QueryRunner(); String sql = "SELECT COUNT(*) FROM sort"; //调用方法query,传递结果集处理实现类ScalarHandler long count = qr.query(con, sql, new ScalarHandler<Long>()); System.out.println(count); } }
结果集处理MapHandler
public class QueryRunnerDemo1 { private static Connection con = JDBCUtilsConfig.getConnection(); public static void main(String[] args) throws SQLException{ mapHandler(); } /* * 结果集第七种处理方法,MapHandler * 将结果集第一行数据,封装到Map集合中 * Map<键,值> 键:列名 值:这列的数据 */ public static void mapHandler()throws SQLException{ QueryRunner qr = new QueryRunner(); String sql = "SELECT * FROM sort"; //调用方法query,传递结果集实现类MapHandler //返回值: Map集合,Map接口实现类, 泛型 Map<String,Object> map = qr.query(con, sql, new MapHandler()); //遍历Map集合 for(String key : map.keySet()){ System.out.println(key+".."+map.get(key)); } } }
结果集处理MapListHandler
public class QueryRunnerDemo1 { private static Connection con = JDBCUtilsConfig.getConnection(); public static void main(String[] args) throws SQLException{ mapListHandler(); } /* * 结果集第八种处理方法,MapListHandler * 将结果集每一行存储到Map集合,键:列名,值:数据 * Map集合过多,存储到List集合 */ public static void mapListHandler()throws SQLException{ QueryRunner qr = new QueryRunner(); String sql = "SELECT * FROM sort"; //调用方法query,传递结果集实现类MapListHandler //返回值List集合, 存储的是Map集合 List<Map<String,Object>> list = qr.query(con, sql, new MapListHandler()); //遍历集合list for( Map<String,Object> map : list ){ for(String key : map.keySet()){ System.out.print(key+"..."+map.get(key)); } System.out.println(); } } }
二.连接池
1.连接池介绍
- 实际上就是存放连接的池子(容器)
- 在开发中“获得连接”或“释放资源”是非常消耗系统资源的两个过程
- 为了解决此类性能问题,通常情况我们采用连接池技术,来共享连接Connection。
- 这样我们就不需要每次都创建连接、释放连接了,这些操作都交给了连接池
2.连接池概念规范和DataSource接口
- 连接池概念规范
- 用池来管理Connection,这样可以重复使用Connection
- 不用自己来创建Connection,而是通过池来获取Connection对象
- 使用完Connection后,调用Connection的close()方法也不会真的关闭Connection,而是把Connection“归还”给池
- DataSource接口
- Java为数据库连接池提供了公共的接口:
javax.sql.DataSource
- 各个厂商需要让自己的连接池实现这个接口。这样应用程序可以方便的切换不同厂商的连接池
- 常见的连接池:DBCP、C3P0
- DBCP也是一个开源的连接池,是Apache Common成员之一,在企业开发中也比较常见,tomcat内置的连接池
- Java为数据库连接池提供了公共的接口:
3.编写工具类及使用
连接数据库表的工具类, 采用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; } }
测试类
/* * 演示使用DBUtils工具 完成数据库表的增加操作 */ public class Demo { // 插入功能 @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); } } //更新功能 @Test public void update(){ try { //创建一个QueryRunner对象,用来完成SQL语句的执行 QueryRunner qr = new QueryRunner(JDBCUtils.getDataSource()); //执行SQL语句 String sql = "UPDATE zhangwu SET money = money+1000 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); } } }
4.BasicDataSource类的常见配置
分类 | 属性 | 描述 |
---|---|---|
必须项 | driverClassName | 数据库驱动名称 |
必须项 | url | 数据库的地址 |
必须项 | username | 用户名 |
必须项 | password | 密码 |
基本项 | maxActive | 最大连接数量 |
基本项 | minIdle | 最小空闲连接 |
基本项 | maxIdle | 最大空闲连接 |
基本项 | initialSize | 初始化连接 |