带有弹簧靴的Jooq不插入实体

Question

除非存储库带有@transactional ，否则我面临着JOOQ不会插入实体的问题。

这是我的配置：

@Configuration
@EnableTransactionManagement
@RequiredArgsConstructor
public class PersistenceConfig {

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

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

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

    @Bean
    @SneakyThrows
    public DataSource dataSource() {
        HikariConfig config = new HikariConfig();

        // https://mariadb.com/kb/en/about-mariadb-connector-j/
        config.setDriverClassName(DatabaseDriver.MARIADB.getDriverClassName());
        config.setJdbcUrl(dbUrl);
        config.setUsername(dbUser);
        config.setPassword(dbPassword);
        config.setAutoCommit(false);

        // https://github.com/brettwooldridge/HikariCP/wiki/MySQL-Configuration
        config.addDataSourceProperty("cacheServerConfiguration", true);
        config.addDataSourceProperty("useServerPrepStmts", true);
        config.addDataSourceProperty("useLocalSessionState", true);
        config.addDataSourceProperty("cacheResultSetMetadata", true);
        config.addDataSourceProperty("rewriteBatchedStatements", true);
        config.addDataSourceProperty("elideSetAutoCommits", true);
        config.addDataSourceProperty("maintainTimeStats", false);
        config.addDataSourceProperty("cachePrepStmts", true);
        config.addDataSourceProperty("prepStmtCacheSize", 350);
        config.addDataSourceProperty("prepStmtCacheSqlLimit", 2048);

        return new HikariDataSource(config);
    }

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

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

    @Bean
    public DataSourceConnectionProvider connectionProvider() {
        return new DataSourceConnectionProvider(transactionAwareDataSource());
    }

    @Bean
    public ExceptionTranslator exceptionTransformer() {
        return new ExceptionTranslator();
    }

    @Bean
    public SpringTransactionProvider springTransactionProvider() {
        return new SpringTransactionProvider(transactionManager());
    }

    @Bean
    public DefaultConfiguration configuration() {
        DefaultConfiguration jooqConfiguration = new DefaultConfiguration();

        jooqConfiguration.set(connectionProvider());
        jooqConfiguration.set(new DefaultExecuteListenerProvider(exceptionTransformer()));
        jooqConfiguration.set(SQLDialect.MARIADB);
        jooqConfiguration.set(springTransactionProvider());

        return jooqConfiguration;
    }

    @Bean
    public DefaultDSLContext dsl() {
        return new DefaultDSLContext(configuration());
    }

    @Bean
    public TransactionTemplate transactionTemplate() {
        return new TransactionTemplate(transactionManager());
    }

    private static class ExceptionTranslator extends DefaultExecuteListener {
        public void exception(ExecuteContext context) {
            SQLDialect dialect = context.configuration().dialect();
            SQLExceptionTranslator translator
                = new SQLErrorCodeSQLExceptionTranslator(dialect.name());
            context.exception(translator
                .translate("Access database using jOOQ", context.sql(), context.sqlException()));
        }
    }

}

存储库：

@Repository
public class UserRepository extends UserDao {

    private final DSLContext dslContext;

    public UserRepository(DSLContext dslContext) {
        super(dslContext.configuration());
        this.dslContext = dslContext;
    }
}

因此，调用userRepository.insert（...）实际上未插入数据库中，尽管日志表示以下内容：

org.jooq.tools.LoggerListener            : Executing query          : insert into `user` (...)
org.jooq.tools.LoggerListener            : -> with bind values      : insert into `user` ...

但是，如果我超载 userdao <> userdao <> /strong>的插入方法并用@transacational 对其进行注释 - 它有效，行实际上被插入。我想我已经错过了一些东西。

使用JOOQ引导启动器的弹簧启动。

Answer 1

问题实际上是setautocommit（false）。