Configure jOOQ with TransactionProvider bean when available

See gh-33979
spring-projects · Feb 1, 2023 · b2a8c8b · b2a8c8b
1 parent b28369d
commit b2a8c8b
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 1 deletion.
diff --git a/...gure/src/main/java/org/springframework/boot/autoconfigure/jooq/JooqAutoConfiguration.java b/...gure/src/main/java/org/springframework/boot/autoconfigure/jooq/JooqAutoConfiguration.java
@@ -87,11 +87,13 @@ public DefaultDSLContext dslContext(org.jooq.Configuration configuration) {
 		@Bean
 		@ConditionalOnMissingBean(org.jooq.Configuration.class)
 		public DefaultConfiguration jooqConfiguration(JooqProperties properties, ConnectionProvider connectionProvider,
-				DataSource dataSource, ObjectProvider<ExecuteListenerProvider> executeListenerProviders,
+				DataSource dataSource, ObjectProvider<TransactionProvider> transactionProvider,
+				ObjectProvider<ExecuteListenerProvider> executeListenerProviders,
 				ObjectProvider<DefaultConfigurationCustomizer> configurationCustomizers) {
 			DefaultConfiguration configuration = new DefaultConfiguration();
 			configuration.set(properties.determineSqlDialect(dataSource));
 			configuration.set(connectionProvider);
+			transactionProvider.ifAvailable(configuration::set);
 			configuration.set(executeListenerProviders.orderedStream().toArray(ExecuteListenerProvider[]::new));
 			configurationCustomizers.orderedStream().forEach((customizer) -> customizer.customize(configuration));
 			return configuration;

diff --git a/...src/test/java/org/springframework/boot/autoconfigure/jooq/JooqAutoConfigurationTests.java b/...src/test/java/org/springframework/boot/autoconfigure/jooq/JooqAutoConfigurationTests.java
@@ -113,6 +113,17 @@ void jooqWithDefaultConnectionProvider() {
 		});
 	}
 
+	@Test
+	void jooqWithDefaultTransactionProvider() {
+		this.contextRunner.withUserConfiguration(JooqDataSourceConfiguration.class, TxManagerConfiguration.class)
+				.run((context) -> {
+					DSLContext dsl = context.getBean(DSLContext.class);
+					TransactionProvider expectedTransactionProvider = context.getBean(TransactionProvider.class);
+					TransactionProvider transactionProvider = dsl.configuration().transactionProvider();
+					assertThat(transactionProvider).isSameAs(expectedTransactionProvider);
+				});
+	}
+
 	@Test
 	void jooqWithDefaultExecuteListenerProvider() {
 		this.contextRunner.withUserConfiguration(JooqDataSourceConfiguration.class).run((context) -> {