使用过滤器和 ThreadLocal 实现事务操作

Connection对象关于事务的操作ThreadLocal对象实现事务操作

对于一系列的数据库操作，要保证操作的事务性。即这些操作要么全都完成，要么全都不完成。

Connection对象关于事务的操作

数据库连接对象Connection提供了实现事务操作的方法：

关闭自动更新，开启事务

connection.setAutoCommit(false);

数据库操作

/* 数据库操作... */

提交更新

connection.commit();

回滚事务

connection.rollback();

ThreadLocal对象

ThreadLocal对象可以为每个线程提供一个局部变量，这个变量与对应的某个线程关联且只被该线程访问。多线程环境中，当每个线程都要有一个对应的实例（不是共享的实例）的时候，可考虑通过ThreadLocal对象实现。

Servlet容器为每一个请求都创建了一个线程，这些线程都将涉及到数据库操作，所有可以将每一个请求看做一个事务操作。而在每一个请求线程的过程中，进行数据库操作时使用的数据库连接对象需要是同一个（既上文描述的第二个阶段），从而实现数据库操作的事务性。

ThreadLocal对象提供的方法：

构造ThreadLocal对象

ThreadLocal<Object> threadLocal = new ThreadLocal<>();

添加值

threadLocal.set(object);

获取值

threadLocal.get();

删除值

threadLocal.remove();

ThreadLocal对象原理：每个线程都包含一个ThreadLocalMap对象，ThreadLocalMap对象包含一个Entry(ThreadLocal<?> k, Object v)内部类并维护一个Entry内部类的数组table（实际上是一个散列表）。使用ThreadLocal对象保存数据时，首先获取当前线程并获取当前线程的ThreadLocalMap对象，并将该ThreadLocal对象的引用作为键k，保存的数据作为值封装为Entry对象保存到table数组中。取数据时，首先获取当前线程并获取当前线程的ThreadLocalMap对象，并将该ThreadLocal对象的引用作为键k取出table中的值。

实现事务操作

思路：创建一个过滤器拦截需要进行事务操作的请求，在过滤器中获取数据库连接并将创建的数据库连接绑定到ThreadLocal对象上，然后转发过滤器链。在之后过滤器链的运行过程中，所有的数据库连接通过ThreadLocal对象获取（以保证是同一Connection对象），注意在此过程中不要释放掉数据库连接！沿过滤器链运行完后，回到事务操作过滤器，此时提交数据库操作的更新。在整个过程中，如果发生错误则回滚数据库更新操作。

/** * Connection上下文，采用单例模式，通过 ThreadLocal 维护数据库连接对象 */ public class ConnectionContext { private static ConnectionContext instance = new ConnectionContext(); // 创建 Connection 的新 ThreadLocal 对象 private ThreadLocal<Connection> threadLocal = new ThreadLocal<>(); // 获取实例 public static ConnectionContext getInstance() { return instance; } public void bind(Connection connection){ threadLocal.set(connection); } public Connection get(){ return threadLocal.get(); } public void remove(){ threadLocal.remove(); } } @WebFilter(description = "事务操作过滤器", urlPatterns = { "/*" }) public class TransactionFilter implements Filter { public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException { // 获取数据库连接 Connection conn = JDBCUtils.getConnection(); try { // 开启事务 conn.setAutoCommit(false); // 绑定数据库连接对象 ConnectionContext.getInstance().bind(conn); // 转发过滤器链 chain.doFilter(request, response); // 提交更新 conn.commit(); } catch (Exception e) { try { // 发生错误，回滚更新 conn.rollback(); } catch (SQLException e1) { e1.printStackTrace(); } e.printStackTrace(); }finally { // 移除Connection上下文绑定的数据库连接对象 ConnectionContext.getInstance().remove(); // 释放数据库连接 JDBCUtils.release(conn); } } }

过滤器链中的数据库操作

public T query(String sql, Object... args) { // 通过 Connection上下文 获取数据库连接对象 Connection connection = ConnectionContext.getInstance().get(); try { T t = queryRunner.query(connection, sql, new BeanHandler<>(clazz), args); return t; } catch (Exception e) { e.printStackTrace(); } return null; }