Add getR2dbcUrl to postgres

Author: jan-knoblich

modules/postgresql/src/main/java/org/testcontainers/postgresql/PostgreSQLR2DBCDatabaseContainer.java

@@ -24,6 +24,24 @@ public static ConnectionFactoryOptions getOptions(PostgreSQLContainer container)
         return new PostgreSQLR2DBCDatabaseContainer(container).configure(options);
     }
 
+    /**
+     * Returns the R2DBC URL for connecting to the PostgreSQL database.
+     *
+     * @param container the PostgreSQL container instance
+     * @return the R2DBC URL in the format: r2dbc:postgresql://username:password@host:port/database
+     */
+    public static String getR2dbcUrl(PostgreSQLContainer container) {
+        return String.format(
+            "r2dbc:%s://%s:%s@%s:%d/%s",
+            PostgresqlConnectionFactoryProvider.POSTGRESQL_DRIVER,
+            container.getUsername(),
+            container.getPassword(),
+            container.getHost(),
+            container.getMappedPort(PostgreSQLContainer.POSTGRESQL_PORT),
+            container.getDatabaseName()
+        );
+    }
+
     @Override
     public ConnectionFactoryOptions configure(ConnectionFactoryOptions options) {
         return options
@@ -55,4 +73,9 @@ public void stop() {
     public void close() {
         this.container.close();
     }
+
+    @Override
+    public String getR2dbcUrl() {
+        return getR2dbcUrl(this.container);
+    }
 }

modules/postgresql/src/test/java/org/testcontainers/postgresql/PostgreSQLR2DBCDatabaseContainerTest.java

@@ -27,4 +27,39 @@ protected ConnectionFactoryOptions getOptions(PostgreSQLContainer container) {
     protected String createR2DBCUrl() {
         return "r2dbc:tc:postgresql:///db?TC_IMAGE_TAG=10-alpine";
     }
+
+    @org.junit.jupiter.api.Test
+    void testGetR2dbcUrl() {
+        try (PostgreSQLContainer container = createContainer()) {
+            container.start();
+
+            // Test static method
+            String r2dbcUrlStatic = PostgreSQLR2DBCDatabaseContainer.getR2dbcUrl(container);
+
+            org.assertj.core.api.Assertions.assertThat(r2dbcUrlStatic).isNotNull();
+            org.assertj.core.api.Assertions.assertThat(r2dbcUrlStatic).startsWith("r2dbc:postgresql://");
+            org.assertj.core.api.Assertions.assertThat(r2dbcUrlStatic).contains(container.getHost());
+            org.assertj.core.api.Assertions.assertThat(r2dbcUrlStatic).contains(String.valueOf(container.getMappedPort(PostgreSQLContainer.POSTGRESQL_PORT)));
+            org.assertj.core.api.Assertions.assertThat(r2dbcUrlStatic).contains(container.getDatabaseName());
+            org.assertj.core.api.Assertions.assertThat(r2dbcUrlStatic).contains(container.getUsername());
+            org.assertj.core.api.Assertions.assertThat(r2dbcUrlStatic).contains(container.getPassword());
+
+            // Verify the format: r2dbc:postgresql://username:password@host:port/database
+            String expectedUrl = String.format(
+                "r2dbc:postgresql://%s:%s@%s:%d/%s",
+                container.getUsername(),
+                container.getPassword(),
+                container.getHost(),
+                container.getMappedPort(PostgreSQLContainer.POSTGRESQL_PORT),
+                container.getDatabaseName()
+            );
+            org.assertj.core.api.Assertions.assertThat(r2dbcUrlStatic).isEqualTo(expectedUrl);
+
+            // Test instance method
+            PostgreSQLR2DBCDatabaseContainer r2dbcContainer = new PostgreSQLR2DBCDatabaseContainer(container);
+            String r2dbcUrlInstance = r2dbcContainer.getR2dbcUrl();
+
+            org.assertj.core.api.Assertions.assertThat(r2dbcUrlInstance).isEqualTo(r2dbcUrlStatic);
+        }
+    }
 }