首页 > > 程序设计 > Java技术 >

day14_DBUtils学习笔记

2018-06-18 00:58:24来源：未知 阅读 ()

新老客户大回馈,云服务器低至5折

一、DBUtils介绍

Apache公司开发的框架。 
什么是dbutils？它的作用？ 
? DBUtils是java编程中的数据库操作实用工具，小巧简单实用。 
? DBUtils封装了对JDBC的操作，简化了JDBC操作。可以少写代码。

commons-dbutils 是 Apache 组织提供的一个开源 JDBC工具类库，它是对JDBC的简单封装 ，学习成本极低，并且使用dbutils能极大简化jdbc编码的工作量，同时也不会影响程序的性能。因此 dbutils 成为很多不喜欢 hibernate 的公司的首选框架。

  1. 对于数据表的 读操作 ，dbutils可以把结果转换成List、Array、Set等java集合，便于程序员操作。
  2. 对于数据表的 写操作 ，也变得很简单(只需写sql语句就行)。
  3. 可以使用数据源、使用JNDI、数据库连接池等技术来优化性能(即重用已经构建好的数据库连接对象)。

二、DBUtils的三个核心对象

  • QueryRunner类
  • ResultSetHandler接口
  • DBUtils类 
    • QueryRunner类 
      • QueryRunner中提供对sql语句操作的API。 
        它主要有三个方法 
        • query() 用于执行select语句
        • update() 用于执行insert、update、delete语句
        • batch() 批处理
    • ResultSetHandler接口 
      • 用于定义select操作后，怎样封装结果集。
    • DbUtils类 
      • 它就是一个工具类，定义了关闭资源与事务处理的方法。

三、DBUtils快速入门

  1. 导入jar包
  2. 创建QueryRunner对象
  3. 使用query方法执行select语句
  4. 使用ResultSetHandler封装结果集
  5. 使用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个实现类 )：

  1. ArrayHandler实现类：适合取1条记录(1行数据)。把该条记录的每列值封装到一个Object[]数组中。
  2. ArrayListHandler实现类：适合取多条记录(多行数据)。把每条记录的每列值封装到一个Object[]数组中，把数组封装到一个List集合中。
  3. ColumnListHandler实现类：适合取某一列的数据。把取到的数据封装到List集合中。
  4. KeyedHandler实现类：取多条记录(多行数据)，每一条记录封装到一个Map集合中，再把这个Map集合封装到另外一个Map集合中，key为指定的字段值。
  5. MapHandler实现类：适合取1条记录(1行数据)。把当前记录的列名和列值放到一个Map集合中。
  6. MapListHandler实现类：适合取多条记录(多行数据)。把每条记录封装到一个Map集合中，再把Map集合封装到List集合中。
  7. ScalarHandler实现类：适合取单行单列数据(一个单元格的数据)。
  8. BeanHandler实现类：适合取单行数据。
  9. 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叫做线程局部变量。

八、完成案例

  1. 项目开发的准备工作
  2. 创建项目
    　　添加jar包
  3. 添加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, '科技', '好书');

显示列表数据 的思路图： 

　　

添加/修改列表数据 的思路图： 

　　

实现 删除 功能(并添加删除提示)：
　　

　　

实现 全选/全不选 功能：
　　

　　

实现 批量删除 功能(方式1：使用js的方式)：
　　

　　

实现 批量删除 功能(方式2：通过提交表单的方式)：
　　

　　

实现 多条件查询 功能：
　　

　　

　　

实现 分页显示 的功能：
　　分页显示思路及思路图：
　　

　　

　　

标签：

版权申明：本站文章部分自网络，如有侵权，请联系：west999com@outlook.com
特别注意：本站所有转载文章言论不代表本站观点，本站所提供的摄影照片，插画，设计作品，如需使用，请与原作者联系，版权归原作者所有

上一篇：Java描述数据结构之链表的增删改查

下一篇：AOP

相关文章

IDC资讯： 主机资讯 注册资讯 托管资讯 vps资讯 网站建设

网站运营： 建站经验 策划盈利 搜索优化 网站推广 免费资源

网站联盟： 联盟新闻 联盟介绍 联盟点评 网赚技巧

行业资讯： 搜索引擎 网络游戏 电子商务 广告传媒

网络编程： Asp.Net编程 Asp编程 Php编程 Xml编程 Access Mssql Mysql 其它

服务器技术： Web服务器 Ftp服务器 Mail服务器 Dns服务器 安全防护

软件技巧： 其它软件 Word Excel Powerpoint Ghost Vista QQ空间 QQ FlashGet 迅雷

网页制作： FrontPages Dreamweaver Javascript css photoshop fireworks Flash

程序设计： Java技术 C/C++ VB delphi

网络知识： 网络协议 网络安全 网络管理 组网方案 Cisco技术

操作系统： Win2000 WinXP Win2003 Mac OS Linux FreeBSD

热门词条
最新资讯
热门关注
热门标签