Do not block indefinitely when querying SQL database

Author: wilkinsona

spring-boot-project/spring-boot-docker-compose/src/test/java/org/springframework/boot/docker/compose/service/connection/oracle/OracleR2dbcDockerComposeConnectionDetailsFactoryIntegrationTests.java

@@ -16,6 +16,8 @@
 
 package org.springframework.boot.docker.compose.service.connection.oracle;
 
+import java.time.Duration;
+
 import io.r2dbc.spi.ConnectionFactories;
 import io.r2dbc.spi.ConnectionFactoryOptions;
 import org.junit.jupiter.api.Test;
@@ -49,7 +51,7 @@ void runCreatesConnectionDetailsThatCanBeUsedToAccessDatabase() {
 			.sql(DatabaseDriver.ORACLE.getValidationQuery())
 			.map((row, metadata) -> row.get(0))
 			.first()
-			.block();
+			.block(Duration.ofSeconds(30));
 		assertThat(result).isEqualTo("Hello");
 	}
 

spring-boot-project/spring-boot-docker-compose/src/test/java/org/springframework/boot/docker/compose/service/connection/sqlserver/SqlServerR2dbcDockerComposeConnectionDetailsFactoryIntegrationTests.java

@@ -16,6 +16,8 @@
 
 package org.springframework.boot.docker.compose.service.connection.sqlserver;
 
+import java.time.Duration;
+
 import io.r2dbc.spi.ConnectionFactories;
 import io.r2dbc.spi.ConnectionFactoryOptions;
 import org.junit.jupiter.api.Test;
@@ -50,7 +52,7 @@ void runCreatesConnectionDetailsThatCanBeUsedToAccessDatabase() {
 			.sql(DatabaseDriver.SQLSERVER.getValidationQuery())
 			.map((row, metadata) -> row.get(0))
 			.first()
-			.block();
+			.block(Duration.ofSeconds(30));
 		assertThat(result).isEqualTo(1);
 	}
 

spring-boot-project/spring-boot-testcontainers/src/test/java/org/springframework/boot/testcontainers/service/connection/r2dbc/OracleR2dbcContainerConnectionDetailsFactoryTests.java

@@ -16,6 +16,8 @@
 
 package org.springframework.boot.testcontainers.service.connection.r2dbc;
 
+import java.time.Duration;
+
 import io.r2dbc.spi.ConnectionFactory;
 import org.junit.jupiter.api.Test;
 import org.testcontainers.containers.OracleContainer;
@@ -56,7 +58,7 @@ void connectionCanBeMadeToOracleContainer() {
 			.sql(DatabaseDriver.ORACLE.getValidationQuery())
 			.map((row, metadata) -> row.get(0))
 			.first()
-			.block();
+			.block(Duration.ofSeconds(30));
 		assertThat(result).isEqualTo("Hello");
 	}