Skip to content

Commit 3457cba

Browse files
committed
Merge branch '68-example'
2 parents 95bb6ea + eab20cf commit 3457cba

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)