Spring Integration (DSL)：在同一事务中运行两个JPA查询

@Configuration
@EnableTransactionManagement
public class AppConfig {

    @Autowired
    private EntityManagerFactory entityManagerFactory;

    @Bean
    public DataSource dataSource() {
        // 配置数据库连接信息
        // ...
    }

    @Bean
    public LocalContainerEntityManagerFactoryBean entityManagerFactory() {
        // 配置JPA实体和数据源
        // ...
    }

    @Bean
    public PlatformTransactionManager transactionManager() {
        // 配置事务管理器
        JpaTransactionManager transactionManager = new JpaTransactionManager();
        transactionManager.setEntityManagerFactory(entityManagerFactory);
        return transactionManager;
    }

    @Bean
    public IntegrationFlow integrationFlow() {
        return IntegrationFlows
                .from("inputChannel")
                .handle((payload, headers) -> {
                    // 在同一事务中执行第一个JPA查询
                    // ...
                    // 在同一事务中执行第二个JPA查询
                    // ...
                    return payload;
                })
                .get();
    }
}