04_ThreadLocal整合事务操作

文章导读：

本文主要讲解了如何在没有框架情况下如何解决Dao的事务问题, 重点理解Connection存放到WeakReference中为什么垃圾回收的时候Connection不回收

视频与源码下载：http://edu.51cto.com/lecturer/index/user_id-9166337.html  (代码在视频的附件中)

先准备下测试的环境：db.sql、model、dao、Service

db.sql 代码如下(只有一张表)

/*删除商城数据库,如果存在*/
drop database if exists demo;
create database demo default character set utf8;
use demo;
drop table if exists book;

create table book
(
   id                  int not null auto_increment,
   name                varchar(20),
   price               decimal(8,2),
   remark              longtext,
   storage             int,
   primary key (id)
);

/* 图书测试用例 */
insert into book (name,price,remark,storage) values ('Java编程思想',99.99,'Java学习必读经典,殿堂级著作！赢得了全球程序员的广泛赞誉',200);
insert into book (name,price,remark,storage) values ('HTML5与CSS3权威指南',49.99,'一本前端应用开发的书籍',300);
insert into book (name,price,remark,storage) values ('Android从入门到精通',79.99,'移动互联网书籍',100);

select * from book;

执行SQL语句结果如下：

根据表生成Java的model(模型)

public class Book {

    private Integer id;
    private String name;
    private Double price;
    private String remark;
    public Integer storage;

          // ..... 省略了 set get方法
}

编写一个BookDaoImpl完成数据的插入功能

public class BookDaoImpl {

    public int save(Book book) {
        String sql = "insert into book (name,price,remark,storage) values (?,?,?,?)";
        Connection conn = null;
        PreparedStatement pre = null;
        try {
            conn = JdbcUtils.getConnection();
            System.out.println("BookDaoImpl conn:" + conn);
            pre = conn.prepareStatement(sql);
            pre.setString(1, book.getName());
            pre.setDouble(2, book.getPrice());
            pre.setString(3, book.getRemark());
            pre.setInt(4, book.getStorage());
            return pre.executeUpdate();
        } catch (SQLException e) {
            throw new RuntimeException(e);
        } finally {
            try {
                pre.close();
            } catch (SQLException e) {
                throw new RuntimeException(e);
            } 
        }
    }
}

编写一个AuthorDaoImpl完成作者插入功能(主要是为了测试事务, 如果两个方法有一个方法执行失败,则事务要回滚)

public class AuthorDaoImpl {

    public int save() {
        Connection conn = JdbcUtils.getConnection();
        System.out.println("AuthorDaoImpl conn:" + conn);
        System.out.println("----另一张表插入作者信息-----");
//        Integer.parseInt("xxxx");
        return 0;
    }
}

最后编写一个Service把需要的事务操作整合起来, Conn的创建与销毁都在Service中.

public class BookServiceImpl {
    
    private BookDaoImpl bookDaoImpl = new BookDaoImpl();
    private AuthorDaoImpl authorDaoImpl = new AuthorDaoImpl();
    
    public static void main(String[] args) {
        BookServiceImpl serviceImpl=new BookServiceImpl();
        serviceImpl.save();
        System.out.println("---------------------over------------------------");
    }
    
    // 业务逻辑完成之后调用数据访问层,来实现数据入库
    public void save(){
        Connection conn = null;
        try{
            conn = JdbcUtils.getConnection();
            // 手动提交事务
            conn.setAutoCommit(false);
            // 事务应该在业务逻辑层创建,包含所有事务的dao
            bookDaoImpl.save(new Book(null, "测试书籍", 45.67, "我是备注", 100));
            System.gc(); // 手动调用垃圾回收并不会导致弱引用Connection关闭,因为当前处于Open状态
            authorDaoImpl.save();
            conn.commit();
        }catch (Exception e) {
            try {
                System.out.println("conn.rollback()");
                conn.rollback();
            } catch (SQLException e1) {
                throw new RuntimeException(e1);
            }
            throw new RuntimeException(e);
        }finally{
            JdbcUtils.closeConnection(); // 必须要关闭,否则不会被销毁.因为Connecion默认是open状态
        }
    }
}

测试结果如下(通过测试我们会发现,两个Dao中使用的是同一个事务,如果出错事务将会回滚,在测试的时候会发现如果调用的gc也不会导致弱引用的Connection回收, 为什么呢,因为Connection是Open状态,只要没有关闭是不会被回收的,理解相信的原理可以参考当前文章的视频教程)