Always check if lock is held by current process. (#229)

liquibase · Nov 15, 2023 · c042d2b · c042d2b
1 parent 98ca9ca
commit c042d2b
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/src/main/java/liquibase/ext/cassandra/lockservice/LockServiceCassandra.java b/src/main/java/liquibase/ext/cassandra/lockservice/LockServiceCassandra.java
@@ -179,10 +179,8 @@ public boolean isDatabaseChangeLogLockTableInitialized(final boolean tableJustCr
     }
 
     private boolean isLocked(Executor executor) throws DatabaseException {
-        return executor.queryForInt(
-                new RawSqlStatement("SELECT COUNT(*) FROM " + getChangeLogLockTableName() + " where " +
-                        "locked = TRUE ALLOW FILTERING")
-        ) > 0;
+        // Check to see if current process holds the lock each time
+        return isLockedByCurrentInstance(executor);
     }
 
     private boolean isLockedByCurrentInstance(Executor executor) throws DatabaseException {