day12-功能实现11

家居网购项目实现011

以下皆为部分代码，详见 https://github.com/liyuelian/furniture_mall.git

27.功能25-事务管理

27.1下订单问题思考

在生成订单的功能中，系统会去同时修改数据库中的order，order_item，furn三张表，如果有任意一个表修改失败，就会出现数据不一致问题。因此出现了事务控制问题。
27.2思路分析

之前，我们每次调用底层的dao操作，每次进行的都是独立事务，因此一但在一次业务中调用了多个dao操作，就不能保证多表的事务一致性。

因为JDBC局部事务是控制是由java.sql.Connection来完成的，要保证多个DAO的数据访问处于一个事务中，我们需要保证他们使用的是同一个java.sql.Connection.

要保证数据一致性，就要使用事务。使用事务的前提是保证同一个连接connection。我们的想法是，在进行dao操作的前面就开启事务，然后在进行各种dao操作后，如果没有出现异常，则手动进行事务提交，否则进行回滚。
现在的问题是：
q1. 我们之前使用数据库连接池，无法保证每次进行dao操作都是同一个connection连接对象
q2. 设置开启手动提交事务以及事务回滚的时机
解决方法：

• 使用Filter+ThreadLocal进行事务管理
  
• 在一次http请求，servlet-service-dao的调用过程，始终是一个线程，这是使用ThreadLocal的前提
  
• 使用ThreadLocal来确保所有dao操作都在同一个Connection连接对象中完成
  
• 根据过滤器的机制，在所有代码都走完之后会回来走过滤器的chain.dofilter()的后置代码，这个特性非常适合进行事务管理
  

27.3代码实现

27.3.1uilts包

重写JDBCUtilsByDruid，修改getConnection方法，同时设置手动提交事务

1. package com.li.furns.utils;
3. import com.alibaba.druid.pool.DruidDataSourceFactory;
5. import javax.sql.DataSource;
6. import java.io.FileInputStream;
7. import java.sql.Connection;
8. import java.sql.ResultSet;
9. import java.sql.SQLException;
10. import java.sql.Statement;
11. import java.util.Properties;
13. /**
14. * 基于Druid数据库连接池的工具类
15. */
16. public class JDBCUtilsByDruid {
18.     private static DataSource ds;
19.     //定义属性ThreadLocal，这里存放一个Connection
20.     private static ThreadLocal<Connection> threadLocalConn = new ThreadLocal<>();
22.     //在静态代码块完成ds的初始化
23.     //静态代码块在加载类的时候只会执行一次，因此数据源也只会初始化一次
24.     static {
25.         Properties properties = new Properties();
26.         try {
27.             //因为我们是web项目，它的工作目录不在src下面，文件的加载需要使用类加载器
28.             properties.load(JDBCUtilsByDruid.class.getClassLoader()
29.                     .getResourceAsStream("druid.properties"));
30.             //properties.load(new FileInputStream("src\\druid.properties"));
31.             ds = DruidDataSourceFactory.createDataSource(properties);
32.         } catch (Exception e) {
33.             e.printStackTrace();
34.         }
35.     }
37. //    //编写getConnection方法
38. //    public static Connection getConnection() throws SQLException {
39. //        return ds.getConnection();
40. //    }
42.     /**
43.      * 获取连接方法
44.      * 从ThreadLocal中获取connection，
45.      * 从而保证在同一个线程中获取的是同一个Connection
46.      *
47.      * @return
48.      * @throws SQLException
49.      */
50.     public static Connection getConnection() {
51.         Connection connection = threadLocalConn.get();
52.         if (connection == null) {//说明当前的threadLocalConn没有连接
53.             //就从数据库连接池中获取一个连接，放到ThreadLocal中
54.             try {
55.                 connection = ds.getConnection();
56.                 //设置为手动提交，即不要自动提交
57.                 connection.setAutoCommit(false);
58.             } catch (SQLException e) {
59.                 e.printStackTrace();
60.             }
61.             threadLocalConn.set(connection);
62.         }
63.         return connection;
64.     }
66.     /**
67.      * 提交事务
68.      */
69.     public static void commit() {
70.         Connection connection = threadLocalConn.get();
71.         if (connection != null) {//确保该连接是有效的
72.             try {
73.                 connection.commit();
74.             } catch (SQLException e) {
75.                 e.printStackTrace();
76.             } finally {
77.                 try {
78.                     connection.close();//将连接释放回连接池
79.                 } catch (SQLException e) {
80.                     e.printStackTrace();
81.                 }
82.             }
83.             //1.当提交后，需要把connection从threadLocalConn中清除掉
84.             //2.否则会造成ThreadLocalConn长时间持有该连接，会影响效率
85.             //3.也因为我们Tomcat底层使用的是线程池技术
86.             threadLocalConn.remove();
87.         }
88.     }
90.     /**
91.      * 回滚，回滚的是和connection相关的dml操作
92.      */
93.     public static void rollback() {
94.         Connection connection = threadLocalConn.get();
95.         if (connection != null) {//保证当前的连接是有效的
96.             try {
97.                 connection.rollback();
98.             } catch (SQLException e) {
99.                 e.printStackTrace();
100.             } finally {
101.                 try {
102.                     connection.close();
103.                 } catch (SQLException e) {
104.                     e.printStackTrace();
105.                 }
106.             }
107.         }
108.         threadLocalConn.remove();
109.     }
111.     //关闭连接（注意：在数据库连接池技术中，close不是真的关闭连接，而是将Connection对象放回连接池中）
112.     public static void close(ResultSet resultSet, Statement statemenat, Connection connection) {
113.         try {
114.             if (resultSet != null) {
115.                 resultSet.close();
116.             }
117.             if (statemenat != null) {
118.                 statemenat.close();
119.             }
120.             if (connection != null) {
121.                 connection.close();
122.             }
123.         } catch (SQLException e) {
124.             throw new RuntimeException(e);
125.         }
126.     }
127. }

