java - 与 JOOQ 结合使用声明式事务和 TransactionAwareDataSourceProxy 的问题

Question

我有一个数据源配置类，如下所示，带有单独的 DataSource使用 JOOQ 用于测试和非测试环境的 beans。在我的代码中，我不使用 DSLContext.transaction(ctx -> {...}而是将该方法标记为事务性的，以便 JOOQ 遵从 Spring 的声明性事务的事务性。我正在使用 Spring 4.3.7.RELEASE。

我有以下问题:

• 在测试期间 (JUnit)，@Transactional按预期工作。无论我使用 DSLContext 多少次，单个方法都是事务性的的 store()方法，以及 RuntimeException触发整个事务的回滚。
• 在实际生产运行期间，@Transactional被完全忽略。方法不再是事务性的，并且 TransactionSynchronizationManager.getResourceMap()包含两个独立的值:一个显示给我的连接池(不是事务)，另一个显示 TransactionAwareDataSourceProxy ).

在这种情况下，我希望只有一个 TransactionAwareDataSourceProxy 类型的资源它包装了我的 DB CP。

• 在使用我所做的第二组配置更改(在下面用“AFTER”注明)进行多次试验和错误后，@Transactional尽管 TransactionSynchronizationManager.getResourceMap()，即使在运行时也能按预期正常工作具有以下值:

在这种情况下，我的 DataSourceTransactionManager似乎连TransactionAwareDataSourceProxy都不知道(很可能是因为我将简单的 DataSource 传递给它，而不是代理对象)，这似乎完全“跳过”了代理。

我的问题是:我的初始配置似乎是正确的，但没有用。提议的“修复”有效，但 IMO 根本不起作用(因为事务管理器似乎没有意识到 TransactionAwareDataSourceProxy )。

这是怎么回事？是否有更简洁的方法来解决此问题？

之前(在运行时不是事务性的)

@Configuration
@EnableTransactionManagement
@RefreshScope
@Slf4j
public class DataSourceConfig {

    @Bean
    @Primary
    public DSLContext dslContext(org.jooq.Configuration configuration) throws SQLException {
        return new DefaultDSLContext(configuration);
    }

    @Bean
    @Primary
    public org.jooq.Configuration defaultConfiguration(DataSourceConnectionProvider dataSourceConnectionProvider) {
        org.jooq.Configuration configuration = new DefaultConfiguration()
            .derive(dataSourceConnectionProvider)
            .derive(SQLDialect.POSTGRES_9_5);
        configuration.set(new DeleteOrUpdateWithoutWhereListener());
        return configuration;
    }

    @Bean
    public DataSourceTransactionManager transactionManager(DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }

    @Bean
    public DataSourceConnectionProvider dataSourceConnectionProvider(DataSource dataSource) {
        return new DataSourceConnectionProvider(dataSource);
    }

    @Configuration
    @ConditionalOnClass(EmbeddedPostgres.class)
    static class EmbeddedDataSourceConfig {

        @Value("${spring.jdbc.port}")
        private int dbPort;

        @Bean(destroyMethod = "close")
        public EmbeddedPostgres embeddedPostgres() throws Exception {
            EmbeddedPostgres embeddedPostgres = EmbeddedPostgresHelper.startDatabase(dbPort);
            return embeddedPostgres;
        }

        @Bean
        @Primary
        public DataSource dataSource(EmbeddedPostgres embeddedPostgres) throws Exception {
            DataSource dataSource = embeddedPostgres.getPostgresDatabase();
            return new TransactionAwareDataSourceProxy(dataSource);
        }
    }

    @Configuration
    @ConditionalOnMissingClass("com.opentable.db.postgres.embedded.EmbeddedPostgres")
    @RefreshScope
    static class DefaultDataSourceConfig {

        @Value("${spring.jdbc.url}")
        private String url;

        @Value("${spring.jdbc.username}")
        private String username;

        @Value("${spring.jdbc.password}")
        private String password;

        @Value("${spring.jdbc.driverClass}")
        private String driverClass;

        @Value("${spring.jdbc.MaximumPoolSize}")
        private Integer maxPoolSize;

        @Bean
        @Primary
        @RefreshScope
        public DataSource dataSource() {
            log.debug("Connecting to datasource: {}", url);
            HikariConfig hikariConfig = buildPool();
            DataSource dataSource = new HikariDataSource(hikariConfig);
            return new TransactionAwareDataSourceProxy(dataSource);
        }

        private HikariConfig buildPool() {
            HikariConfig config = new HikariConfig();
            config.setJdbcUrl(url);
            config.setUsername(username);
            config.setPassword(password);
            config.setDriverClassName(driverClass);
            config.setConnectionTestQuery("SELECT 1");
            config.setMaximumPoolSize(maxPoolSize);

            return config;
        }
    }

AFTER(如预期的那样，在运行时是事务性的，所有未列出的 bean 与上面相同)

@Configuration
@EnableTransactionManagement
@RefreshScope
@Slf4j
public class DataSourceConfig {

    @Bean
    public DataSourceConnectionProvider dataSourceConnectionProvider(TransactionAwareDataSourceProxy dataSourceProxy) {
        return new DataSourceConnectionProvider(dataSourceProxy);
    }

    @Bean
    public TransactionAwareDataSourceProxy transactionAwareDataSourceProxy(DataSource dataSource) {
        return new TransactionAwareDataSourceProxy(dataSource);
    }

    @Configuration
    @ConditionalOnMissingClass("com.opentable.db.postgres.embedded.EmbeddedPostgres")
    @RefreshScope
    static class DefaultDataSourceConfig {

        @Value("${spring.jdbc.url}")
        private String url;

        @Value("${spring.jdbc.username}")
        private String username;

        @Value("${spring.jdbc.password}")
        private String password;

        @Value("${spring.jdbc.driverClass}")
        private String driverClass;

        @Value("${spring.jdbc.MaximumPoolSize}")
        private Integer maxPoolSize;

        @Bean
        @Primary
        @RefreshScope
        public DataSource dataSource() {
            log.debug("Connecting to datasource: {}", url);
            HikariConfig hikariConfig = buildPoolConfig();
            DataSource dataSource = new HikariDataSource(hikariConfig);
            return dataSource; // not returning the proxy here
        }
    }
}

Answer 1

我会将我的评论变成答案。

事务管理器不应该知道代理。来自documentation :

Note that the transaction manager, for example DataSourceTransactionManager, still needs to work with the underlying DataSource, not with this proxy.

类 TransactionAwareDataSourceProxy 是一个特殊用途的类，在大多数情况下不需要。任何通过 Spring 框架基础设施与您的数据源接口(interface)的东西都不应该在其访问链中有代理。该代理适用于无法与 Spring 基础设施交互的代码。例如，已经设置为使用 JDBC 并且不接受任何 Spring 的 JDBC 模板的第三方库。这在与上述相同的文档中说明:

This proxy allows data access code to work with the plain JDBC API and still participate in Spring-managed transactions, similar to JDBC code in a J2EE/JTA environment. However, if possible, use Spring's DataSourceUtils, JdbcTemplate or JDBC operation objects to get transaction participation even without a proxy for the target DataSource, avoiding the need to define such a proxy in the first place.

如果您没有任何需要绕过 Spring 框架的代码，那么根本不要使用 TransactionAwareDataSourceProxy。如果您确实有这样的遗留代码，那么您将需要执行您在第二个设置中已经配置的操作。您将需要创建两个 bean，一个是数据源，一个是代理。然后，您应该将数据源提供给所有 Spring 托管类型，并将代理提供给遗留类型。