@@ -12,25 +12,30 @@ public class PostgresClientWithAsyncReadConnTest {
12
12
13
13
@ Test
14
14
public void getInstanceTest () {
15
- Envs .setEnv (Map .of (
16
- "DB_HOST_READER_ASYNC" , "myhost_reader_async" ,
17
- "DB_PORT_READER_ASYNC" , "54321" ,
18
- "DB_HOST_READER" , "myhost_reader" ,
19
- "DB_PORT_READER" , "12345" ,
20
- "DB_HOST" , "myhost" ,
21
- "DB_PORT" , "5433" ,
22
- "DB_USERNAME" , "myuser" ,
23
- "DB_PASSWORD" , "mypassword" ,
24
- "DB_DATABASE" , "mydatabase" ,
25
- "DB_CONNECTIONRELEASEDELAY" , "1000"
26
- ));
27
- var vertx = Vertx .vertx ();
28
- var tenant = "testTenant" ;
29
- var client = PostgresClientWithAsyncReadConn .getInstance (vertx , tenant );
30
- var initializer = client .getPostgresClientInitializer ();
31
- assertNotNull (client );
32
- assertNotNull (client .getReaderClient ());
33
- assertNotEquals (client .getClient (), client .getReaderClient ());
34
- assertEquals (client .getReaderClient (), initializer .getAsyncReadClient ());
15
+ try {
16
+ Envs .setEnv (Map .of (
17
+ "DB_HOST_READER_ASYNC" , "myhost_reader_async" ,
18
+ "DB_PORT_READER_ASYNC" , "54321" ,
19
+ "DB_HOST_READER" , "myhost_reader" ,
20
+ "DB_PORT_READER" , "12345" ,
21
+ "DB_HOST" , "myhost" ,
22
+ "DB_PORT" , "5433" ,
23
+ "DB_USERNAME" , "myuser" ,
24
+ "DB_PASSWORD" , "mypassword" ,
25
+ "DB_DATABASE" , "mydatabase" ,
26
+ "DB_CONNECTIONRELEASEDELAY" , "1000"
27
+ ));
28
+ var vertx = Vertx .vertx ();
29
+ var tenant = "testTenant" ;
30
+ var client = PostgresClientWithAsyncReadConn .getInstance (vertx , tenant );
31
+ var initializer = client .getPostgresClientInitializer ();
32
+ assertNotNull (client );
33
+ assertNotNull (client .getReaderClient ());
34
+ assertNotEquals (client .getClient (), client .getReaderClient ());
35
+ assertEquals (client .getReaderClient (), initializer .getAsyncReadClient ());
36
+ } finally {
37
+ // restore defaults
38
+ Envs .setEnv (System .getenv ());
39
+ }
35
40
}
36
41
}
0 commit comments