Skip to content

Commit dbcc9c0

Browse files
committed
Update to ensure deleting cluster record doesn;t fail while upgrading
1 parent 7e369f1 commit dbcc9c0

1 file changed

Lines changed: 7 additions & 7 deletions

File tree

src/com/prtech/svarog/SvarogInstall.java

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1807,14 +1807,14 @@ static void deleteClusterRogueRecord() throws SQLException, SvException {
18071807
if (!isSvarogInstalled())
18081808
return;
18091809

1810-
StringBuilder sbr = new StringBuilder(100);
1811-
sbr.append("DELETE FROM ");
1812-
sbr.append(SvConf.getDefaultSchema() + ".");
1813-
sbr.append((String) SvCore.getDbt(svCONST.OBJECT_TYPE_CLUSTER).getVal("REPO_NAME") + " WHERE ");
1814-
sbr.append(" OBJECT_TYPE=" + Long.toString(svCONST.OBJECT_TYPE_CLUSTER) + " AND OBJECT_ID="
1815-
+ Long.toString(svCONST.CLUSTER_COORDINATOR_ID));
1816-
18171810
try (SvReader svr = new SvReader(); Statement st = svr.dbGetConn().createStatement()) {
1811+
StringBuilder sbr = new StringBuilder(100);
1812+
sbr.append("DELETE FROM ");
1813+
sbr.append(SvConf.getDefaultSchema() + ".");
1814+
sbr.append((String) SvCore.getDbt(svCONST.OBJECT_TYPE_CLUSTER).getVal("REPO_NAME") + " WHERE ");
1815+
sbr.append(" OBJECT_TYPE=" + Long.toString(svCONST.OBJECT_TYPE_CLUSTER) + " AND OBJECT_ID="
1816+
+ Long.toString(svCONST.CLUSTER_COORDINATOR_ID));
1817+
18181818
DbDataObject clusterCoordinator = svr.getObjectById(svCONST.CLUSTER_COORDINATOR_ID,
18191819
svCONST.OBJECT_TYPE_CLUSTER, null);
18201820
if (clusterCoordinator == null) {

0 commit comments

Comments
 (0)