Add ConnectionFactory option for binaryTransfer

[resolves #160]

Author: mp911de

README.md

@@ -75,6 +75,7 @@ Mono<Connection> connectionMono = Mono.from(connectionFactory.create());
 | `database`        | Database to select. _(Optional)_
 | `applicationName` | The name of the application connecting to the database.  Defaults to `r2dbc-postgresql`. _(Optional)_
 | `autodetectExtensions` | Whether to auto-detect and register `Extension`s from the class path.  Defaults to `true`. _(Optional)_
+| `forceBinary`     | Whether to force binary transfer.  Defaults to `false`. _(Optional)_
 | `options`         | A `Map<String, String>` of connection parameters. These are applied to each database connection created by the `ConnectionFactory`. Useful for setting generic [PostgreSQL connection parameters][psql-runtime-config]. _(Optional)_
 | `schema`          | The schema to set. _(Optional)_
 | `sslMode`         | SSL mode to use, see `SSLMode` enum. Supported values: `DISABLE`, `ALLOW`, `PREFER`, `REQUIRE`, `VERIFY_CA`, `VERIFY_FULL`. _(Optional)_

src/main/java/io/r2dbc/postgresql/PostgresqlConnectionFactoryProvider.java

@@ -49,6 +49,11 @@ public final class PostgresqlConnectionFactoryProvider implements ConnectionFact
      */
     public static final Option<Boolean> AUTODETECT_EXTENSIONS = Option.valueOf("autodetectExtensions");
 
+    /**
+     * Force binary transfer.
+     */
+    public static final Option<Boolean> FORCE_BINARY = Option.valueOf("forceBinary");
+
     /**
      * Driver option value.
      */
@@ -135,6 +140,12 @@ static PostgresqlConnectionConfiguration createConfiguration(ConnectionFactoryOp
             builder.port(port);
         }
 
+        Boolean forceBinary = connectionFactoryOptions.getValue(FORCE_BINARY);
+
+        if (forceBinary != null) {
+            builder.forceBinary(forceBinary);
+        }
+
         Boolean ssl = connectionFactoryOptions.getValue(SSL);
         if (ssl != null && ssl) {
             builder.enableSsl();

src/test/java/io/r2dbc/postgresql/PostgresqlConnectionFactoryProviderTest.java

@@ -25,6 +25,7 @@
 import java.util.Map;
 
 import static io.r2dbc.postgresql.PostgresqlConnectionFactoryProvider.AUTODETECT_EXTENSIONS;
+import static io.r2dbc.postgresql.PostgresqlConnectionFactoryProvider.FORCE_BINARY;
 import static io.r2dbc.postgresql.PostgresqlConnectionFactoryProvider.LEGACY_POSTGRESQL_DRIVER;
 import static io.r2dbc.postgresql.PostgresqlConnectionFactoryProvider.OPTIONS;
 import static io.r2dbc.postgresql.PostgresqlConnectionFactoryProvider.POSTGRESQL_DRIVER;
@@ -145,6 +146,19 @@ void shouldCreateConnectionFactoryWithoutPassword() {
             .build())).isNotNull();
     }
 
+    @Test
+    void providerShouldConsiderBinaryTransfer() {
+        PostgresqlConnectionFactory factory = this.provider.create(builder()
+            .option(DRIVER, LEGACY_POSTGRESQL_DRIVER)
+            .option(HOST, "test-host")
+            .option(PASSWORD, "test-password")
+            .option(USER, "test-user")
+            .option(FORCE_BINARY, true)
+            .build());
+
+        assertThat(factory.getConfiguration().isForceBinary()).isTrue();
+    }
+
     @Test
     void providerShouldParseAndHandleConnectionParameters() {
         Map<String, String> expectedOptions = new HashMap<>();