java操作数据库的事务支持

时间:2022-09-12 15:16:16

一、需求背景:

我们生活经常遇到一个情况:在购买商品的时候,已经支付的了,那么商品应该处于已购买订单里。而不是付款之后,已购买商品没有。

还有转账的时候,转出方和转入方都需要扣减相应的金额,而不是一方减少或者增加。

因为上面的例子都是对数据操作,所以需要我们操作数据库的事务。

如何确定一个事务范围?

事务是由一系列数据库操作组成,他和业务场景有关。当操作完成的时候,如果操作过程没有出现失败,则这个事务产生的数据库操作一并提交(commit)。反之,如果出现失败,则一并回滚(rollback)。

所有事务和业务层(service)确定。

事务的特点:

ACID

   1、原子性:事务里面的操作单元不可切割,要么全部成功,要么全部失败
        2、一致性:事务执行前后,业务状态和其他业务状态保持一致.
        3、隔离性:一个事务执行的时候最好不要受到其他事务的影响
        4、持久性:一旦事务提交或者回滚.这个状态都要持久化到数据库中

 不考虑隔离性会出现的读问题:
        脏读:在一个事务中读取到另一个事务没有提交的数据
        不可重复读:在一个事务中,两次查询的结果不一致(针对的update操作)
        虚读(幻读):在一个事务中,两次查询的结果不一致(针对的insert操作)
    通过设置数据库的隔离级别来避免上面的问题(理解)
        read uncommitted      读未提交    上面的三个问题都会出现
        read committed      读已提交    可以避免脏读的发生
        repeatable read        可重复读    可以避免脏读和不可重复读的发生
        serializable        串行化        可以避免所有的问题

两种方式:

1)数据库上控制事务:

默认情况下,mysql数据库中的事务是自动提交。

1 mysql> show variables like "%autocommit%";
2 +---------------+-------+
3 | Variable_name | Value |
4 +---------------+-------+
5 | autocommit    | ON    |
6 +---------------+-------+
7 1 row in set (0.00 sec

 

我们可以在数据库上进行事务的开启和关闭。但是这种方式显然不好。

2)java代码实现。

查看connection的方法:

1:void commit() 提交事务。Makes all changes made since the previous commit/rollback permanent and releases any database locks currently held by this Connection object.

2:void  rollback()回滚事务.Undoes all changes made in the current transaction and releases any database locks currently held by this Connection object

3:void setAutocommit(boolean ) false 表示开启事务,true表示事务关闭。Sets this connection's auto-commit mode to the given state.

注意:事务要作用同一个数据库连接。

java代码实现有两种方式:

  1、自上到下传递参数:

    通过service传递到dao层的connection的变量,保证整个过程使用的是同一个数据连接。

  2、当前线程绑定事务:

    通过绑定当前线程一个变量(connection),在dao中获取这个connection,保证整个事务的过程中,使用的是同一个连接。

  其中threadLocal方法:ThreadLocal instances are typically private static fields in classes that wish to associate state with a thread (e.g., a user ID or Transaction ID)

    该字段在类中要以private  static 来进行修饰。

    1) T  get() 返回当前线程绑定的值。

    2)void  remove() 从当前线程解绑。

    3)void  set(T  value)  绑定当前线程。

内部实现原理就是map方法对currentThread  进行put 和set  remove。

jdbc工具类:

 1 package jd.com.tool_jdbc;
 2 
 3 import org.apache.commons.dbcp2.BasicDataSource;
 4 import org.apache.commons.dbcp2.BasicDataSourceFactory;
 5 
 6 
 7 import java.io.InputStream;
 8 import java.sql.Connection;
 9 import java.sql.PreparedStatement;
10 import java.sql.SQLException;
11 import java.util.Properties;
12 
13 
14 
15 public   class ds_tool {
16     private  static BasicDataSource ds=null;
17     private static Connection con=null;
18     private static ThreadLocal<Connection> threadLocal=new ThreadLocal<>();
19     public   static  BasicDataSource getDs(){
20         try {
21             InputStream inp= ds_tool.class.getClassLoader().getResourceAsStream("database.properties");
22             Properties  pro=new Properties();
23             pro.load(inp);
24             ds=new BasicDataSourceFactory().createDataSource(pro);
25             ds.setInitialSize(4);
26             ds.setMaxTotal(8);
27             ds.setMaxIdle(2);
28             return  ds;
29         }catch (Exception ex){
30             throw  new RuntimeException("初始化数据库失败"+ex);
31         }
32 
33     }
34     //给当前线程绑定变量。
35     public  static  BasicDataSource setDs(){
36         try {
37             if(con==null){
38                 ds=getDs();
39                 con=ds.getConnection();
40                 threadLocal.set(con);
41             }else{
42                 threadLocal.set(con);
43             }
44             return  ds;
45         }catch (Exception ex){
46             ex.printStackTrace();
47             throw  new RuntimeException("初始化错误"+ex);
48         }
49 
50     }
51     //开启事务
52     public static void  openEven(){
53         try {
54             setDs();
55             con=threadLocal.get();
56             con.setAutoCommit(false);
57         }catch (Exception ex){
58             ex.printStackTrace();
59         }
60 
61     }
62     //提交事务
63     public static void  commEven(){
64         try {
65             con=threadLocal.get();
66             con.commit();
67         }catch (Exception ex){
68             ex.printStackTrace();
69         }
70 
71     }
72     //回滚事务
73     public static  void  rollbackEvent(){
74         try {
75             con=threadLocal.get();
76             System.out.println(con);
77             con.rollback();
78         }catch (Exception ex){
79             ex.printStackTrace();
80         }
81 
82     }
83     public  static  void closedDs(BasicDataSource ds, PreparedStatement pre){
84         try { 
85             ds.close();
86             pre.close();
87             threadLocal.remove();
88         }catch (Exception ex){
89             ex.printStackTrace();
90         }
91 
92     }
93 
94 }

 

然后在业务层上进行事务的控制。

3)1、queryRunner()初始化的时候,不带参数,是默认是开启事务。

  在执行的时候,update(connection con  sql  object ...parm)传入connection。需要关闭资源 connection。

  2、如果quryRunner(Datasource ds)的时候,内部代码会帮我们实现资源回收。不需要connection.close()