public class DynamicDataSource extends AbstractRoutingDataSource {
    @Override
    protected Object determineCurrentLookupKey() {
        return DbContextHolder.getCurrentDataSource();
    }
}

@Aspect
@Component
public class DataSourceAspect {
    @Before("execution(* org.flowable..*.*(..))")
    public void setFlowableDataSource() {
        DbContextHolder.setDataSource("flowable");
    }
    
    @Before("execution(* com.yourpackage.business..*.*(..))")
    public void setBusinessDataSource() {
        DbContextHolder.setDataSource("business");
    }
}

@Service
public class WorkflowService {
    @Autowired
    private TaskService taskService; // Flowable服務(wù)
    
    @Autowired
    private BusinessService businessService; // 業(yè)務(wù)服務(wù)
    
    @Transactional
    public void processWorkflow() {
        // 預(yù)期使用flowable數(shù)據(jù)源
        List<Task> tasks = taskService.createTaskQuery().list();
        
        // 預(yù)期使用business數(shù)據(jù)源
        List<BusinessEntity> entities = businessService.findAll();
    }
}

@Service
public class WorkflowService {
    @Transactional
    public void mainProcess() {
        // 使用主數(shù)據(jù)源
        flowableOperation();
        
        // 開(kāi)啟新事務(wù)，使用業(yè)務(wù)數(shù)據(jù)源
        businessOperationInNewTx();
    }
    
    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public void businessOperationInNewTx() {
        // 業(yè)務(wù)數(shù)據(jù)操作
    }
}

@Transactional(propagation = Propagation.NOT_SUPPORTED)
public List<BusinessEntity> getBusinessData() {
    // 此方法執(zhí)行時(shí)不支持當(dāng)前事務(wù)，會(huì)暫?，F(xiàn)有事務(wù)
    return businessRepository.findAll();
}

public class MultiDataSourceTransaction implements Transaction {
    private final DataSource dataSource;
    private Connection mainConnection;
    private Map<String, Connection> otherConnections = new ConcurrentHashMap<>();
    
    public MultiDataSourceTransaction(DataSource dataSource) {
        this.dataSource = dataSource;
    }
    
    @Override
    public Connection getConnection() throws SQLException {
        String currentDataSource = DbContextHolder.getCurrentDataSource();
        if (currentDataSource.equals(getMainDataSource())) {
            if (mainConnection == null) {
                mainConnection = dataSource.getConnection();
            }
            return mainConnection;
        } else {
            return otherConnections.computeIfAbsent(currentDataSource, 
                key -> fetchConnectionForDataSource(key));
        }
    }
    
    // 其他必要方法實(shí)現(xiàn)...
}

public class MultiDataSourceTransactionFactory extends SpringManagedTransactionFactory {
    @Override
    public Transaction newTransaction(DataSource dataSource, 
            TransactionIsolationLevel level, boolean autoCommit) {
        return new MultiDataSourceTransaction(dataSource);
    }
}

@Bean
public SqlSessionFactoryBean sqlSessionFactory(DataSource dataSource) {
    SqlSessionFactoryBean factory = new SqlSessionFactoryBean();
    factory.setDataSource(dataSource);
    factory.setTransactionFactory(new MultiDataSourceTransactionFactory());
    return factory;
}

public class OrderWorkflowService {
    @Autowired
    private OrderRepository orderRepository;
    
    @Autowired
    private RuntimeService runtimeService;
    
    @Transactional
    public void createOrder(Order order) {
        // 保存訂單到業(yè)務(wù)數(shù)據(jù)庫(kù)
        orderRepository.save(order);
        
        // 啟動(dòng)工作流
        startWorkflow(order);
    }
    
    @Transactional(propagation = Propagation.REQUIRES_NEW)
    private void startWorkflow(Order order) {
        Map<String, Object> variables = new HashMap<>();
        variables.put("orderId", order.getId());
        runtimeService.startProcessInstanceByKey("orderApproval", variables);
    }
}