@@ -42,14 +42,18 @@ Publisher<? extends Connection> connectionPublisher = connectionFactory.create()
42
42
** Programmatic Connection Factory Discovery**
43
43
44
44
``` java
45
+ Map<String , String > options = new HashMap<> ();
46
+ options. put(" lock_timeout" , " 10s" );
47
+ options. put(" statement_timeout" , " 5m" );
48
+
45
49
ConnectionFactory connectionFactory = ConnectionFactories . get(ConnectionFactoryOptions . builder()
46
50
.option(DRIVER , " postgresql" )
47
51
.option(HOST , " ..." )
48
52
.option(PORT , 5432 ) // optional, defaults to 5432
49
53
.option(USER , " ..." )
50
54
.option(PASSWORD , " ..." )
51
55
.option(DATABASE , " ..." ) // optional
52
- .option(OPTIONS , Map . of( " lock_timeout " , " 30s " , " statement_timeout " , " 5m " ) ) // optional
56
+ .option(OPTIONS , options ) // optional
53
57
.build());
54
58
55
59
Publisher<? extends Connection > connectionPublisher = connectionFactory. create();
@@ -83,13 +87,16 @@ Mono<Connection> connectionMono = Mono.from(connectionFactory.create());
83
87
** Programmatic Configuration**
84
88
85
89
``` java
90
+ Map<String , String > options = new HashMap<> ();
91
+ options. put(" lock_timeout" , " 10s" );
92
+
86
93
ConnectionFactory connectionFactory = new PostgresqlConnectionFactory (PostgresqlConnectionConfiguration . builder()
87
94
.host(" ..." )
88
95
.port(5432 ) // optional, defaults to 5432
89
96
.username(" ..." )
90
97
.password(" ..." )
91
98
.database(" ..." ) // optional
92
- .options(Map . of( " lock_timeout " , " 10s " , " search_path " , " public, myschema " ) ) // optional
99
+ .options(options ) // optional
93
100
.build());
94
101
95
102
Mono<Connection > mono = connectionFactory. create();
0 commit comments