一、需求背景:
我们生活经常遇到一个情况:在购买商品的时候,已经支付的了,那么商品应该处于已购买订单里。而不是付款之后,已购买商品没有。
还有转账的时候,转出方和转入方都需要扣减相应的金额,而不是一方减少或者增加。
因为上面的例子都是对数据操作,所以需要我们操作数据库的事务。
如何确定一个事务范围?
事务是由一系列数据库操作组成,他和业务场景有关。当操作完成的时候,如果操作过程没有出现失败,则这个事务产生的数据库操作一并提交(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 ThreadLocalthreadLocal=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()