Skip to content

Commit

Permalink
- Fix compile issues since PgConnection constructor no longer needs u…
Browse files Browse the repository at this point in the history
…ser and db names separately
  • Loading branch information
ashetkar committed Oct 7, 2024
1 parent f8c7f82 commit b6f5811
Showing 1 changed file with 2 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -248,7 +248,7 @@ public static Connection getConnection(String url, Properties properties,
LoadBalanceProperties lbProperties, ArrayList<String> timedOutHosts) {
// Cleanup extra properties used for load balancing?
if (lbProperties.isLoadBalanceEnabled()) {
Connection conn = getConnection(lbProperties, properties, user, database, timedOutHosts);
Connection conn = getConnection(lbProperties, properties, timedOutHosts);
if (conn != null) {
return conn;
}
Expand Down Expand Up @@ -316,8 +316,6 @@ private static Connection getConnection(LoadBalanceProperties loadBalancePropert
/**
* @param loadBalanceProperties
* @param lb LoadBalancer instance
* @param user
* @param dbName
* @return true if the refresh was not required or if it was successful.
*/
private static synchronized boolean checkAndRefresh(LoadBalanceProperties loadBalanceProperties,
Expand All @@ -334,7 +332,7 @@ private static synchronized boolean checkAndRefresh(LoadBalanceProperties loadBa
boolean refreshFailed = false;
try {
if (controlConnection == null || controlConnection.isClosed()) {
controlConnection = new PgConnection(hspec, user, dbName, properties, url);
controlConnection = new PgConnection(hspec, properties, url);
}
try {
refresh(controlConnection, lb.getRefreshListSeconds());
Expand Down

0 comments on commit b6f5811

Please sign in to comment.