Skip to content

Commit eab20cf

Browse files
committed
Valid Example
Previously, the example in the README did not comile as the return types were not accurate. This change updates the example to be accurate. [resolves pgjdbc#68] Signed-off-by: Ben Hale <[email protected]>
1 parent 95bb6ea commit eab20cf

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

README.md

+4-1
Original file line numberDiff line numberDiff line change
@@ -71,7 +71,10 @@ ConnectionFactory connectionFactory = ConnectionFactories.get(ConnectionFactoryO
7171
.option(DATABASE, "...") // optional
7272
.build());
7373

74-
Mono<Connection> connection = connectionFactory.create();
74+
Publisher<? extends Connection> connectionPublisher = connectionFactory.create();
75+
76+
// Alternative: Creating a Mono using Project Reactor
77+
Mono<Connection> connectionMono = Mono.from(connectionFactory.create());
7578
```
7679

7780
Supported Connection Factory Discovery options:

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

+2-1
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@
2323

2424
import static io.r2dbc.spi.ConnectionFactoryOptions.CONNECT_TIMEOUT;
2525
import static io.r2dbc.spi.ConnectionFactoryOptions.DATABASE;
26+
import static io.r2dbc.spi.ConnectionFactoryOptions.DRIVER;
2627
import static io.r2dbc.spi.ConnectionFactoryOptions.HOST;
2728
import static io.r2dbc.spi.ConnectionFactoryOptions.PASSWORD;
2829
import static io.r2dbc.spi.ConnectionFactoryOptions.PORT;
@@ -74,7 +75,7 @@ public PostgresqlConnectionFactory create(ConnectionFactoryOptions connectionFac
7475
public boolean supports(ConnectionFactoryOptions connectionFactoryOptions) {
7576
Assert.requireNonNull(connectionFactoryOptions, "connectionFactoryOptions must not be null");
7677

77-
String driver = connectionFactoryOptions.getValue(ConnectionFactoryOptions.DRIVER);
78+
String driver = connectionFactoryOptions.getValue(DRIVER);
7879
if (driver == null || !driver.equals(POSTGRESQL_DRIVER)) {
7980
return false;
8081
}

0 commit comments

Comments
 (0)