Spring事務(wù)失效問題分析及解決方案

/**
 * 【Spring 獨有】使用后端數(shù)據(jù)庫默認(rèn)的隔離級別
 *
 * MySQL 默認(rèn)采用的 REPEATABLE_READ隔離級別
 * Oracle 默認(rèn)采用的 READ_COMMITTED隔離級別
 */
int ISOLATION_DEFAULT = -1;
 
/**
 * 最低的隔離級別，允許讀取尚未提交的數(shù)據(jù)變更，可能會導(dǎo)致臟讀、幻讀或不可重復(fù)讀
 */
int ISOLATION_READ_UNCOMMITTED = Connection.TRANSACTION_READ_UNCOMMITTED;
 
/**
 * 允許讀取并發(fā)事務(wù)已經(jīng)提交的數(shù)據(jù)，可以阻止臟讀，但是幻讀或不可重復(fù)讀仍有可能發(fā)生
 */
int ISOLATION_READ_COMMITTED = Connection.TRANSACTION_READ_COMMITTED;
/**
 * 對同一字段的多次讀取結(jié)果都是一致的，除非數(shù)據(jù)是被本身事務(wù)自己所修改，可以阻止臟讀和不可重復(fù)讀，但幻讀仍有可能發(fā)生。
 */
int ISOLATION_REPEATABLE_READ = Connection.TRANSACTION_REPEATABLE_READ;
/**
 * 最高的隔離級別，完全服從ACID的隔離級別。所有的事務(wù)依次逐個執(zhí)行，這樣事務(wù)之間就完全不可能產(chǎn)生干擾，也就是說，該級別可以防止臟讀、不可重復(fù)讀以及幻讀。
 *
 * 但是這將嚴(yán)重影響程序的性能。通常情況下也不會用到該級別。
 */
int ISOLATION_SERIALIZABLE = Connection.TRANSACTION_SERIALIZABLE;

// ========== 支持當(dāng)前事務(wù)的情況 ==========
 
/**
 * 如果當(dāng)前存在事務(wù)，則使用該事務(wù)。
 * 如果當(dāng)前沒有事務(wù)，則創(chuàng)建一個新的事務(wù)。
 */
int PROPAGATION_REQUIRED = 0;
/**
 * 如果當(dāng)前存在事務(wù)，則使用該事務(wù)。
 * 如果當(dāng)前沒有事務(wù)，則以非事務(wù)的方式繼續(xù)運行。
 */
int PROPAGATION_SUPPORTS = 1;
/**
 * 如果當(dāng)前存在事務(wù)，則使用該事務(wù)。
 * 如果當(dāng)前沒有事務(wù)，則拋出異常。
 */
int PROPAGATION_MANDATORY = 2;
 
// ========== 不支持當(dāng)前事務(wù)的情況 ==========
 
/**
 * 創(chuàng)建一個新的事務(wù)。
 * 如果當(dāng)前存在事務(wù)，則把當(dāng)前事務(wù)掛起。
 */
int PROPAGATION_REQUIRES_NEW = 3;
/**
 * 以非事務(wù)方式運行。
 * 如果當(dāng)前存在事務(wù)，則把當(dāng)前事務(wù)掛起。
 */
int PROPAGATION_NOT_SUPPORTED = 4;
/**
 * 以非事務(wù)方式運行。
 * 如果當(dāng)前存在事務(wù)，則拋出異常。
 */
int PROPAGATION_NEVER = 5;
 
// ========== 其他情況 ==========
 
/**
 * 如果當(dāng)前存在事務(wù)，則創(chuàng)建一個事務(wù)作為當(dāng)前事務(wù)的嵌套事務(wù)來運行。
 * 如果當(dāng)前沒有事務(wù)，則等價于 {@link TransactionDefinition#PROPAGATION_REQUIRED}
 */
int PROPAGATION_NESTED = 6;

@Slf4j
@Service
public class OrderServiceImpl implements OrderService {
  @Autowired
  private OrderMapper orderMapper;
 
  @Transactional
  @Override
  public void parent() {
    try {
      this.child();
 
    } catch (Exception e) {
      log.error("插入異常", e);
    }
 
 
    Order order = new Order();
    order.setOrderNo("parent");
    order.setStatus("0");
    order.setTitle("parent");
    order.setAmount("1000");
    orderMapper.insert(order);
  }
 
 
  @Transactional
  @Override
  public void child() {
 
    Order order = new Order();
    order.setOrderNo("child");
    order.setStatus("0");
    order.setTitle("child");
    order.setAmount("2000");
    orderMapper.insert(order);
 
    throw new RuntimeException();
  }
}

@Autowired
private ApplicationContext context;
 
private OrderService orderService;
 
@PostConstruct
public void init() {
  orderService = context.getBean(OrderService.class);
}
 
 
@Transactional
@Override
public void parent() {
  try {
    //獲取代理對象，通過代理對象調(diào)用child()
    orderService.child();
 
　　　//獲取代理對象
    //OrderService orderService = (OrderService) AopContext.currentProxy();
    //orderService.child();
  } catch (Exception e) {
    log.error("插入異常", e);
  }
  Order order = new Order();
  order.setOrderNo("parent");
  order.setStatus("0");
  order.setTitle("parent");
  order.setAmount("1000");
  orderMapper.insert(order);
}

@Transactional(propagation = Propagation.REQUIRES_NEW)
@Override
public void child() {
 
  Order order = new Order();
  order.setOrderNo("child");
  order.setStatus("0");
  order.setTitle("child");
  order.setAmount("2000");
  orderMapper.insert(order);
 
  throw new RuntimeException();
}

@Transactional(propagation = Propagation.REQUIRES_NEW)