复制代码

因为现在连接的关闭是在commit或者rollback中发生的，因此BasicDAO中写的关闭连接已经没有意义了，将其删掉即可。
27.3.2filter

配置TransactionFilter

1. <filter>
2.     <filter-name>TransactionFilter</filter-name>
3.     <filter-class>com.li.furns.filter.TransactionFilter</filter-class>
4. </filter>
5. <filter-mapping>
6.     <filter-name>TransactionFilter</filter-name>
7.    
8.     <url-pattern>/*</url-pattern>
9. </filter-mapping>

复制代码

TransactionFilter：

1. package com.li.furns.filter;
3. import com.li.furns.utils.JDBCUtilsByDruid;
5. import javax.servlet.*;
6. import java.io.IOException;
8. /**
9. * 管理事务
10. *
11. * @author 李
12. * @version 1.0
13. */
14. public class TransactionFilter implements Filter {
15.     public void init(FilterConfig config) throws ServletException {
16.     }
18.     public void destroy() {
19.     }
21.     @Override
22.     public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws ServletException, IOException {
23.         try {
24.             //先放行
25.             chain.doFilter(request, response);
26.             //统一提交
27.             JDBCUtilsByDruid.commit();
29.         } catch (Exception e) {
30.             //只有在try{}中出现了异常，才会进行catch{}
31.             //这里想要捕获异常，前提是底层的代码没有将抛出的异常捕获
32.             JDBCUtilsByDruid.rollback();//回滚
33.             e.printStackTrace();
34.         }
35.     }
36. }

复制代码

由于之前在BasicServlet中捕获了异常，因此需要修改BasicServlet，将捕获的异常抛出给Filter，否则无法在出现异常时进行回滚。

27.4完成测试

为了测试，在FurnDAOImpl操作中写入错误的sql语句，模拟表操作失败
现在来测试一下，当发生dao操作失败后会产生什么现象。
登录用户，点击添加某个家居，点击购物车生成订单，因为生成订单涉及到furn表的操作，因此可以看到点击后页面没有跳转到正常的显示订单页面
查看后台输出，发现抛出异常
查看数据库：
相关的表没有进行改动，说明事务管理起作用了。
order_item表：
order表：
furn表：（操作前后的sales和stock字段一致）
28.功能26-统一错误提示页面

28.1需求分析/图解

• 如果在访问/操作网站时，出现了内部错误，统一显示 500.jsp
  
• 如果访问/操作不存在的页面/servlet时，统一显示 404.jsp
  

28.2思路分析

• 在发生错误/异常时，将错误/异常 抛给tomcat
  
• 在web.xml配置不同的错误显示不同的页面即可
  

28.3代码实现

404.jsp用于显示404错误；500.jsp用于显示服务器内部错误。

• 页面代码：略。
  
• 在web.xml文件中配置错误提示页：
  

1. <error-page>
2.     <error-code>404</error-code>
3.     <location>/views/error/404.jsp</location>
4. </error-page>
6. <error-page>
7.     <error-code>500</error-code>
8.     <location>/views/error/500.jsp</location>
9. </error-page>

复制代码

如果在代码中捕获了异常，那么将不会起到效果，应该要将异常抛出给tomcat，让tomcat可以根据不同的异常进行页面展示。
TransactionFilter：
28.4完成测试

在浏览器中输入一个项目不存在的资源http://localhost:8080/furniture_mall/abc.jsp，访问结果：
内部发生错误：

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！