在同一个类中调用带有@Transactional注解的方法示例

@Service
@Transactional
public class MyService {
    @Autowired
    private MyRepository myRepository;
    public void foo() {
        // 在此调用 bar 方法，事务将自动传播
        bar();
    }
    public void bar() {
        // 这里是被调用的方法，也添加 @Transactional 注解来管理事务
        myRepository.save(new MyEntity());
    }
}

@Service
@Transactional
public class MyService {
    @Autowired
    private MyRepository myRepository;
    public void foo() {
        // 在此调用 bar 方法，事务将生效
        ((MyService) AopContext.currentProxy()).bar();
    }
    @Transactional(propagation = Propagation.REQUIRES_NEW)
    private void bar() {
        // 这里是被调用的方法，使用 REQUIRES_NEW 传播行为开启一个新的事务
        myRepository.save(new MyEntity());
    }
}

@Service
@Transactional
public class MyService {
    @Autowired
    private MyRepository myRepository;
    @Autowired
    private MyService self;
    public void foo() {
        // 在此调用 bar 方法，事务将自动传播
        self.bar();
    }
    public void bar() {
        // 这里是被调用的方法，也添加 @Transactional 注解来管理事务
        myRepository.save(new MyEntity());
    }
}

@Service
@Transactional
public class MyService {
    @Autowired
    private MyRepository myRepository;
    @Autowired
    private TransactionTemplate transactionTemplate;
    public void foo() {
        // 在此调用 bar 方法，事务将生效
        transactionTemplate.execute(new TransactionCallback<Void>() {
            @Override
            public Void doInTransaction(TransactionStatus status) {
                // 在此执行需要在事务中完成的逻辑
                myRepository.save(new MyEntity());
                return null;
            }
        });
    }
}

@Component
@Aspect
public class TransactionalAspect {
    @Autowired
    private PlatfORMTransactionManager transactionManager;
    @Pointcut("@annotation(org.springframework.transaction.annotation.Transactional)")
    public void transactionalMethod() {}
    @Around("transactionalMethod()")
    public Object manageTransaction(ProceedingJoinPoint pjp) throws Throwable {
        DefaultTransactionDefinition definition = new DefaultTransactionDefinition();
        definition.setName(pjp.getSignature().getName());
        definition.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW);
        TransactionStatus status = transactionManager.getTransaction(definition);
        try {
            Object result = pjp.proceed();
            transactionManager.commit(status);
            return result;
        } catch (Throwable t) {
            transactionManager.rollback(status);
            throw t;
        }
    }
}