[Draft] Impl with consideration of lock duration

ozone-his · May 9, 2024 · c8c26c7 · c8c26c7
1 parent e9f05b9
commit c8c26c7
Showing 1 changed file with 14 additions and 1 deletion.
diff --git a/app/src/main/java/com/ozonehis/eip/Application.java b/app/src/main/java/com/ozonehis/eip/Application.java
@@ -10,6 +10,7 @@
 import liquibase.database.Database;
 import liquibase.database.DatabaseFactory;
 import liquibase.database.jvm.JdbcConnection;
+import liquibase.lockservice.LockService;
 import liquibase.lockservice.LockServiceFactory;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Value;
@@ -40,7 +41,19 @@ private static void releaseLiquibaseLock() {
         try (Connection connection = dataSource.getConnection()) {
             Database database = DatabaseFactory.getInstance()
                     .findCorrectDatabaseImplementation(new JdbcConnection(connection));
-            LockServiceFactory.getInstance().getLockService(database).forceReleaseLock();
+//            LockServiceFactory.getInstance().getLockService(database).forceReleaseLock();
+            LockService lockService = LockServiceFactory.getInstance().getLockService(database);
+            if (lockService.hasChangeLogLock()) {
+                long lockAcquiredAt = lockService.listLocks()[lockService.listLocks().length - 1].getLockGranted().getTime();
+                long currentTime = System.currentTimeMillis();
+                long lockDuration = currentTime - lockAcquiredAt;
+                if (lockDuration > 20000) {
+                    lockService.forceReleaseLock();
+                } else {
+                    log.info("Liquibase lock is not held for more than 20 seconds. No action needed.");
+                }
+            }
+
         } catch (Exception e) {
             log.error("Error occurred while releasing lock from Liquibase: {}", e.getMessage(), e);
         }