File tree Expand file tree Collapse file tree 2 files changed +6
-2
lines changed
src/main/java/io/r2dbc/postgresql Expand file tree Collapse file tree 2 files changed +6
-2
lines changed Original file line number Diff line number Diff 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
7780Supported Connection Factory Discovery options:
Original file line number Diff line number Diff line change 2323
2424import static io .r2dbc .spi .ConnectionFactoryOptions .CONNECT_TIMEOUT ;
2525import static io .r2dbc .spi .ConnectionFactoryOptions .DATABASE ;
26+ import static io .r2dbc .spi .ConnectionFactoryOptions .DRIVER ;
2627import static io .r2dbc .spi .ConnectionFactoryOptions .HOST ;
2728import static io .r2dbc .spi .ConnectionFactoryOptions .PASSWORD ;
2829import 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 }
You can’t perform that action at this time.
0 commit comments