Apache公司开发的框架。
什么是dbutils?它的作用?
DBUtils是java编程中的数据库操作实用工具,小巧简单实用。 DBUtils封装了对JDBC的操作,简化了JDBC操作。可以少写代码。
commons-dbutils 是 Apache 组织提供的一个开源 JDBC工具类库,
它是对JDBC的简单封装
,学习成本极低,并且使用dbutils能极大简化jdbc编码的工作量,同时也不会影响程序的性能。因此dbutils
成为很多不喜欢hibernate
的公司的首选框架。
读操作
,dbutils可以把结果转换成List、Array、Set等java集合,便于程序员操作。写操作
,也变得很简单(只需写sql语句就行)。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 }
1.1 构造函数
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接口下的所有结果处理器实现类(
共9个实现类
):
ArrayHandler实现类
:适合取1条记录(1行数据)。把该条记录的每列值封装到一个Object[]数组中。ArrayListHandler实现类
:适合取多条记录(多行数据)。把每条记录的每列值封装到一个Object[]数组中,把数组封装到一个List集合中。ColumnListHandler实现类
:适合取某一列的数据。把取到的数据封装到List集合中。KeyedHandler实现类
:取多条记录(多行数据),每一条记录封装到一个Map集合中,再把这个Map集合封装到另外一个Map集合中,key为指定的字段值。MapHandler实现类
:适合取1条记录(1行数据)。把当前记录的列名和列值放到一个Map集合中。MapListHandler实现类
:适合取多条记录(多行数据)。把每条记录封装到一个Map集合中,再把Map集合封装到List集合中。ScalarHandler实现类
:适合取单行单列数据(一个单元格的数据)。示例代码如下
: 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 }
1.版本一:转账的具体操作在数据访问层(dao)中实现。不好,因为转账操作属于业务层(service)的东西。
2.
版本二:转账的具体操作在业务层(service)中实现。可以,但是,业务层里面出现了数据访问层(dao)的东西。Connection conn = C3P0Util.getConnection();
3.版本三:使用线程局部变量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叫做线程局部变量。
八、完成案例
创建数据库及表
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, '科技', '好书');
显示列表数据
的思路图:
添加/修改列表数据
的思路图:
实现 删除 功能(并添加删除提示):
实现 全选/全不选 功能:
实现 批量删除 功能(方式1:使用js的方式):
实现 批量删除 功能(方式2:通过提交表单的方式):
实现 多条件查询 功能:
实现 分页显示 的功能: 分页显示思路及思路图: