24、DbUtils框架的应用（JavaEE笔记）

以下所有示例都是在工程day17中。

一、模拟转账

首先我们建立数据库：

CREATE TABLE account(
    id INT PRIMARY KEY AUTO_INCREMENT,
    NAME VARCHAR(40),
    money FLOAT
)CHARACTER SET utf8 COLLATE utf8_general_ci;

INSERT INTO account(NAME,money) VALUES('aaa',1000);
INSERT INTO account(NAME,money) VALUES('bbb',1000);
INSERT INTO account(NAME,money) VALUES('ccc',1000);

注意：这里使用的是day17数据库。

实体类
Account.java

private int id;
private String name;
private float money;

在实际开发中使用JDBC的时候需要用到一个类ThreadLocal，这里我们使用此类改进我们的工具类：
JdbcUtils.java

package cn.itcast.utils;
import java.sql.Connection;
import java.sql.SQLException;
import javax.sql.DataSource;
import com.mchange.v2.c3p0.ComboPooledDataSource;

public class JdbcUtils {
    private static ComboPooledDataSource ds = null;
    private static ThreadLocal<Connection> threadLocal = new ThreadLocal();
    
    static{
        ds = new ComboPooledDataSource();
    }
    
    public static Connection getConnection() throws SQLException{
        Connection connection = threadLocal.get();
        if(connection == null){
            connection = getDataSource().getConnection();//如果没有绑定链接，就从数据源中获取一个
            threadLocal.set(connection);
        }
        return connection;
    }
    public static DataSource getDataSource(){
        return ds;
    }
    
    public static void startTransaction(){
        try{
            Connection connection = threadLocal.get();
            if(connection == null){//从当前线程上获得一个链接，如果没有，则从数据库取得
                connection = getConnection();
                threadLocal.set(connection);//把connection绑定到当前线程上
            }
            connection.setAutoCommit(false);
        }catch(Exception e){
            throw new RuntimeException(e);
        }
        
    }
    public static void rollback(){
        try{
            Connection connection = threadLocal.get();
            if(connection != null){
                connection.rollback();
            }
        }catch(Exception e){
            throw new RuntimeException(e);
        }
    }
    
    public static void commit(){
        try{
            Connection connection = threadLocal.get();
            if(connection != null){
                connection.commit();
            }
        }catch(Exception e){
            throw new RuntimeException(e);
        }
    }
    
    public static void release(){
        try{
            Connection connection = threadLocal.get();
            if(connection != null){
                connection.close();
                threadLocal.remove();//解除当前线程上绑定的connection,一定要有
            }
        }catch(Exception e){
            throw new RuntimeException(e);
        }
    }
}

说明：对于ThreadLocal，我们可以这样理解，这个类就是一个容器。向这个容器存储的对象（存储使用set方法），在当前线程范围内都可以取出来。下面我们通过一个示例进行说明：
Test.java

package junit.test;
public class Test {

    public static void main(String[] args) {
        
        Thread currentThread = Thread.currentThread();
        System.out.println(currentThread);
        
        ThreadLocal t = new ThreadLocal();
        t.set("aaa");  //把某个对象绑定到当前线程上  map(currentThread,"aaa")
        
        String value = (String) t.get();
        System.out.println(value);
    }
}

说明：我们将这个类用来改进工具类，将当前的Connection绑定到当前线程上，于是就可以保证在进行数据库操作的时候确保所有操作都是使用的同一个Connection。注意各个方法对于Connection的操作。

dao层：AccountDaoImpl.java

package cn.itcast.dao.impl;
import java.sql.Connection;
import java.sql.SQLException;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanHandler;
import cn.itcast.dao.AccountDao;
import cn.itcast.domain.Account;
import cn.itcast.utils.JdbcUtils;

public class AccountDaoImpl implements AccountDao {
    
    //将操作需要的链接传递进来，自己进行管理
    private Connection conn = null;
    
    public AccountDaoImpl(Connection conn){
        this.conn = conn;
    }
    
    public AccountDaoImpl(){
        
    }
    
    public void update(Account account) throws SQLException{
        
        QueryRunner qr = new QueryRunner();
        String sql = "update account set name=?,money=? where id=?";
        Object params[] = {account.getName(),account.getMoney(),account.getId()};
        qr.update(JdbcUtils.getConnection(),sql, params);
        
    }
    
