Join the 1-day Testing & QA Summit featuring 15+ Expert Speakers.Register for FREE! Join TestMu Conference

How to use onComplete method of org.testcontainers.r2dbc.ConnectionPublisher class

Best Testcontainers-java code snippet using org.testcontainers.r2dbc.ConnectionPublisher.onComplete

Source:TestcontainersR2DBCConnectionFactory.java

...69            CancellableSubscription subscription = new CancellableSubscription();70            s.onSubscribe(subscription);71            if (futureRef == null) {72                if (!subscription.isCancelled()) {73                    s.onComplete();74                }75            } else {76                futureRef.thenAcceptAsync(Startable::stop, EXECUTOR);77                EXECUTOR.execute(() -> {78                    futureRef.cancel(true);79                    if (!subscription.isCancelled()) {80                        s.onComplete();81                    }82                });83            }84        };85    }86}...

onComplete

Using AI Code Generation

1public class ConnectionPublisherTest {2    public void testConnectionPublisher() {3        ConnectionFactoryOptions options = ConnectionFactoryOptions.builder()4                .option(ConnectionFactoryOptions.DRIVER, "postgresql")5                .option(ConnectionFactoryOptions.HOST, "localhost")6                .option(ConnectionFactoryOptions.PORT, 5432)7                .option(ConnectionFactoryOptions.USER, "test")8                .option(ConnectionFactoryOptions.PASSWORD, "test")9                .option(ConnectionFactoryOptions.DATABASE, "test")10                .build();11        ConnectionFactory connectionFactory = ConnectionFactories.get(options);12        Connection connection = Mono.from(connectionFactory.create())13                .onErrorMap(throwable -> new RuntimeException("Unable to connect to the database", throwable))14                .block();15        assertThat(connection).isNotNull();16    }17}

onComplete

Using AI Code Generation

