1

我正在使用 Spring 批处理并尝试使用两个“ORM”框架构建 TASKLET：使用 jdbcTemplate 进行简单查询，使用 JOOQ 框架进行更复杂的查询。

这是弹簧配置的一部分：

<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    <property name="dataSource" ref="dataSourceDbcp_MySQL" /> 
</bean>
<bean id="jobRepository" class="org.springframework.batch.core.repository.support.MapJobRepositoryFactoryBean">
    <property name="transactionManager" ref="transactionManager" />
</bean>
<bean id="jobLauncher" class="org.springframework.batch.core.launch.support.SimpleJobLauncher">
    <property name="jobRepository" ref="jobRepository" />
</bean>
<job id="importProductsJob" xmlns="http://www.springframework.org/schema/batch">
    <step id="readWrite">
        <tasklet transaction-manager="transactionManager">
            <chunk  reader="multiResourceReader" 
                    processor="itemProcessor" 
                    writer="itemWriter" 
                    commit-interval="250" />
        </tasklet>
    </step>
</job>
<bean id="itemWriter" class="com.myexample.writer.JdbcSequenceWriter">
    <property name="dataSourceTransactionManager" ref="transactionManager" />
    <!-- and some more specific properties -->
</bean>

我在 com.myexample.writer.JdbcSequenceWriter 的 setter 处初始化我的 ORM：

private JdbcTemplate jdbcTemplate;
private JdbcTemplate jdbcTemplate2; 
private DSLContext dslContext;

public void setDataSourceTransactionManager(DataSourceTransactionManager trxManager) {
    this.jdbcTemplate = new JdbcTemplate(trxManager.getDataSource());
    this.jdbcTemplate2 = new JdbcTemplate(trxManager.getDataSource());
    dslContext = DSL.using(trxManager.getDataSource(), SQLDialect.MYSQL);
}

两个 jdbcTemplate 都有一个会话，我可以使用“jdbcTemplate”插入一条记录，并使用带有“jdbcTemplate2”的 SELECT 找到这条记录。但是，如果尝试使用任何 'jdbcTemplate' 插入记录并使用 dslContext (JOOQ ORM) 找到它，我会得到空结果。我不明白 Spring Batch 使用了一些棘手的事务管理器，如果“作者”无法完成所有操作，则女巫回滚所有操作。但是如何将另一个框架与单个事务管理器同步？

4

1 回答 1

2

通常预期的行为是您在 和 之间观察到的JdbcTemplate：dslContext每个都从DataSource.

您的第一个发现，有两个JdbcTemplate实例，是必须专门设计的特殊行为。JdbcTemplate显然，它的所有实例在内部共享相同的连接。

Connection您可以通过首先从获取 JDBCDataSource然后将其传递给 andJdbcTemplate来使两者都工作（可能） dslContext。这不是受支持的使用模式，并且可能仍然存在问题。

一旦你获得了一个连接，你自然也将负责释放它。

于 2014-01-12T21:37:40.603 回答