在 Spring Boot 中使用事务_代码007(未授权)

本文介绍: 您可以使用 @Transactional 注解的 rollbackFor 或 noRollbackFor 属性来自定义回滚行为。@Service// …在这个例子中，我们指定 RuntimeException 不应触发回滚。这在您希望在事务内保留更改，即使发生错误时也很有用。

当调用使用 @Transactional 注解的方法时，Spring Boot利用事务管理器来创建或加入事务。事务管理器监视事务的生命周期，根据操作结果进行提交或回滚。

Spring Boot支持各种事务隔离级别，包括READ_UNCOMMITTED（读取未提交的数据）、READ_COMMITTED（读取已提交的数据）、REPEATABLE_READ（可重复读）、SERIALIZABLE（串行化）。这些级别确定事务如何与其他事务和底层数据交互。根据应用程序的需求选择正确的隔离级别。

@Service
public class UserService {
  @Autowired
  private UserRepository userRepository;
jj@Transactional
  public void updateUser(String username, String email) {
    User user = userRepository.findByUsername(username);
    user.setEmail(email);
    // ... other operations
  }
}

在上面的示例中，updateUser() 被标记为 @Transactional，允许Spring Boot管理事务的行为。

事务行为可以根据方法的注解方式而有所不同。以下是一个关键区别：

@Service
public class MyService {
@Transactional
    public void methodA() {
        // ... some code here
        methodB();
        // ... some code here
    }
@Transactional(propagation = Propagation.REQUIRES_NEW)
    public void methodB() {
        // ... some code here
    }
}

在这个例子中，methodA() 调用了 methodB()。由于 REQUIRES_NEW 传播设置，当 methodB() 开始一个新的事务时，methodA() 的事务被挂起。

当一个 @Transactional 方法调用同一类内的另一个 @Transactional 方法时，Spring 的默认行为值得注意：

@Service
public class MyService {
    @Autowired
    private MyService self;
ja   @Transactional
    public void methodA() {
        // ... some code here
        self.methodB();
        // ... some code here
    }
@Transactional
    public void methodB() {
        // ... some code here
    }
}

@Service
public class MyService {
@Autowired
    private OtherService otherService;
@Transactional
    public void methodA() {
        // ... some code here
        otherService.methodB();
        // ... some code here
    }
}
@Service
public class OtherService {
   @Transactional
    public void methodB() {
        // ... some code here
    }
}

@Service
@Transactional
public class UserService {
 @Autowired
  private UserRepository userRepository;
 public void updateUser(String username, String email) {
    User user = userRepository.findByUsername(username);
    if (user == null) {
      throw new RuntimeException("User not found");
    }
    user.setEmail(email);
    userRepository.save(user);
    throw new RuntimeException("Something went wrong");
  }
}

@Service
@Transactional(noRollbackFor = RuntimeException.class)
public class UserService { 
// ...
}

@Service
public class MyService {
   @Transactional
    public void methodA() {
        // ... some code here
        methodB();
        // ... some code here
    }
    private void methodB() {
        // ... some code here
    }
}

@Service
public class UserService {
  @Autowired
  private UserRepository userRepository;
 @Transactional
  public void updateUser(String username, String email) {
    User user = userRepository.findByUsername(username);
    user.setEmail(email);
    // ... other operations
  }
}