1import org.testcontainers.containers.PostgreSQLContainer2import org.testcontainers.r2dbc.ConnectionPublisher3import org.testcontainers.r2dbc.R2DBCDatabaseContainerProvider4import org.testcontainers.utility.DockerImageName5import org.testcontainers.r2dbc.ConnectionFactoryOptionsBuilder6import io.r2dbc.spi.ConnectionFactory7import io.r2dbc.spi.ConnectionFactories8import io.r2dbc.spi.ConnectionFactoryOptions9import io.r2dbc.spi.Connection10import io.r2dbc.spi.Result11import reactor.core.publisher.Flux12import reactor.core.publisher.Mono13import java.util.function.Consumer14public class R2DBCPostgreSQLTest {15    private final PostgreSQLContainer container = new R2DBCDatabaseContainerProvider().newInstance(16            DockerImageName.parse("postgres:13.2-alpine")17    public void test() {18        container.start()19        ConnectionFactoryOptions options = ConnectionFactoryOptionsBuilder.builder(container)20                .database()21                .username()22                .password()23                .build()24        ConnectionFactory connectionFactory = ConnectionFactories.get(options)25        Mono.from(connectionFactory.create())26                .flatMapMany { connection ->27                    return@flatMapMany Flux.from(connection.createStatement("SELECT 1").execute())28                            .flatMap { result ->29                                return@flatMap result.map { row, rowMetadata -> row.get(0) }30                            }31                            .doFinally { signalType -> connection.close() }32                }33                .as(ConnectionPublisher::from)34                .onComplete { result ->35                    println("Result: $result")36                }37                .subscribe()38    }39}

onComplete

Using AI Code Generation

1R2dbc r2dbc = R2dbc.builder()2        .connectionFactory(connectionFactory)3        .build();4r2dbc.withHandle(handle -> handle5        .createUpdate("INSERT INTO test VALUES (:id, :name)")6        .bind("id", 1)7        .bind("name", "test")8        .execute())9        .as(StepVerifier::create)10        .expectNextCount(1)11        .verifyComplete();12[INFO] --- maven-surefire-plugin:3.0.0-M5:test (default-test) @ testcontainers-r2dbc ---132021-03-29 14:03:19.942  INFO 20168 --- [           main] o.t.utility.RegistryAuthLocator          : Credential helper/store (docker-credential-desktop) does not have credentials for index.docker.io142021-03-29 14:03:19.944  INFO 20168 --- [           main] o.t.utility.RegistryAuthLocator          : Credential helper/store (docker-credential-desktop) does not have credentials for docker.io152021-03-29 14:03:19.947  INFO 20168 --- [           main] o.t.utility.RegistryAuthLocator          : Credential helper/store (docker-credential-desktop) does not have credentials for registry.hub.docker.com162021-03-29 14:03:19.949  INFO 20168 --- [           main] o.t.utility.RegistryAuthLocator          : Credential helper/store (docker-credential-desktop) does not have credentials for quay.io

onComplete

Using AI Code Generation

1import org.springframework.context.annotation.Bean;2import org.springframework.context.annotation.Configuration;3import org.testcontainers.r2dbc.ConnectionPublisher;4import org.testcontainers.r2dbc.R2dbcDatabaseContainer;5import org.testcontainers.r2dbc.R2dbcDatabaseContainerProvider;6import org.testcontainers.r2dbc.R2dbcDatabaseDelegate;7import org.testcontainers.r2dbc.R2dbcDatabaseDelegateProvider;8import org.testcontainers.r2dbc.R2dbcDatabaseDelegateProvider.R2dbcDatabaseDelegateProviderBuilder;9import org.testcontainers.r2dbc.R2dbcDatabaseDelegateProvider.R2dbcDatabaseDelegateProviderBuilder.R2dbcDatabaseDelegateBuilder;10import org.testcontainers.r2dbc.R2dbcDatabaseDelegateProvider.R2dbcDatabaseDelegateProviderBuilder.R2dbcDatabaseDelegateBuilder.R2dbcDatabaseDelegateConnectionBuilder;11import org.testcontainers.r2dbc.R2dbcDatabaseDelegateProvider.R2dbcDatabaseDelegateProviderBuilder.R2dbcDatabaseDelegateBuilder.R2dbcDatabaseDelegateConnectionBuilder.R2dbcDatabaseDelegateConnectionPublisherBuilder;12import org.testcontainers.r2dbc.R2dbcDatabaseDelegateProvider.R2dbcDatabaseDelegateProviderBuilder.R2dbcDatabaseDelegateBuilder.R2dbcDatabaseDelegateConnectionBuilder.R2dbcDatabaseDelegateConnectionPublisherBuilder.R2dbcDatabaseDelegateConnectionPublisherBuilderOnCompleteBuilder;13import org.testcontainers.r2dbc.R2dbcDatabaseDelegateProvider.R2dbcDatabaseDelegateProviderBuilder.R2dbcDatabaseDelegateBuilder.R2dbcDatabaseDelegateConnectionBuilder.R2dbcDatabaseDelegateConnectionPublisherBuilder.R2dbcDatabaseDelegateConnectionPublisherBuilderOnCompleteBuilder.R2dbcDatabaseDelegateConnectionPublisherBuilderOnCompleteBuilderOnCompleteBuilder;14import org.testcontainers.r2dbc.R2dbcDatabaseDelegateProvider.R2dbcDatabaseDelegateProviderBuilder.R2dbcDatabaseDelegateBuilder.R2dbcDatabaseDelegateConnectionBuilder.R2dbcDatabaseDelegateConnectionPublisherBuilder.R2dbcDatabaseDelegateConnectionPublisherBuilderOnCompleteBuilder.R2dbcDatabaseDelegateConnectionPublisherBuilderOnCompleteBuilderOnCompleteBuilder.R2dbcDatabaseDelegateConnectionPublisherBuilderOnCompleteBuilderOnCompleteBuilderOnCompleteBuilder;15import org.testcontainers.r2dbc.R2dbcDatabaseDelegateProvider.R2dbcDatabaseDelegateProviderBuilder.R2dbcDatabaseDelegateBuilder.R2dbcDatabaseDelegateConnectionBuilder.R2dbcDatabaseDelegateConnectionPublisherBuilder.R2dbcDatabaseDelegateConnectionPublisherBuilderOnCompleteBuilder.R2dbcDatabaseDelegateConnectionPublisherBuilderOnCompleteBuilderOnCompleteBuilder.R2dbcDatabaseDelegateConnectionPublisherBuilderOnCompleteBuilderOnCompleteBuilderOnCompleteBuilder

onComplete

Using AI Code Generation

1import org.testcontainers.r2dbc.ConnectionPublisher2import org.testcontainers.r2dbc.MysqlR2dbcDatabaseContainer3import org.testcontainers.r2dbc.R2dbcDatabaseContainerProvider4import org.testcontainers.utility.DockerImageName5import org.testcontainers.utility.TestcontainersConfiguration6import reactor.core.publisher.Flux7import reactor.core.publisher.Mono8TestcontainersConfiguration.getInstance().getEnvironmentVariables().setProperty("ryuk.container.image", "testcontainersofficial/ryuk:0.3.1")9def provider = new R2dbcDatabaseContainerProvider()10def container = provider.newInstance("mysql:8.0.23")11container.start()12def connection = container.createConnection()13def publisher = new ConnectionPublisher(connection)14def result = publisher.execute(sql)15    .onComplete {16        connection.close()17        container.stop()18    }19println(Flux.from(result).collectList().block())20import org.testcontainers.r2dbc.MysqlR2dbcDatabaseContainer21import org.testcontainers.r2dbc.R2dbcDatabaseContainerProvider22import org.testcontainers.utility.DockerImageName23import org.testcontainers.utility.TestcontainersConfiguration24import reactor.core.publisher.Flux25import reactor.core.publisher.Mono26TestcontainersConfiguration.getInstance().getEnvironmentVariables().setProperty("ryuk.container.image", "testcontainersofficial/ryuk:0.3.1")27def provider = new R2dbcDatabaseContainerProvider()28def container = provider.newInstance("mysql:8.0.23")29container.start()30def result = container.createConnection().createStatement(sql).execute()31    .map { row, _ -> row.get(0) }32println(Flux.from(result).collectList().block())33import org.testcontainers.r2dbc.MysqlR2dbcDatabaseContainer34import org.testcontainers.r2dbc.R2dbcDatabaseContainerProvider35import org.testcontainers.utility.DockerImageName36import org.testcontainers.utility.TestcontainersConfiguration37TestcontainersConfiguration.getInstance().getEnvironmentVariables().setProperty("ryuk.container.image", "testcontainersofficial/ryuk:0.3.1")

onComplete

Using AI Code Generation

1void testR2dbc() {2    try (R2dbcContainer<?> container = new R2dbcContainer<>("postgres:11.1")) {3        container.start();4        Mono<Connection> connectionMono = container.createConnection()5                .onComplete()6                .map(ConnectionPublisher::getConnection);7                .flatMap(connection -> connection.createStatement("select * from pg_tables")8                        .execute())9                .flatMap(result -> result.map((row, rowMetadata) -> row.get("tablename")))10                .subscribe(System.out::println);11    }12}13void testR2dbc() {14    try (R2dbcContainer<?> container = new R2dbcContainer<>("postgres:11.1")) {15        container.start();16        Mono<Connection> connectionMono = container.createConnection()17                .onComplete()18                .map(ConnectionPublisher::getConnection);19                .flatMap(connection -> connection.createStatement("select * from pg_tables")20                        .execute())21                .flatMap(result -> result.map((row, rowMetadata) -> row.get("tablename")))22                .subscribe(System.out::println);23    }24}25void testR2dbc() {26    try (R2dbcContainer<?> container = new R2dbcContainer<>("postgres:11.1")) {27        container.start();28        Mono<Connection> connectionMono = container.createConnection()29                .onComplete()30                .map(ConnectionPublisher::getConnection);31                .flatMap(connection -> connection.createStatement("select * from pg_tables")32                        .execute())33                .flatMap(result -> result.map((row, rowMetadata) -> row.get("tablename")))34                .subscribe(System.out::println);35    }36}

onComplete

Using AI Code Generation

1void testcontainers() {2    PostgresContainer container = new PostgresContainer()3    container.start()4    ConnectionFactory connectionFactory = ConnectionFactories.get(5            ConnectionFactoryOptions.builder()6                    .option(DRIVER, "pool")7                    .option(PROTOCOL, "postgresql")8                    .option(HOST, container.getHost())9                    .option(PORT, container.getFirstMappedPort())10                    .option(USER, container.getUsername())11                    .option(PASSWORD, container.getPassword())12                    .option(DATABASE, container.getDatabaseName())13                    .build()14    Mono.from(connectionFactory.create())15            .flatMapMany(it -> it.createStatement(query).execute())16            .flatMap(it -> it.map((row, rowMetadata) -> row.get("1", Integer.class)))17            .as(ConnectionPublisher::new)18            .onComplete {19                assertThat(it).isEqualTo(1)20            }21}22void testcontainers() {23    PostgresContainer container = new PostgresContainer()24    container.start()25    ConnectionFactory connectionFactory = ConnectionFactories.get(26            ConnectionFactoryOptions.builder()27                    .option(DRIVER, "pool")28                    .option(PROTOCOL, "postgresql")29                    .option(HOST, container.getHost())30                    .option(PORT, container.getFirstMappedPort())31                    .option(USER, container.getUsername())32                    .option(PASSWORD, container.getPassword())33                    .option(DATABASE, container.getDatabaseName())34                    .build()35    Mono.from(connectionFactory

onComplete

Using AI Code Generation

1        Mono<Connection> conn cuionMono =sconeainer.createConnection()2                .onComplete()3                .map(ConnectionPublisher::getConnection);4                .flatMap(connection -> connection.createStatement("select * from pg_tables")5                        .execute())6                .flatMap(result -> result.map((row, rowMetadata) -> row.get("tablename")))7                .subscribe(System.out::println);8    }9}10void testR2dbc() {11    try (R2dbcContainer<?> container = new R2dbcContainer<>("postgres:11.1")) {12        container.start();13        Mono<Connection> connectionMono = container.createConnection()14                .onComplete()15                .map(ConnectionPublisher::getConnection);16                .flatMap(connection -> connection.createStatement("select * from pg_tables")17                        .execute())18                .flatMap(result -> result.map((row, rowMetadata) -> row.get("tablename")))19                .subscribe(System.out::println);20    }21}22void testR2dbc() {23    try (R2dbcContainer<?> container = new R2dbcContainer<>("postgres:11.1")) {24        container.start();25        Mono<Connection> connectionMono = container.createConnection()26                .onComplete()27                .map(ConnectionPublisher::getConnection);28                .flatMap(connection -> connection.createStatement("select * from pg_tables")29                        .execute())30                .flatMap(result -> result.map((row, rowMetadata) -> row.get("tablename")))31                .subscribe(System.out::println);32    }33}

onComplete

Using AI Code Generation

1void testcontainers() {2    PostgresContainer container = new PostgresContainer()3    container.start()4    ConnectionFactory connectionFactory = ConnectionFactories.get(5            ConnectionFactoryOptions.builder()6                    .option(DRIVER, "pool")7                    .option(PROTOCOL, "postgresql")8                    .option(HOST, container.getHost())9                    .option(PORT, container.getFirstMappedPort())10                    .option(USER, container.getUsername())11                    .option(PASSWORD, container.getPassword())12                    .option(DATABASE, container.getDatabaseName())13                    .build()14    Mono.from(connectionFactory.create())15            .flatMapMany(it -> it.createStatement(query).execute())16            .flatMap(it -> it.map((row, rowMetadata) -> row.get("1", Integer.class)))17            .as(ConnectionPublisher::new)18            .onComplete {19                assertThat(it).isEqualTo(1)20            }21}22void testcontainers() {23    PostgresContainer container = new PostgresContainer()24    container.start()25    ConnectionFactory connectionFactory = ConnectionFactories.get(26            ConnectionFactoryOptions.builder()27                    .option(DRIVER, "pool")28                    .option(PROTOCOL, "postgresql")29                    .option(HOST, container.getHost())30                    .option(PORT, container.getFirstMappedPort())31                    .option(USER, container.getUsername())32                    .option(PASSWORD, container.getPassword())33                    .option(DATABASE, container.getDatabaseName())34                    .build()35    Mono.from(connectionFactory

onComplete

Using AI Code Generation

1R2dbc r2dbc = R2dbc.builder()2        .connectionFactory(connectionFactory)3        .build();4r2dbc.withHandle(handle -> handle5        .createUpdate("INSERT INTO test VALUES (:id, :name)")6        .bind("id", 1)7        .bind("name", "test")8        .execute())9        .as(StepVerifier::create)10        .expectNextCount(1)11        .verifyComplete();12[INFO] --- maven-surefire-plugin:3.0.0-M5:test (default-test) @ testcontainers-r2dbc ---132021-03-29 14:03:19.942  INFO 20168 --- [           main] o.t.utility.RegistryAuthLocator          : Credential helper/store (docker-credential-desktop) does not have credentials for index.docker.io142021-03-29 14:03:19.944  INFO 20168 --- [           main] o.t.utility.RegistryAuthLocator          : Credential helper/store (docker-credential-desktop) does not have credentials for docker.io152021-03-29 14:03:19.947  INFO 20168 --- [           main] o.t.utility.RegistryAuthLocator          : Credential helper/store (docker-credential-desktop) does not have credentials for registry.hub.docker.com162021-03-29 14:03:19.949  INFO 20168 --- [           main] o.t.utility.RegistryAuthLocator          : Credential helper/store (docker-credential-desktop) does not have credentials for quay.io

onComplete

Using AI Code Generation

1import org.testcontainers.r2dbc.ConnectionPublisher2import org.testcontainers.r2dbc.MysqlR2dbcDatabaseContainer3import org.testcontainers.r2dbc.R2dbcDatabaseContainerProvider4import org.testcontainers.utility.DockerImageName5import org.testcontainers.utility.TestcontainersConfiguration6import reactor.core.publisher.Flux7import reactor.core.publisher.Mono8TestcontainersConfiguration.getInstance().getEnvironmentVariables().setProperty("ryuk.container.image", "testcontainersofficial/ryuk:0.3.1")9def provider = new R2dbcDatabaseContainerProvider()10def container = provider.newInstance("mysql:8.0.23")11container.start()12def connection = container.createConnection()13def publisher = new ConnectionPublisher(connection)14def result = publisher.execute(sql)15    .onComplete {16        connection.close()17        container.stop()18    }19println(Flux.from(result).collectList().block())20import org.testcontainers.r2dbc.MysqlR2dbcDatabaseContainer21import org.testcontainers.r2dbc.R2dbcDatabaseContainerProvider22import org.testcontainers.utility.DockerImageName23import org.testcontainers.utility.TestcontainersConfiguration24import reactor.core.publisher.Flux25import reactor.core.publisher.Mono26TestcontainersConfiguration.getInstance().getEnvironmentVariables().setProperty("ryuk.container.image", "testcontainersofficial/ryuk:0.3.1")27def provider = new R2dbcDatabaseContainerProvider()28def container = provider.newInstance("mysql:8.0.23")29container.start()30def result = container.createConnection().createStatement(sql).execute()31    .map { row, _ -> row.get(0) }32println(Flux.from(result).collectList().block())33import org.testcontainers.r2dbc.MysqlR2dbcDatabaseContainer34import org.testcontainers.r2dbc.R2dbcDatabaseContainerProvider35import org.testcontainers.utility.DockerImageName36import org.testcontainers.utility.TestcontainersConfiguration37TestcontainersConfiguration.getInstance().getEnvironmentVariables().setProperty("ryuk.container.image", "testcontainersofficial/ryuk:0.3.1")

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.