How to use PostgreSQLR2DBCDatabaseContainerProvider class of org.testcontainers.containers package

Best Testcontainers-java code snippet using org.testcontainers.containers.PostgreSQLR2DBCDatabaseContainerProvider

Source:PostgreSQLR2DBCDatabaseContainer.java

...9    @Delegate(types = Startable.class)10    private final PostgreSQLContainer<?> container;11    public static ConnectionFactoryOptions getOptions(PostgreSQLContainer<?> container) {12        ConnectionFactoryOptions options = ConnectionFactoryOptions.builder()13            .option(ConnectionFactoryOptions.DRIVER, PostgreSQLR2DBCDatabaseContainerProvider.DRIVER)14            .build();15        return new PostgreSQLR2DBCDatabaseContainer(container).configure(options);16    }17    @Override18    public ConnectionFactoryOptions configure(ConnectionFactoryOptions options) {19        return options.mutate()20            .option(ConnectionFactoryOptions.HOST, container.getContainerIpAddress())21            .option(ConnectionFactoryOptions.PORT, container.getMappedPort(PostgreSQLContainer.POSTGRESQL_PORT))22            .option(ConnectionFactoryOptions.DATABASE, container.getDatabaseName())23            .option(ConnectionFactoryOptions.USER, container.getUsername())24            .option(ConnectionFactoryOptions.PASSWORD, container.getPassword())25            .build();26    }27}...

PostgreSQLR2DBCDatabaseContainerProvider

Using AI Code Generation

1    void testPostgreSQLR2DBCDatabaseContainerProvider() {2        PostgreSQLR2DBCDatabaseContainer container = new PostgreSQLR2DBCDatabaseContainer();3        container.start();4        R2dbc r2dbc = R2dbc.connect(container.getR2dbcUrl(), container.getUsername(), container.getPassword());5        r2dbc.withHandle(handle ->6                handle.execute("CREATE TABLE IF NOT EXISTS test (id SERIAL PRIMARY KEY, name VARCHAR(50))")7                        .flatMap(result -> handle.execute("INSERT INTO test (name) VALUES ('test')"))8                        .flatMap(result -> handle.execute("SELECT * FROM test WHERE name = 'test'"))9                        .flatMap(result -> result.map((row, rowMetadata) -> row.get("id", Long.class)))10                        .flatMap(id -> handle.execute("DELETE FROM test WHERE id = " + id))11        ).block();12        container.stop();13    }14}

PostgreSQLR2DBCDatabaseContainerProvider

Using AI Code Generation

