Как синхронизировать JOOQ с SpringBatch JdbcTemplate

Question

Я работаю с пакетом Spring и пытаюсь построить TASKLET с двумя средами ORM: используйте 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>

Я инициализирую мои ORM в сеттере в com.myexample.writer.JdbcSequenceWriter:

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', и найти эту запись, используя SELECT с 'jdbcTemplate2'. Но если попытаться вставить запись с помощью любого jdbcTemplate и найти ее с помощью dslContext (JOOQ ORM), у меня будет пустой результат. Я понимаю, что Spring Batch использует какой-то хитрый менеджер транзакций, который откатит все операции, если "писатель" не сможет завершить все свои операции. Но как я могу синхронизировать другую структуру с одним менеджером транзакций?

Answer 1

Общее ожидаемое поведение - это то, что вы наблюдаете между JdbcTemplate а также dslContext: каждый получает отдельное соединение с БД от DataSource,

Ваша первая находка, с двумя JdbcTemplate экземпляры, это особое поведение, которое JdbcTemplate должен был быть специально разработан для. По-видимому, все его экземпляры имеют одно и то же внутреннее соединение.

Вы можете заставить оба работать (вероятно), сначала приобретая JDBC Connection от DataSource а затем передать его как JdbcTemplate а также dslContext, Это не поддерживаемый шаблон использования, и с ним все еще могут быть проблемы.

После того, как вы приобрели соединение, естественно, вы также будете отвечать за его освобождение.