我正在使用Spring batch并尝试使用两个"ORM"框架构建TASKLET:使用 jdbcTemplate 进行简单查询,使用 JOOQ 框架进行更复杂的查询。
这是 spring 配置的一部分:
<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处初始化我的ORMs:
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使用了一些棘手的tansaction管理器,如果"编写器"无法完成所有操作,则女巫回滚所有操作。但是,如何将另一个框架与单个事务管理器同步呢?
通常预期的行为是您在JdbcTemplate
和dslContext
之间观察到的行为:每个都从DataSource
获取单独的数据库连接。
您的第一个发现,有两个JdbcTemplate
实例,是JdbcTemplate
必须专门设计的特殊行为。显然,它的所有实例在内部共享相同的连接。
您可以通过首先从DataSource
获取 JDBC Connection
,然后将其传递给JdbcTemplate
和dslContext
来使这两个工作(可能)。这不是受支持的使用模式,可能仍然存在问题。
一旦你获得了连接,自然你也会负责释放它。