    public Account find(int id) throws SQLException{
        QueryRunner qr = new QueryRunner();
        String sql = "select * from account where id=?";
        return (Account) qr.query(JdbcUtils.getConnection(),sql, id, new BeanHandler(Account.class));
    }
}

说明：在使用Connection的时候我们不能都交给数据库链接池管理，因为一个操作（如update）完了连接池就会帮我们将Connection释放掉，于是这里使用QueryRunner类的时候不要给其传递链接，这样当我们使用update方法传递一个链接的时候在操作结束后就不会将链接释放，注意这个方法传递链接和不传链接时的区别。

业务类：AccountService.java

package cn.itcast.service;
import java.sql.Connection;
import java.sql.SQLException;
import cn.itcast.dao.AccountDao;
import cn.itcast.dao.impl.AccountDaoImpl;
import cn.itcast.domain.Account;
import cn.itcast.utils.JdbcUtils;

public class AccountService {
    
    //其实下面这种方式在开发中也不会使用(被注释掉的),我们一般使用ThreadLocal类，这是一个容器，
    //在当前线程范围内都可以取得出来
    public void transfer(int sourceid, int targetid, float money) throws SQLException{
        
        Connection connection = null;
        try{
            JdbcUtils.startTransaction();//获得一个链接，开启一个事务，则下面的代码都是在当前线程上进行的
            
            AccountDao dao = new AccountDaoImpl(connection);
            Account source = dao.find(sourceid);
            Account target = dao.find(targetid);
            
            source.setMoney(source.getMoney()-money);
            target.setMoney(target.getMoney()+money);
            
            dao.update(source);//这里两个操作共享一个链接，我们在dao层中的update方法中就不能给其连接，而应该自己管理
            dao.update(target);
            
            JdbcUtils.commit();
            
        }catch(Exception e){
            e.printStackTrace();
            JdbcUtils.rollback();
        }finally{
            JdbcUtils.release();
        }   
    }
}

说明：当然这里我们只是让对数据库的操作在同一个事务中完成，但是有时候我们可能还需要多个service在同一个事务中，此时我们就需要使用拦截器，当web请求过来的时候直接拦截，然后获取一个连接给service，这样可以使得所有service在一个事务中，我们将拦截器使用ThreadLocal管理。当然在后面我们一般使用spring进行管理事务。

测试：AccountServiceTest.java

package junit.test;
import java.sql.SQLException;
import org.junit.Test;
import cn.itcast.service.AccountService;
public class AccountServiceTest {

    @Test
    public void testTransfer() throws SQLException{
        AccountService service = new AccountService();
        service.transfer(1, 2, 100);
    }
}

二、使用JDBC操作多个表（工程`day17`）

2.1一对多关系（部门和员工）

相关实体：
Department.java

private String id;
private String name;
private Set<Employee> employees = new HashSet();

Employee.java

private String id;
private String name;
private double salary;
private Department department;

建立数据库表：

    create table department
    (
        id varchar(40) primary key,
        name varchar(40)
    );
    
    create table employee
    (
        id varchar(40) primary key,
        name varchar(40),
        salary double,
        department_id varchar(40),
        constraint department_id_FK foreign key(department_id) references department(id)
    );

dao层：DepartmentDaoImpl.java

package cn.itcast.dao.impl;
import java.sql.SQLException;
import java.util.List;
import java.util.Set;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanHandler;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import cn.itcast.dao.DepartmentDao;
import cn.itcast.domain.Department;
import cn.itcast.domain.Employee;
import cn.itcast.utils.JdbcUtils;

public class DepartmentDaoImpl implements DepartmentDao {
    //session.add(department);
    public void add(Department department) throws SQLException{
        
        QueryRunner qr = new QueryRunner(JdbcUtils.getDataSource());
        
        //1.取出department对象的基本信息存在 department表
        String sql = "insert into department(id,name) values(?,?)";
        Object params[] = {department.getId(),department.getName()};
        qr.update(sql, params);
        
        //2. 取出department对象中所有的员工信息，存在员工表
        sql = "insert into employee(id,name,salary,department_id) values(?,?,?,?)";
        Set<Employee> set = department.getEmployees();
        Object params2[][] = new Object[set.size()][];
        
        int index = 0;
        for(Employee e : set){
            params2[index++] = new Object[]{e.getId(),e.getName(),e.getSalary(),department.getId()};
        }
        qr.batch(sql, params2);//使用批处理
    }
    