1public class PostgresContainerProvider implements R2DBCDatabaseContainerProvider {2    public boolean supports(String databaseType) {3        return "postgresql".equals(databaseType);4    }5    public R2DBCDatabaseContainer newInstance() {6        return new PostgreSQLR2DBCDatabaseContainer();7    }8}9public class MySQLContainerProvider implements R2DBCDatabaseContainerProvider {10    public boolean supports(String databaseType) {11        return "mysql".equals(databaseType);12    }13    public R2DBCDatabaseContainer newInstance() {14        return new MySQLR2DBCDatabaseContainer();15    }16}17public class MariaDBContainerProvider implements R2DBCDatabaseContainerProvider {18    public boolean supports(String databaseType) {19        return "mariadb".equals(databaseType);20    }21    public R2DBCDatabaseContainer newInstance() {22        return new MariaDBR2DBCDatabaseContainer();23    }24}25public class MSSQLServerContainerProvider implements R2DBCDatabaseContainerProvider {26    public boolean supports(String databaseType) {27        return "sqlserver".equals(databaseType);28    }29    public R2DBCDatabaseContainer newInstance() {30        return new MSSQLServerR2DBCDatabaseContainer();31    }32}33public class OracleContainerProvider implements R2DBCDatabaseContainerProvider {34    public boolean supports(String databaseType) {35        return "oracle".equals(databaseType);36    }37    public R2DBCDatabaseContainer newInstance() {38        return new OracleR2DBCDatabaseContainer();39    }40}41public class H2ContainerProvider implements R2DBCDatabaseContainerProvider {42    public boolean supports(String databaseType) {43        return "h2".equals(databaseType);44    }45    public R2DBCDatabaseContainer newInstance() {46        return new H2R2DBCDatabaseContainer();

PostgreSQLR2DBCDatabaseContainerProvider

Using AI Code Generation

1    val container = PostgreSQLR2DBCDatabaseContainerProvider().newInstance("postgres:13.0")2    container.start()3    val connectionFactory = container.createConnectionFactory()4    val connection = connectionFactory.create().block()5    val statement = connection.createStatement("select 1")6    val result = statement.execute().block()7    val rows = result.map { it.map { it.toString() } }8    rows.map { println(it) }9    container.stop()

PostgreSQLR2DBCDatabaseContainerProvider

Using AI Code Generation

1    static PostgreSQLR2DBCDatabaseContainerProvider provider = new PostgreSQLR2DBCDatabaseContainerProvider();2    void test() {3    }4    static PostgreSQLR2DBCDatabaseContainerProvider provider = new PostgreSQLR2DBCDatabaseContainerProvider();5    void test() {6    }7    static PostgreSQLR2DBCDatabaseContainerProvider provider = new PostgreSQLR2DBCDatabaseContainerProvider();8    void test() {9        PostgreSQLR2DBCDatabaseContainer container = provider.newInstance();10        container.start();11        R2dbc r2dbc = R2dbc.connect(ConnectionFactories.get(container.getR2dbcUrl()));12    }13    static PostgreSQLR2DBCDatabaseContainerProvider provider = new PostgreSQLR2DBCDatabaseContainerProvider();14    void test() {15        PostgreSQLR2DBCDatabaseContainer container = provider.newInstance();16        container.start();17        R2dbc r2dbc = R2dbc.connect(ConnectionFactories.get(container.getR2dbcUrl()));18    }

PostgreSQLR2DBCDatabaseContainerProvider

Using AI Code Generation

1import org.junit.jupiter.api.Test;2import org.springframework.beans.factory.annotation.Autowired;3import org.springframework.boot.test.context.SpringBootTest;4import org.springframework.r2dbc.core.DatabaseClient;5import org.springframework.transaction.annotation.Transactional;6import reactor.core.publisher.Flux;7import reactor.core.publisher.Mono;8import reactor.test.StepVerifier;9import java.util.List;10import static org.assertj.core.api.Assertions.assertThat;11class SpringBootR2dbcApplicationTests {12    private DatabaseClient databaseClient;13    private R2dbcTransactionManager transactionManager;14    void test() {15        StepVerifier.create(16                databaseClient.sql("create table user (id serial primary key, name text not null)")17                        .then()18                        .then(databaseClient.sql("insert into user (name) values ('test')")19                                .fetch()20                                .rowsUpdated())21                        .then(databaseClient.sql("select * from user")22                                .map((row, metadata) -> row.get("name", String.class))23                                .all())24                        .then(databaseClient.sql("drop table user")25                                .then()))26                .expectNext(List.of("test"))27                .expectComplete()28                .verify();29    }30    void testTransaction() {31        StepVerifier.create(32                databaseClient.sql("create table user (id serial primary key, name text not null)")33                        .then()34                        .then(databaseClient.sql("insert into user (name) values ('test')")35                                .fetch()36                                .rowsUpdated())37                        .as(transactional())38                        .then(databaseClient.sql("select * from user")39                                .map((row, metadata) -> row.get("name", String.class))40                                .all())41                        .then(databaseClient.sql("drop table user")42                                .then()))43                .expectNext(List.of("test"))44                .expectComplete()45                .verify();46    }47    private <T> Mono<T> transactional() {48        return Mono.defer(() -> transactionManager.getReactiveTransactionManager()49                .flatMap(transactionManager -> Mono.subscriberContext()50                        .flatMap(context -> {51                            var transaction = context.getOrDefault(TransactionContext.class, new TransactionContext());

PostgreSQLR2DBCDatabaseContainerProvider

Using AI Code Generation

1class PostgreSqlR2DBCContainerTest {2    static PostgreSQLContainer<?> postgreSQLContainer = new PostgreSQLContainer<>();3    static R2dbc r2dbc = R2dbc.connect(4            new PostgreSqlR2DBCDatabaseContainerProvider().create(postgreSQLContainer));5    static DatabaseClient databaseClient = DatabaseClient.create(r2dbc);6    void test() {7        databaseClient.execute("CREATE TABLE test (id SERIAL PRIMARY KEY, data VARCHAR(255))")8                .fetch()9                .rowsUpdated()10                .as(StepVerifier::create)11                .expectNextCount(1)12                .verifyComplete();13    }14}15class PostgreSqlR2DBCContainerTest {16    static PostgreSQLContainer<?> postgreSQLContainer = new PostgreSQLContainer<>();17    static R2dbc r2dbc = R2dbc.connect(18            new PostgreSQLR2DBCContainerProvider().create(postgreSQLContainer));19    static DatabaseClient databaseClient = DatabaseClient.create(r2dbc);20    void test() {21        databaseClient.execute("CREATE TABLE test (id SERIAL PRIMARY KEY, data VARCHAR(255))")22                .fetch()23                .rowsUpdated()24                .as(StepVerifier::create)25                .expectNextCount(1)26                .verifyComplete();27    }28}

PostgreSQLR2DBCDatabaseContainerProvider

Using AI Code Generation

1import org.junit.jupiter.api.Test;2import org.springframework.beans.factory.annotation.Autowired;3import org.springframework.boot.test.context.SpringBootTest;4import org.springframework.r2dbc.core.DatabaseClient;5import org.springframework.transaction.annotation.Transactional;6import reactor.core.publisher.Flux;7import reactor.core.publisher.Mono;8import reactor.test.StepVerifier;9import java.util.List;10import static org.assertj.core.api.Assertions.assertThat;11class SpringBootR2dbcApplicationTests {12    private DatabaseClient databaseClient;13    private R2dbcTransactionManager transactionManager;14    void test() {15        StepVerifier.create(16                databaseClient.sql("create table user (id serial primary key, name text not null)")17                        .then()18                        .then(databaseClient.sql("insert into user (name) values ('test')")19                                .fetch()20                                .rowsUpdated())21                        .then(databaseClient.sql("select * from user")22                                .map((row, metadata) -> row.get("name", String.class))23                                .all())24                        .then(databaseClient.sql("drop table user")25                                .then()))26                .expectNext(List.of("test"))27                .expectComplete()28                .verify();29    }30    void testTransaction() {31        StepVerifier.create(32                databaseClient.sql("create table user (id serial primary key, name text not null)")33                        .then()34                        .then(databaseClient.sql("insert into user (name) values ('test')")35                                .fetch()36                                .rowsUpdated())37                        .as(transactional())38                        .then(databaseClient.sql("select * from user")39                                .map((row, metadata) -> row.get("name", String.class))40                                .all())41                        .then(databaseClient.sql("drop table user")42                                .then()))43                .expectNext(List.of("test"))44                .expectComplete()45                .verify();46    }47    private <T> Mono<T> transactional() {48        return Mono.defer(() -> transactionManager.getReactiveTransactionManager()49                .flatMap(transactionManager -> Mono.subscriberContext()50                        .flatMap(context -> {51                            var transaction = context.getOrDefault(TransactionContext.class, new TransactionContext());

PostgreSQLR2DBCDatabaseContainerProvider

Using AI Code Generation

1class PostgreSqlR2DBCContainerTest {2    static PostgreSQLContainer<?> postgreSQLContainer = new PostgreSQLContainer<>();3    static R2dbc r2dbc = R2dbc.connect(4            new PostgreSqlR2DBCDatabaseContainerProvider().create(postgreSQLContainer));5    static DatabaseClient databaseClient = DatabaseClient.create(r2dbc);6    void test() {7        databaseClient.execute("CREATE TABLE test (id SERIAL PRIMARY KEY, data VARCHAR(255))")8                .fetch()9                .rowsUpdated()10                .as(StepVerifier::create)11                .expectNextCount(1)12                .verifyComplete();13    }14}15class PostgreSqlR2DBCContainerTest {16    static PostgreSQLContainer<?> postgreSQLContainer = new PostgreSQLContainer<>();17    static R2dbc r2dbc = R2dbc.connect(18            new PostgreSQLR2DBCContainerProvider().create(postgreSQLContainer));19    static DatabaseClient databaseClient = DatabaseClient.create(r2dbc);20    void test() {21        databaseClient.execute("CREATE TABLE test (id SERIAL PRIMARY KEY, data VARCHAR(255))")22                .fetch()23                .rowsUpdated()24                .as(StepVerifier::create)25                .expectNextCount(1)26                .verifyComplete();27    }28}29import org.junit.jupiter.api.Test;30import org.springframework.beans.factory.annotation.Autowired;31import org.springframework.boot.test.context.SpringBootTest;32import org.springframework.r2dbc.core.DatabaseClient;33import org.springframework.transaction.annotation.Transactional;34import reactor.core.publisher.Flux;35import reactor.core.publisher.Mono;36import reactor.test.StepVerifier;37import java.util.List;38import static org.assertj.core.api.Assertions.assertThat;39class SpringBootR2dbcApplicationTests {40    private DatabaseClient databaseClient;41    private R2dbcTransactionManager transactionManager;42    void test() {43        StepVerifier.create(44                databaseClient.sql("create table user (id serial primary key, name text not null)")45                        .then()46                        .then(databaseClient.sql("insert into user (name) values ('test')")47                                .fetch()48                                .rowsUpdated())49                        .then(databaseClient.sql("select * from user")50                                .map((row, metadata) -> row.get("name", String.class))51                                .all())52                        .then(databaseClient.sql("drop table user")53                                .then()))54                .expectNext(List.of("test"))55                .expectComplete()56                .verify();57    }58    void testTransaction() {59        StepVerifier.create(60                databaseClient.sql("create table user (id serial primary key, name text not null)")61                        .then()62                        .then(databaseClient.sql("insert into user (name) values ('test')")63                                .fetch()64                                .rowsUpdated())65                        .as(transactional())66                        .then(databaseClient.sql("select * from user")67                                .map((row, metadata) -> row.get("name", String.class))68                                .all())69                        .then(databaseClient.sql("drop table user")70                                .then()))71                .expectNext(List.of("test"))72                .expectComplete()73                .verify();74    }75    private <T> Mono<T> transactional() {76        return Mono.defer(() -> transactionManager.getReactiveTransactionManager()77                .flatMap(transactionManager -> Mono.subscriberContext()78                        .flatMap(context -> {79                            var transaction = context.getOrDefault(TransactionContext.class, new TransactionContext());

PostgreSQLR2DBCDatabaseContainerProvider

Using AI Code Generation

1class PostgreSqlR2DBCContainerTest {2    static PostgreSQLContainer<?> postgreSQLContainer = new PostgreSQLContainer<>();3    static R2dbc r2dbc = R2dbc.connect(4            new PostgreSqlR2DBCDatabaseContainerProvider().create(postgreSQLContainer));5    static DatabaseClient databaseClient = DatabaseClient.create(r2dbc);6    void test() {7        databaseClient.execute("CREATE TABLE test (id SERIAL PRIMARY KEY, data VARCHAR(255))")8                .fetch()9                .rowsUpdated()10                .as(StepVerifier::create)11                .expectNextCount(1)12                .verifyComplete();13    }14}15class PostgreSqlR2DBCContainerTest {16    static PostgreSQLContainer<?> postgreSQLContainer = new PostgreSQLContainer<>();17    static R2dbc r2dbc = R2dbc.connect(18            new PostgreSQLR2DBCContainerProvider().create(postgreSQLContainer));19    static DatabaseClient databaseClient = DatabaseClient.create(r2dbc);20    void test() {21        databaseClient.execute("CREATE TABLE test (id SERIAL PRIMARY KEY, data VARCHAR(255))")22                .fetch()23                .rowsUpdated()24                .as(StepVerifier::create)25                .expectNextCount(1)26                .verifyComplete();27    }28}

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.