数据库事务管理及引入乐观锁、悲观锁

叁歲伎倆 2022-03-18 06:41 128阅读 0赞

前文：

当多线程访问数据库时，会出现并发问题，于是需要用到事务。

一、事务

1.概念

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjY4NzA3NA_size_16_color_FFFFFF_t_70][]

2.代码实现

try {
    	conn=DriverManager.getConnection(url, user, password);
    	// 1.开启事务
    	conn.setAutoCommit(false);
    	// 获取SQL的执行器
    	st=conn.createStatement();
    	// 执行SQL语句
    	String sql1="update account set money=money-1000 where name='a'";
    	String sql2="update account set money=money+1000 where name='b'";	
    	for(int i=1;i<=5;i++){
    		int i1=st.executeUpdate(sql1);// 从a账户扣1000
    		int i2=st.executeUpdate(sql2);// 向b账户加1000
    		sp=conn.setSavepoint();//2.设置一次存档点
    	}
    	// 3.提交事务
    	conn.commit();
    } catch (Exception e) {
    	e.printStackTrace();
    	// 4.回滚事务
    	try {
    		conn.rollback(sp);// 5.回滚到存档点
    		// 如果是回滚到存档点，那么之后还必须进行一次commit操作，才能让存档点之前的操作都生效
    		conn.commit();
    	} catch (SQLException e1) {
    		e1.printStackTrace();
    	}
    }

二、ThreadLocal

事务的提交回滚等操作，需要在同一个连接池对象下操作。在分层开发中的多个代码块要使用同一个连接池对象的话，就需要用到每个线程自带的Map存放该连接池对象，线程对线不能直接使用这个Map，就需要用到ThreadLocal对象。

1.概念

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjY4NzA3NA_size_16_color_FFFFFF_t_70 1][]

2.代码实现

public class TransactionManager {
    	
    	//设置一个ThreadLocal对象，用于存放每个线程自己的连接池对象
    	private static ThreadLocal<Connection> tl=new ThreadLocal<Connection>();
    	
    	public static void startTran(){
    		// 从数据库连接池为当前线程获取一个新的连接
    		Connection conn=JDBCUtils.getConn();
    
    		try {
    			// 使用该连接对象开启事务
    			conn.setAutoCommit(false);
    			// 将该连接对象存入当前线程对象的map集合中
    			tl.set(conn);
    		} catch (SQLException e) {
    			e.printStackTrace();
    		}
    	}
    	
    	public static void commitTran(){
    		// 从当前线程对象的map集合中获取开启事务所使用的连接对象
    		Connection conn=tl.get();
    		try {
    			conn.commit();//其他方法类似
    		} catch (SQLException e) {
    			e.printStackTrace();
    		}
    	}
    	
    }

三、乐观锁、悲观锁与更新丢失

使用Serializable虽然可以防止两个事务对同一数据的更新丢失，但效率较低，所以引入了乐观锁和悲观锁

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjY4NzA3NA_size_16_color_FFFFFF_t_70 2][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjY4NzA3NA_size_16_color_FFFFFF_t_70]: /images/20220318/02aacb79aa5e486eac0aa0bacaa674bf.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjY4NzA3NA_size_16_color_FFFFFF_t_70 1]: /images/20220318/4dd03eadaa80489f898be0b001ce85ad.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjY4NzA3NA_size_16_color_FFFFFF_t_70 2]: /images/20220318/fe44c1b4f1fe4614b71cdaa9d55099e1.png