day14_DBUtils学习笔记
一、DBUtils介绍
Apache公司开发的框架。
什么是dbutils？它的作用？
DBUtils是java编程中的数据库操作实用工具，小巧简单实用。
DBUtils封装了对JDBC的操作，简化了JDBC操作。可以少写代码。
commons-dbutils 是 Apache 组织提供的一个开源 JDBC工具类库，
它是对JDBC的简单封装，学习成本极低，并且使用dbutils能极大简化jdbc编码的工作量，同时也不会影响程序的性能。因此dbutils成为很多不喜欢hibernate的公司的首选框架。
- 对于数据表的
读操作，dbutils可以把结果转换成List、Array、Set等java集合，便于程序员操作。 - 对于数据表的
写操作，也变得很简单(只需写sql语句就行)。 - 可以使用数据源、使用JNDI、数据库连接池等技术来优化性能(即重用已经构建好的数据库连接对象)。
二、DBUtils的三个核心对象
- QueryRunner类
- ResultSetHandler接口
- DBUtils类
- QueryRunner类
- QueryRunner中提供对sql语句操作的API。
它主要有三个方法
- query() 用于执行select语句
- update() 用于执行insert、update、delete语句
- batch() 批处理
- QueryRunner中提供对sql语句操作的API。
- ResultSetHandler接口
- 用于定义select操作后，怎样封装结果集。
- DbUtils类
- 它就是一个工具类，定义了关闭资源与事务处理的方法。
- QueryRunner类
三、DBUtils快速入门
- 导入jar包
- 创建QueryRunner对象
- 使用query方法执行select语句
- 使用ResultSetHandler封装结果集
- 使用DbUtils类释放资源
Dbutils快速入门实现步骤：
创建数据库及表，如下:
CREATE DATABASE day14; USE day14; CREATE TABLE users ( id INT PRIMARY KEY AUTO_INCREMENT, username VARCHAR (40) NOT NULL, PASSWORD VARCHAR (40), email VARCHAR (60), birthday DATE ) CHARACTER SET utf8 COLLATE utf8_general_ci; INSERT INTO users(username, PASSWORD, email, birthday) VALUES('tom', '123', 'tom@163.com', '1980-12-04');
导入jar包
注意: c3p0与mysql驱动jar包也要导入。示例代码如下：
1 package com.itheima.util; 2 3 import java.sql.ResultSet; 4 import java.sql.SQLException; 5 import java.util.ArrayList; 6 import java.util.List; 7 8 import org.apache.commons.dbutils.QueryRunner; 9 import org.apache.commons.dbutils.ResultSetHandler; 10 import org.apache.commons.dbutils.handlers.BeanListHandler; 11 import org.junit.Test; 12 13 import com.itheima.entity.User; 14 15 public class TestSelect { 16 17 @Test 18 public void testSelect() throws SQLException { 19 // 创建一个QueryRunner对象 20 QueryRunner qr = new QueryRunner(C3P0Util.getDataSource()); 21 List<User> list = qr.query("select * from users", new ResultSetHandler<List<User>>() { 22 // 当query方法执行select语句后，将结果集以参数的形式传递过来 23 public List<User> handle(ResultSet rs) throws SQLException { 24 List<User> list = new ArrayList<User>(); 25 while (rs.next()) { 26 User u = new User(); 27 u.setId(rs.getInt(1)); 28 u.setUsername(rs.getString(2)); 29 u.setPassword(rs.getString(3)); 30 u.setEmail(rs.getString(4)); 31 u.setBirthday(rs.getDate(5)); 32 list.add(u); 33 } 34 return list; 35 } 36 }); 37 38 for (User user : list) { 39 System.out.println(user); 40 } 41 } 42 43 @Test 44 public void testSelect2() throws SQLException { 45 // 创建一个QueryRunner对象 46 QueryRunner qr = new QueryRunner(C3P0Util.getDataSource()); 47 // 执行查询语句，并返回结果 48 List<User> list = qr.query("select * from users", new BeanListHandler<User>(User.class)); 49 50 for (User user : list) { 51 System.out.println(user); 52 } 53 } 54 }
四、QueryRunner对象
1.1 构造函数
- new QueryRunner(); // 它的事务可以手动控制。
此对象调用的方法（如：query、update、batrch）参数中要有Connection对象。 - new QueryRunner(DataSource ds); // 它的事务是自动控制的。一个sql一个事务。
此对象调用的方法（如：query、update、batrch）参数中无需Connection对象。
1.2 方法
<T> T query(String sql, ResultSetHandler<T> rsh) <T> T query(Connection conn, String sql, ResultSetHandler<T> rsh) <T> T query(Connection conn, String sql, ResultSetHandler<T> rsh, Object... params) int update(String sql, Object... params) int update(Connection conn, String sql, Object... params) int batch(String sql, Object[][] params) int[] batch(Connection conn, String sql, Object[][] params)
示例如下：
进行基本的CRUD操作：练习一下，
示例代码如下：
1 package com.itheima.util; 2 3 import java.sql.Connection; 4 import java.sql.PreparedStatement; 5 import java.sql.SQLException; 6 import java.util.Date; 7 8 import org.apache.commons.dbutils.QueryRunner; 9 import org.junit.Test; 10 11 public class TestCRUD { 12 13 // 没有使用框架之前 14 @Test 15 public void testInsert0() { 16 Connection conn = null; 17 PreparedStatement ps = null; 18 19 try { 20 conn = C3P0Util.getConnection(); 21 ps = conn.prepareStatement("insert into users(name, money) values('ggg', 2000)"); 22 ps.executeUpdate(); 23 } catch (Exception e) { 24 e.printStackTrace(); 25 } finally { 26 C3P0Util.release(conn, ps, null); 27 } 28 } 29 30 // 使用框架之后 31 @Test 32 public void testInsert() throws SQLException { 33 // 创建一个QueryRunner对象 34 QueryRunner qr = new QueryRunner(C3P0Util.getDataSource()); 35 // 执行sql语句 36 qr.update("insert into users(username, password, email, birthday) values(?, ?, ?, ?)", "菜10", "123", "c10@163.com", new Date()); 37 38 } 39 40 @Test 41 public void testUpdate() throws SQLException { 42 // 创建一个QueryRunner对象 43 QueryRunner qr = new QueryRunner(C3P0Util.getDataSource()); 44 qr.update("update users set username=?, password=? where id=?", "周杰杰", "333", 15); 45 } 46 47 @Test 48 public void testDelete() throws SQLException { 49 // 创建一个QueryRunner对象 50 QueryRunner qr = new QueryRunner(C3P0Util.getDataSource()); 51 qr.update("delete from users where id=?", 15); 52 } 53 54 // 批处理，只能执行相同的sql语句 55 @Test 56 public void testBatch() throws SQLException { 57 // 创建一个QueryRunner对象 58 QueryRunner qr = new QueryRunner(C3P0Util.getDataSource()); 59 60 Object[][] params = new Object[10][]; // 高维代表执行多少次sql语句 61 for (int i = 0; i < params.length; i++) { 62 params[i] = new Object[] { "菜10" + i, "123", "c10@163.com", new Date() }; // 给每次执行的sql语句中的?赋值 63 } 64 qr.batch("insert into users(username, password, email, birthday) values(?, ?, ?, ?)", params); 65 } 66 }
五、ResultSetHandler接口
ResultSetHandler接口下的所有结果处理器实现类(
共9个实现类)：
-
ArrayHandler实现类：适合取1条记录(1行数据)。把该条记录的每列值封装到一个Object[]数组中。 -
ArrayListHandler实现类：适合取多条记录(多行数据)。把每条记录的每列值封装到一个Object[]数组中，把数组封装到一个List集合中。 -
ColumnListHandler实现类：适合取某一列的数据。把取到的数据封装到List集合中。 -
KeyedHandler实现类：取多条记录(多行数据)，每一条记录封装到一个Map集合中，再把这个Map集合封装到另外一个Map集合中，key为指定的字段值。 -
MapHandler实现类：适合取1条记录(1行数据)。把当前记录的列名和列值放到一个Map集合中。 -
MapListHandler实现类：适合取多条记录(多行数据)。把每条记录封装到一个Map集合中，再把Map集合封装到List集合中。 -
ScalarHandler实现类：适合取单行单列数据(一个单元格的数据)。 - BeanHandler实现类：适合取单行数据。
- BeanListHandler实现类：适合取单行数据。
示例代码如下：
1 package com.itheima.util; 2 3 import java.sql.SQLException; 4 import java.util.List; 5 import java.util.Map; 6 7 import org.apache.commons.dbutils.QueryRunner; 8 import org.apache.commons.dbutils.handlers.ArrayHandler; 9 import org.apache.commons.dbutils.handlers.ArrayListHandler; 10 import org.apache.commons.dbutils.handlers.BeanHandler; 11 import org.apache.commons.dbutils.handlers.BeanListHandler; 12 import org.apache.commons.dbutils.handlers.ColumnListHandler; 13 import org.apache.commons.dbutils.handlers.KeyedHandler; 14 import org.apache.commons.dbutils.handlers.MapHandler; 15 import org.apache.commons.dbutils.handlers.MapListHandler; 16 import org.apache.commons.dbutils.handlers.ScalarHandler; 17 import org.junit.Test; 18 19 import com.itheima.entity.User; 20 21 public class TestResultSetHandler { 22 @Test // ArrayHandler实现类：适合取1条记录(1行数据)。把该条记录的每列值封装到一个Object[]数组中。 23 public void tese1() throws SQLException { 24 QueryRunner qr = new QueryRunner(C3P0Util.getDataSource()); 25 Object[] arr = qr.query("select * from users", new ArrayHandler()); 26 27 for (Object o : arr) { 28 System.out.println(o); 29 } 30 } 31 32 @Test // ArrayListHandler实现类：适合取多条记录(多行数据)。把每条记录的每列值封装到一个Object[]数组中，把数组封装到一个List集合中。 33 public void tese2() throws SQLException { 34 QueryRunner qr = new QueryRunner(C3P0Util.getDataSource()); 35 List<Object[]> query = qr.query("select * from users", new ArrayListHandler()); 36 37 for (Object[] os : query) { 38 for (Object o : os) { 39 System.out.println(o); 40 } 41 System.out.println("--------------"); 42 } 43 } 44 45 @Test // ColumnListHandler实现类：适合取某一列的数据。把取到的数据封装到List集合中。 46 public void tese3() throws SQLException { 47 QueryRunner qr = new QueryRunner(C3P0Util.getDataSource()); 48 List<Object> list = qr.query("select * from users", new ColumnListHandler(3)); 49 50 for (Object o : list) { 51 System.out.println(o); 52 } 53 } 54 55 @Test // KeyedHandler实现类：适合取多条记录(多行数据)。每一条记录封装到一个Map集合中，再把这个Map集合封装到另外一个Map集合中，key为指定的字段值。 56 public void tese4() throws SQLException { 57 QueryRunner qr = new QueryRunner(C3P0Util.getDataSource()); 58 // 大Map集合的key是表中的第一列数据，小Map集合中的key是表的列名，所以大Map集合的key是Object类型，小Map集合的key是String类型。 59 Map<Object, Map<String, Object>> map = qr.query("select * from users", new KeyedHandler(1)); 60 61 for (Map.Entry<Object, Map<String, Object>> m : map.entrySet()) { 62 System.out.println(m.getKey()); // 默认大Map集合中key值就是id列的值 63 for (Map.Entry<String, Object> mm : m.getValue().entrySet()) { 64 System.out.println(mm.getKey() + "\t" + mm.getValue()); // 取出小Map集合中的列名和列值 65 } 66 System.out.println("--------------"); 67 } 68 } 69 70 @Test // MapHandler实现类：适合取1条记录(1行数据)。把当前记录的列名和列值放到一个Map集合中。 71 public void tese5() throws SQLException { 72 QueryRunner qr = new QueryRunner(C3P0Util.getDataSource()); 73 Map<String, Object> map = qr.query("select * from users where id=?", new MapHandler(), 10); 74 75 for (Map.Entry<String, Object> m : map.entrySet()) { 76 System.out.println(m.getKey() + "\t" + m.getValue()); 77 } 78 } 79 80 @Test // MapListHandler实现类：适合取多条记录(多行数据)。把每条记录封装到一个Map集合中，再把Map封装到List集合中。 81 public void tese6() throws SQLException { 82 QueryRunner qr = new QueryRunner(C3P0Util.getDataSource()); 83 List<Map<String, Object>> list = qr.query("select * from users", new MapListHandler()); 84 85 for (Map<String, Object> map : list) { 86 for (Map.Entry<String, Object> m : map.entrySet()) { 87 System.out.println(m.getKey() + "\t" + m.getValue()); 88 } 89 System.out.println("--------------"); 90 } 91 } 92 93 @Test // ScalarHandler实现类：适合取单行单列数据(一个单元格的数据)。 94 public void tese7() throws SQLException { 95 QueryRunner qr = new QueryRunner(C3P0Util.getDataSource()); 96 Object o = qr.query("select count(*) from users", new ScalarHandler(1)); // 统计有多少行数据 97 System.out.println(o.getClass().getName()); // 注意：行数是long类型，因为表格已经突破了千万行了。 98 } 99 100 @Test // BeanHandler实现类：适合取单行数据。 101 public void tese8() throws SQLException { 102 QueryRunner qr = new QueryRunner(C3P0Util.getDataSource()); 103 User user = qr.query("select * from users where id=?", new BeanHandler<User>(User.class), 1); 104 System.out.println(user); 105 } 106 107 @Test // BeanListHandler实现类：适合取单行数据。 108 public void tese9() throws SQLException { 109 QueryRunner qr = new QueryRunner(C3P0Util.getDataSource()); 110 List<User> list = qr.query("select * from users where id=?", new BeanListHandler<User>(User.class), 1); 111 System.out.println(list); 112 } 113 }
六、DBUtils控制事务的开发
1.版本一：转账的具体操作在数据访问层（dao）中实现。不好，因为转账操作属于业务层（service）的东西。
2.版本二：转账的具体操作在业务层（service）中实现。可以，但是，业务层里面出现了数据访问层（dao）的东西。
Connection conn = C3P0Util.getConnection();
3.版本三：使用线程局部变量ThreadLocal
七、ThreadLocal线程局部变量
模拟ThreadLocal类的设计，让大家明白它的作用。
public class ThreadLocal { private Map<Runnable, Object> container = new HashMap<Runnable, Object>(); public void set(Object value) { container.put(Thread.currentThread(), value); // 用当前线程作为key } public Object get() { return container.get(Thread.currentThread()); } public void remove() { container.remove(Thread.currentThread()); } }
总结：调用该类的get方法，永远返回当前线程放入的数据，保证线程安全。所以ThreadLocal叫做线程局部变量。
八、完成案例
- 项目开发的准备工作
- 创建项目
添加jar包 - 添加dao、service、servlet分层代码
创建数据库及表
create database day14; use day14; create table books ( id varchar(200) primary key, name varchar(100) not null, price double, pnum int, category varchar(50), description varchar(200) ) SELECT * FROM books; INSERT INTO books VALUES('1001', 'java编程思想', 98, 100, '计算机', '好书'); INSERT INTO books VALUES('1002', '解忧杂货铺', 10, 20, '文学', '好书'); INSERT INTO books VALUES('1003', '创京东', 20, 30, '科技', '好书');
显示列表数据 的思路图：
添加/修改列表数据 的思路图：
版权声明：本文为chenmingjun原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。