    public Department find(String id) throws SQLException{
        QueryRunner qr = new QueryRunner(JdbcUtils.getDataSource());
        
        //1.查出部门表的信息，存在department对象中
        String sql = "select * from department where id=?";
        Department d = (Department) qr.query(sql, id, new BeanHandler(Department.class));
        
        /*注意：我们在查询的时候对于多的一方，我们能够不进行查找则尽量
        不要显示，因为多的一方可能太多导致内存崩溃
        在我们这种情况下显示部门是不需要显示员工的，但是在订单中我们
        需要显示其下的完整信息，此时则需要显示,于是一定要显示的话
        则一定要进行分页，同时能不显示则不显示*/
        
        //2.查出部门下的所有员工信息，存在department对象维护的员工对象中
        sql = "select id,name,salary from employee where department_id=?";
        List list = (List) qr.query(sql, id, new BeanListHandler(Employee.class));
        
        d.getEmployees().addAll(list);//这里可以一次性添加到set集合中
        
        return d;
    }
    
}

测试：DepartmentService.java

package cn.itcast.test;
import java.sql.SQLException;
import java.util.UUID;
import cn.itcast.dao.DepartmentDao;
import cn.itcast.dao.impl.DepartmentDaoImpl;
import cn.itcast.domain.Department;
import cn.itcast.domain.Employee;
public class DepartmentService {
    
    DepartmentDao dao = new DepartmentDaoImpl();
    
    public void add() throws SQLException{
        Department d = new Department();
        d.setId(UUID.randomUUID().toString());
        d.setName("开发部");
        
        Employee e1 = new Employee();
        e1.setId(UUID.randomUUID().toString());
        e1.setName("aaa");
        e1.setSalary(300);
        
        Employee e2 = new Employee();
        e2.setId(UUID.randomUUID().toString());
        e2.setName("bbb");
        e2.setSalary(400);
        
        d.getEmployees().add(e1);
        d.getEmployees().add(e2);
        
        dao.add(d);
    }
}

2.2多对多（老师和学生）

相关实体类：
Teacher.java

private String id;
private String name;
private double salary;
private Set<Student> students = new HashSet<Student>();

Student.java

private String id;
private String name;
private Set<Teacher> teachers = new HashSet();

建立数据库表：

    create table teacher
    (
        id varchar(40) primary key,
        name varchar(40),
        salary double
    );
    
    create table student
    (
        id varchar(40) primary key,
        name varchar(40)
    );
    
    create table teacher_student
    (
        teacher_id varchar(40),
        student_id varchar(40),
        primary key(teacher_id,student_id),
        constraint teacher_id_FK foreign key(teacher_id) references teacher(id),
        constraint student_id_FK foreign key(student_id) references student(id)
    );

说明：对于多对多这种关系，我们一般单独建立一张表来保存实体类之间的关系。

dao层：TeacherDaoImpl.java

package cn.itcast.dao.impl;
import java.sql.SQLException;
import java.util.List;
import java.util.Set;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanHandler;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import cn.itcast.dao.TeacherDao;
import cn.itcast.domain.Student;
import cn.itcast.domain.Teacher;
import cn.itcast.utils.JdbcUtils;

public class TeacherDaoImpl implements TeacherDao {

    public void add(Teacher t) throws SQLException{
        
        QueryRunner qr = new QueryRunner(JdbcUtils.getDataSource());
        
        //1.取出老师的基本信息，存在老师表
        String sql = "insert into teacher(id,name,salary) values(?,?,?)";
        Object params[] = {t.getId(),t.getName(),t.getSalary()};
        qr.update(sql, params);
        
        ///2.取出老师下面所有的学生，存在学生表
        Set<Student> set = t.getStudents();
        for(Student s : set){
            sql = "insert into student(id,name) values(?,?)";
            params = new Object[]{s.getId(),s.getName()};
            qr.update(sql, params);
            
            //3.在中间表中说明老师和学生的关系
            sql = "insert into teacher_student(teacher_id,student_id) values(?,?)";
            params = new Object[]{t.getId(),s.getId()};
            qr.update(sql, params);
        }
    }
    
