Discover AI-native insights at Testμ Conference‘25

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}

Blogs

Check out the latest blogs from LambdaTest on this topic:

Nov’22 Updates: Live With Automation Testing On OTT Streaming Devices, Test On Samsung Galaxy Z Fold4, Galaxy Z Flip4, & More

Hola Testers! Hope you all had a great Thanksgiving weekend! To make this time more memorable, we at LambdaTest have something to offer you as a token of appreciation.

A Detailed Guide To Xamarin Testing

Xamarin is an open-source framework that offers cross-platform application development using the C# programming language. It helps to simplify your overall development and management of cross-platform software applications.

Oct’22 Updates: New Analytics And App Automation Dashboard, Test On Google Pixel 7 Series, And More

Hey everyone! We hope you had a great Hacktober. At LambdaTest, we thrive to bring you the best with each update. Our engineering and tech teams work at lightning speed to deliver you a seamless testing experience.

What Agile Testing (Actually) Is

So, now that the first installment of this two fold article has been published (hence you might have an idea of what Agile Testing is not in my opinion), I’ve started feeling the pressure to explain what Agile Testing actually means to me.

Options for Manual Test Case Development & Management

The purpose of developing test cases is to ensure the application functions as expected for the customer. Test cases provide basic application documentation for every function, feature, and integrated connection. Test case development often detects defects in the design or missing requirements early in the development process. Additionally, well-written test cases provide internal documentation for all application processing. Test case development is an important part of determining software quality and keeping defects away from customers.

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.