Skip to content

Commit 2161f6a

Browse files
committed
include optional connection parameters in jdbc string
1 parent 7e37202 commit 2161f6a

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

src/main/java/io/zonky/test/db/postgres/embedded/PreparedDbProvider.java

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,7 @@
3333
import java.util.concurrent.Executors;
3434
import java.util.concurrent.SynchronousQueue;
3535
import java.util.function.Consumer;
36+
import java.util.stream.Collectors;
3637

3738
import static java.util.Collections.emptyMap;
3839
import static java.util.Collections.unmodifiableMap;
@@ -143,9 +144,12 @@ public DataSource createDataSource() throws SQLException
143144
return createDataSourceFromConnectionInfo(createNewDatabase());
144145
}
145146

146-
String getJdbcUri(DbInfo db)
147+
private String getJdbcUri(DbInfo db)
147148
{
148-
return String.format(JDBC_FORMAT, db.port, db.dbName, db.user);
149+
String additionalParameters = db.getProperties().entrySet().stream()
150+
.map(e -> String.format("&%s=%s", e.getKey(), e.getValue()))
151+
.collect(Collectors.joining());
152+
return String.format(JDBC_FORMAT, db.port, db.dbName, db.user) + additionalParameters;
149153
}
150154

151155
/**

0 commit comments

Comments
 (0)