    public Teacher find(String id) throws SQLException{
    
        QueryRunner qr = new QueryRunner(JdbcUtils.getDataSource());
        
        //1.从老师表中找出老师的基本信息
        String sql = "select * from teacher where id=?";
        Teacher t = (Teacher) qr.query(sql, id, new BeanHandler(Teacher.class));
        
        //2.从中间表和学生表中得到老师所有的学生（取多的一方的数据时，一定要长心眼，能不取尽量不要取，即使要取，数据量只要一大，一定要分页）
        sql = "select s.id,s.name from teacher_student ts,student s where teacher_id=? and ts.student_id=s.id";
        List list = (List) qr.query(sql, id, new BeanListHandler(Student.class));
        
        t.getStudents().addAll(list);
        
        return t;
    }
}

测试：BusinessService.java

@Test
    public void addTeacher() throws SQLException{
        
        Teacher t = new Teacher();
        t.setId("1");
        t.setName("老张");
        t.setSalary(1000000);
        
        Student s1 = new Student();
        s1.setId("1");
        s1.setName("aaa");
        
        Student s2 = new Student();
        s2.setId("2");
        s2.setName("bbb");
        
        t.getStudents().add(s1);
        t.getStudents().add(s2);
        
        tdao.add(t);
    }
    
    @Test
    public void findTeacher() throws SQLException{
        Teacher t = tdao.find("1");
        System.out.println(t);
    }

2.3一对一（人和身份证）

相关实体类：
Person.java

private String id;
private String name;
private Idcard idcard;

IdCard.java

private String id;
private String address;
private Person person;

建立数据库表：

    create table person
    (
        id varchar(40) primary key,
        name varchar(40)
    );
    
    create table idcard
    (
        id varchar(40) primary key,
        address varchar(100),
        constraint id_FK foreign key(id) references person(id)
    );

说明：对于这种一对一关系，我们这里选择在身份证这边维护关系，当然也可以在人这边维护关系。

dao层：PersonDaoImpl.java

package cn.itcast.dao.impl;
import java.sql.SQLException;
import org.apache.commons.dbutils.QueryRunner;
import cn.itcast.dao.PersonDao;
import cn.itcast.domain.Person;
import cn.itcast.utils.JdbcUtils;

public class PersonDaoImpl implements PersonDao {

    public void add(Person p) throws SQLException{
        
        QueryRunner qr = new QueryRunner(JdbcUtils.getDataSource());
        
        //取出person的信息存在person表
        String sql = "insert into person(id,name) values(?,?)";
        Object params[] = {p.getId(),p.getName()};
        qr.update(sql, params);
        
        
        //取出身份证的信息存在身份证表
        sql = "insert into idcard(id,address) values(?,?)";
        params = new Object[]{p.getId(),p.getIdcard().getAddress()};
        qr.update(sql, params);
    }
}

测试：

    @Test
    public void addPerson() throws SQLException{
        
        Person p = new Person();
        p.setId("1");
        p.setName("aaa");
            
        Idcard idcard = new Idcard();
        idcard.setId("1");
        idcard.setAddress("广东");
        
        p.setIdcard(idcard);
        
        pdao.add(p);
    }

最后：以上的例子只是说明了基本的原理，不能作为实际开发的例子，都比较简单，这里就不多说了。

最后编辑于：2017.12.03 06:07:50

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 203,362评论 5赞 477
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 85,330评论 2赞 381
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 150,247评论 0赞 337
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 54,560评论 1赞 273
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 63,580评论 5赞 365
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 48,569评论 1赞 281
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 37,929评论 3赞 395
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 36,587评论 0赞 258
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 40,840评论 1赞 297
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 35,596评论 2赞 321
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 37,678评论 1赞 329
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 33,366评论 4赞 318
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 38,945评论 3赞 307
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 29,929评论 0赞 19
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 31,165评论 1赞 259
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 43,271评论 2赞 349
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 42,403评论 2赞 342

24、DbUtils框架的应用（JavaEE笔记）

一、模拟转账

二、使用JDBC操作多个表（工程day17）

2.1一对多关系（部门和员工）

2.2多对多（老师和学生）

2.3一对一（人和身份证）

推荐阅读更多精彩内容

二、使用JDBC操作多个表（工程`day17`）