mirror of
https://github.com/spring-projects/spring-boot.git
synced 2024-08-29 03:06:45 +08:00
Auto-configure jOOQ with TransactionListenerProvider
Closes gh-13331
This commit is contained in:
parent
0df37b917b
commit
20003489be
@ -24,6 +24,7 @@ import org.jooq.ExecuteListenerProvider;
|
||||
import org.jooq.RecordListenerProvider;
|
||||
import org.jooq.RecordMapperProvider;
|
||||
import org.jooq.RecordUnmapperProvider;
|
||||
import org.jooq.TransactionListenerProvider;
|
||||
import org.jooq.TransactionProvider;
|
||||
import org.jooq.VisitListenerProvider;
|
||||
import org.jooq.conf.Settings;
|
||||
@ -51,6 +52,7 @@ import org.springframework.transaction.PlatformTransactionManager;
|
||||
*
|
||||
* @author Andreas Ahlenstorf
|
||||
* @author Michael Simons
|
||||
* @author Dmytro Nosan
|
||||
* @since 1.3.0
|
||||
*/
|
||||
@Configuration
|
||||
@ -105,6 +107,8 @@ public class JooqAutoConfiguration {
|
||||
|
||||
private final VisitListenerProvider[] visitListenerProviders;
|
||||
|
||||
private final TransactionListenerProvider[] transactionListenerProviders;
|
||||
|
||||
public DslContextConfiguration(JooqProperties properties,
|
||||
ConnectionProvider connectionProvider, DataSource dataSource,
|
||||
ObjectProvider<TransactionProvider> transactionProvider,
|
||||
@ -113,7 +117,8 @@ public class JooqAutoConfiguration {
|
||||
ObjectProvider<Settings> settings,
|
||||
ObjectProvider<RecordListenerProvider[]> recordListenerProviders,
|
||||
ExecuteListenerProvider[] executeListenerProviders,
|
||||
ObjectProvider<VisitListenerProvider[]> visitListenerProviders) {
|
||||
ObjectProvider<VisitListenerProvider[]> visitListenerProviders,
|
||||
ObjectProvider<TransactionListenerProvider[]> transactionListenerProviders) {
|
||||
this.properties = properties;
|
||||
this.connection = connectionProvider;
|
||||
this.dataSource = dataSource;
|
||||
@ -124,6 +129,8 @@ public class JooqAutoConfiguration {
|
||||
this.recordListenerProviders = recordListenerProviders.getIfAvailable();
|
||||
this.executeListenerProviders = executeListenerProviders;
|
||||
this.visitListenerProviders = visitListenerProviders.getIfAvailable();
|
||||
this.transactionListenerProviders = transactionListenerProviders
|
||||
.getIfAvailable();
|
||||
}
|
||||
|
||||
@Bean
|
||||
@ -152,6 +159,8 @@ public class JooqAutoConfiguration {
|
||||
configuration.set(this.recordListenerProviders);
|
||||
configuration.set(this.executeListenerProviders);
|
||||
configuration.set(this.visitListenerProviders);
|
||||
configuration
|
||||
.setTransactionListenerProvider(this.transactionListenerProviders);
|
||||
return configuration;
|
||||
}
|
||||
|
||||
|
@ -30,6 +30,8 @@ import org.jooq.RecordType;
|
||||
import org.jooq.RecordUnmapper;
|
||||
import org.jooq.RecordUnmapperProvider;
|
||||
import org.jooq.SQLDialect;
|
||||
import org.jooq.TransactionListener;
|
||||
import org.jooq.TransactionListenerProvider;
|
||||
import org.jooq.TransactionalRunnable;
|
||||
import org.jooq.VisitListener;
|
||||
import org.jooq.VisitListenerProvider;
|
||||
@ -56,6 +58,7 @@ import static org.junit.Assert.fail;
|
||||
* @author Phillip Webb
|
||||
* @author Andy Wilkinson
|
||||
* @author Stephane Nicoll
|
||||
* @author Dmytro Nosan
|
||||
*/
|
||||
public class JooqAutoConfigurationTests {
|
||||
|
||||
@ -137,8 +140,8 @@ public class JooqAutoConfigurationTests {
|
||||
this.contextRunner.withUserConfiguration(JooqDataSourceConfiguration.class,
|
||||
TxManagerConfiguration.class, TestRecordMapperProvider.class,
|
||||
TestRecordUnmapperProvider.class, TestRecordListenerProvider.class,
|
||||
TestExecuteListenerProvider.class, TestVisitListenerProvider.class)
|
||||
.run((context) -> {
|
||||
TestExecuteListenerProvider.class, TestVisitListenerProvider.class,
|
||||
TestTransactionListenerProvider.class).run((context) -> {
|
||||
DSLContext dsl = context.getBean(DSLContext.class);
|
||||
assertThat(dsl.configuration().recordMapperProvider().getClass())
|
||||
.isEqualTo(TestRecordMapperProvider.class);
|
||||
@ -150,6 +153,8 @@ public class JooqAutoConfigurationTests {
|
||||
.isEqualTo(2);
|
||||
assertThat(dsl.configuration().visitListenerProviders().length)
|
||||
.isEqualTo(1);
|
||||
assertThat(dsl.configuration().transactionListenerProviders().length)
|
||||
.isEqualTo(1);
|
||||
});
|
||||
}
|
||||
|
||||
@ -273,4 +278,14 @@ public class JooqAutoConfigurationTests {
|
||||
|
||||
}
|
||||
|
||||
protected static class TestTransactionListenerProvider
|
||||
implements TransactionListenerProvider {
|
||||
|
||||
@Override
|
||||
public TransactionListener provide() {
|
||||
return null;
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
|
@ -3777,6 +3777,7 @@ following jOOQ Types:
|
||||
* `RecordListenerProvider`
|
||||
* `ExecuteListenerProvider`
|
||||
* `VisitListenerProvider`
|
||||
* `TransactionListenerProvider`
|
||||
|
||||
You can also create your own `org.jooq.Configuration` `@Bean` if you want to take
|
||||
complete control of the jOOQ configuration.
|
||||
|
Loading…
Reference in New Issue
Block a user