Skip to content

Commit 1b25dd4

Browse files
author
chengyitian
committed
AJ-731: add new connect method with 'tryReconnectNums' param;
1 parent 4314330 commit 1b25dd4

File tree

1 file changed

+12
-0
lines changed

1 file changed

+12
-0
lines changed

src/com/xxdb/DBConnection.java

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -670,6 +670,11 @@ public boolean connect(String hostName, int port, int timeout, boolean reconnect
670670
return connect(hostName, port, "", "", null, false, null, reconnect);
671671
}
672672

673+
public boolean connect(String hostName, int port, int timeout, boolean reconnect, int tryReconnectNums) throws IOException {
674+
this.connTimeout_ = timeout;
675+
return connect(hostName, port, "", "", null, false, null, reconnect, tryReconnectNums);
676+
}
677+
673678
public boolean connect(String hostName, int port, String initialScript) throws IOException {
674679
return connect(hostName, port, "", "", initialScript, false, null);
675680
}
@@ -725,6 +730,13 @@ public boolean connect(String hostName, int port, String userId, String password
725730
return connect(hostName, port, userId, password, initialScript, enableHighAvailability, highAvailabilitySites, reconnect, false);
726731
}
727732

733+
public boolean connect(String hostName, int port, String userId, String password, String initialScript, boolean enableHighAvailability, String[] highAvailabilitySites, boolean reconnect, int tryReconnectNums) throws IOException {
734+
if (enableHighAvailability)
735+
return connect(hostName, port, userId, password, initialScript, enableHighAvailability, highAvailabilitySites, reconnect, true, tryReconnectNums);
736+
else
737+
return connect(hostName, port, userId, password, initialScript, enableHighAvailability, highAvailabilitySites, reconnect, false, tryReconnectNums);
738+
}
739+
728740
public boolean connect(String hostName, int port, String userId, String password, String initialScript, boolean enableHighAvailability, String[] highAvailabilitySites, boolean reconnect, boolean enableLoadBalance) throws IOException {
729741
return connect(hostName, port, userId, password, initialScript, enableHighAvailability, highAvailabilitySites, reconnect, enableLoadBalance, -1);
730742
}

0 commit comments

Comments
 (0)