我正在尋找下一個問題的解決方案。我使用 Spring 并且我有一些不應(yīng)被阻止的執(zhí)行程序線程（至少讀/寫數(shù)據(jù)庫）。有幾個任務(wù)可以通過這個執(zhí)行器執(zhí)行，我不知道哪個可以使用@Transactional方法或任何其他方式來訪問數(shù)據(jù)庫。我想禁止在執(zhí)行者線程中打開新事務(wù)，怎么做？小例子@Componentpublic class Service { public void execute() { System.out.println("I don't need transaction to execute"); }}@Componentpublic class Service2 { @Transactional public void execute() { System.out.println("I've opened new transaction!"); }}@Componentpublic class NonTransactionalExecutor { @Autowired private ThreadPoolExecutor threadPoolExecutor; @Autowired private Service service; @@Autowired private Service2 service2; public void doInExecutor() { threadPoolExecutor.execute(new Runnable() { @Override public void run() { // Is there anything I could do to get exception on service2.execute? service.execute(); service2.execute(); } }); }}PS 在現(xiàn)實世界中，當方法被注釋時，@Transactional它會嘗試TransactionManager使用數(shù)據(jù)庫中的當前值打開新事務(wù)（我使用的是 Postgres）。
1 回答
智慧大石
TA貢獻1946條經(jīng)驗 獲得超3個贊
您可能可以為此使用裝飾器模式。實現(xiàn)您自己的PlatformTransactionManager并將您當前的經(jīng)理作為委托傳遞給它。在 中g(shù)etTransaction，如果當前線程不是您所期望的，則拋出異常。
public class MyTransactionManager implements PlatformTransactionManager {
private final PlatformTransactionManager delegate;
public MyTransactionManager(PlatformTransactionManager delegate) {
this.delegate = delegate;
}
@Override
public void commit(TransactionStatus status) {
delegate.commit(status);
}
@Override
public TransactionStatus getTransaction(TransactionDefinition definition) {
if (Thread.getCurrentThread() == /*something*/) {
return delegate.getTransaction(definition);
}
else {
throw new RuntimeException();
}
}
@Override
public void rollback(TransactionStatus status) {
delegate.rollback(status);
}
}
添加回答
舉報
0/150
提交
取消