SpringBoot超詳細講解事務管理

Posted on by

1. 事務的定義

事務是由 N 步數據庫操作序列組成的邏輯執行單元，這系列操作要麼全部執行，要麼全部放棄執行。

2. 事務的特性

事務的 ACID 特性：

  • 原子性：事務是應用中不可分割的最小執行體
  • 一致性：事務執行的結果必須使得數據從一個一致性狀態轉變為另一個一致性狀態
  • 隔離性：各個事務的執行互不幹擾，任何事務的內部操作對其他事務都是隔離的
  • 持久性：事務一旦提交，對數據所做的任何修改都要記錄到永久存儲器中

3. 事務的隔離性

常見的並發異常

  • 第一類丟失更新、第二類丟失更新
  • 臟讀、不可重復讀、幻讀

常見的隔離級別

  • Read Uncommitted：讀取未提交的數據
  • Read Commited：讀取已提交的數據
  • Repeatable Read：可重復讀
  • Serializable：串行化

第一類更新丟失：某一個事務的回滾，導致另一個事務已更新的數據丟失瞭。

第二類更新丟失：某一個事務的提交，導致另一個事務已更新的數據丟失瞭。

臟讀：某一個事務，讀取瞭另一個事務未提交的數據。

不可重復讀：某一個事務，對同一個數據前後讀取的結果不一致。

幻讀：某一個事務，對同一個表前後查詢到的行數不一致。

隔離級別 第一類丟失更新 臟讀 第二類丟失更新 不可重復讀 幻讀
Read Uncommitted 是 是 是 是 是
Read Commited 否 否 是 是 是
Repeatable Read 否 否 否 否 是
Repeatable Read 否 否 否 否 否

4. 事務管理

實現機制

悲觀鎖（數據庫）

  • 共享鎖（S鎖）：事務A對某數據加瞭共享鎖以後，其他事務隻能對該數據加共享鎖，但不能加排他鎖
  • 排他鎖（X鎖）：事務A對某數據加瞭排他鎖以後，其他事務對該數據既不能加共享鎖，也不能加排他鎖。

樂觀鎖（自定義）

  • 版本號、時間戳等
  • 在更新數據前，檢查版本號是否發生變化。若發生變化則取消本次更新，否則就更新數據（版本號+1）

Spring 事務管理

聲明式事務

  • 通過 XML 配置，聲明某方法的事務特征。
  • 通過註解，聲明某方法的事務特征。

編程式事務

  • 通過 TransactionTemplate管理事務，並通過它執行數據庫的操作。

5. 示例

package com.nowcoder.community.service;
import com.nowcoder.community.dao.AlphaDao;
import com.nowcoder.community.dao.DiscussPostMapper;
import com.nowcoder.community.dao.UserMapper;
import com.nowcoder.community.entity.DiscussPost;
import com.nowcoder.community.entity.User;
import com.nowcoder.community.util.CommunityUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Scope;
import org.springframework.stereotype.Service;
import org.springframework.transaction.TransactionDefinition;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.annotation.Isolation;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.transaction.support.TransactionCallback;
import org.springframework.transaction.support.TransactionTemplate;
import javax.annotation.PostConstruct;
import javax.annotation.PreDestroy;
import java.util.Date;
@Service
//@Scope("prototype")
public class AlphaService {
    @Autowired
    private AlphaDao alphaDao;
    @Autowired
    private UserMapper userMapper;
    @Autowired
    private DiscussPostMapper discussPostMapper;
    @Autowired
    private TransactionTemplate transactionTemplate;
    public AlphaService() {
//        System.out.println("實例化AlphaService");
    }
    @PostConstruct
    public void init() {
//        System.out.println("初始化AlphaService");
    }
    @PreDestroy
    public void destroy() {
//        System.out.println("銷毀AlphaService");
    }
    public String find() {
        return alphaDao.select();
    }
    // REQUIRED: 支持當前事務(外部事務),如果不存在則創建新事務.
    // REQUIRES_NEW: 創建一個新事務,並且暫停當前事務(外部事務).
    // NESTED: 如果當前存在事務(外部事務),則嵌套在該事務中執行(獨立的提交和回滾),否則就會REQUIRED一樣.
    @Transactional(isolation = Isolation.READ_COMMITTED, propagation = Propagation.REQUIRED)
    public Object save1() {
        // 新增用戶
        User user = new User();
        user.setUsername("alpha");
        user.setSalt(CommunityUtil.generateUUID().substring(0, 5));
        user.setPassword(CommunityUtil.md5("123" + user.getSalt()));
        user.setEmail("[email protected]");
        user.setHeaderUrl("http://image.nowcoder.com/head/99t.png");
        user.setCreateTime(new Date());
        userMapper.insertUser(user);
        // 新增帖子
        DiscussPost post = new DiscussPost();
        post.setUserId(user.getId());
        post.setTitle("Hello");
        post.setContent("新人報道!");
        post.setCreateTime(new Date());
        discussPostMapper.insertDiscussPost(post);
        Integer.valueOf("abc");
        return "ok";
    }
    public Object save2() {
        transactionTemplate.setIsolationLevel(TransactionDefinition.ISOLATION_READ_COMMITTED);
        transactionTemplate.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);
        return transactionTemplate.execute(new TransactionCallback<Object>() {
            @Override
            public Object doInTransaction(TransactionStatus status) {
                // 新增用戶
                User user = new User();
                user.setUsername("beta");
                user.setSalt(CommunityUtil.generateUUID().substring(0, 5));
                user.setPassword(CommunityUtil.md5("123" + user.getSalt()));
                user.setEmail("[email protected]");
                user.setHeaderUrl("http://image.nowcoder.com/head/999t.png");
                user.setCreateTime(new Date());
                userMapper.insertUser(user);
                // 新增帖子
                DiscussPost post = new DiscussPost();
                post.setUserId(user.getId());
                post.setTitle("你好");
                post.setContent("我是新人!");
                post.setCreateTime(new Date());
                discussPostMapper.insertDiscussPost(post);
                Integer.valueOf("abc");
                return "ok";
            }
        });
    }
}

到此這篇關於SpringBoot超詳細講解事務管理的文章就介紹到這瞭,更多相關SpringBoot事務管理內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet！

推薦閱讀：