mybatisplus手動獲取數據源執行非主數據庫事務

class A {// 事務管理器@Resourceprivate DataSourceTransactionManager dataSourceTransactionManager;@Autowiredprivate DataSource dataSource; // 最終是com.baomidou.dynamic.datasource.DynamicRoutingDataSource類型public void add(MDTO dto) throws AppException {// 獲取想要執行事務的數據源final DataSource testdb = ((DynamicRoutingDataSource) dataSource).getDataSource("testdb");dataSourceTransactionManager.setDataSource(testdb);DefaultTransactionDefinition transactionDefinition = new DefaultTransactionDefinition();// 新發起一個事務transactionDefinition.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW);// 獲得事務狀態final TransactionStatus transactionStatus = dataSourceTransactionManager.getTransaction(transactionDefinition);try {Map<String, Object> result = new HashMap<>();result.put("test1", 0);result.put("test2", 0);baseMapper.WAdd(result);// 提交所有事務dataSourceTransactionManager.commit(transactionStatus);} catch (Exception e) {// 回滾if (dataSourceTransactionManager != null) {dataSourceTransactionManager.rollback(transactionStatus);}e.printStackTrace();throw e;}}
}