如何向Java DSL集成流添加事务支持

<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-tx</artifactId>
    <version>5.3.10</version>
</dependency>

import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.PlatformTransactionManager;

// 创建一个事务管理器实例
PlatformTransactionManager transactionManager = new DataSourceTransactionManager(dataSource);

import org.springframework.transaction.annotation.Transactional;

// 添加事务支持的流处理代码
stream
    .<InputType>filter(...)
    .<OutputType>map(...)
    .process(...)
    .transactional(transactionManager) // 使用事务管理器包装流处理代码
    .<OutputType>map(...)
    .to(...)
    .start();

<!-- 配置数据源 -->
<bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
    <property name="driverClassName" value="com.mysql.jdbc.Driver" />
    <property name="url" value="jdbc:mysql://localhost:3306/mydb" />
    <property name="username" value="root" />
    <property name="password" value="password" />
</bean>

<!-- 配置事务管理器 -->
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    <property name="dataSource" ref="dataSource" />
</bean>