public class StandardLockService extends Object implements LockService
| Modifier and Type | Field and Description |
|---|---|
protected Database |
database |
protected boolean |
hasChangeLogLock |
COMPARATOR, PRIORITY_DATABASE, PRIORITY_DEFAULT| Constructor and Description |
|---|
StandardLockService() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
acquireLock() |
void |
destroy() |
void |
forceReleaseLock()
Releases whatever locks are on the database change log table
|
Long |
getChangeLogLockRecheckTime() |
Long |
getChangeLogLockWaitTime() |
int |
getPriority() |
boolean |
hasChangeLogLock() |
boolean |
hasDatabaseChangeLogLockTable() |
void |
init() |
boolean |
isDatabaseChangeLogLockTableInitialized(boolean tableJustCreated) |
DatabaseChangeLogLock[] |
listLocks() |
void |
releaseLock() |
void |
reset()
Clears information the lock handler knows about the tables.
|
void |
setChangeLogLockRecheckTime(long changeLogLockRecheckTime) |
void |
setChangeLogLockWaitTime(long changeLogLockWaitTime) |
void |
setDatabase(Database database) |
boolean |
supports(Database database) |
void |
waitForLock() |
protected Database database
protected boolean hasChangeLogLock
public int getPriority()
getPriority in interface PrioritizedServicepublic boolean supports(Database database)
supports in interface LockServicepublic void setDatabase(Database database)
setDatabase in interface LockServicepublic Long getChangeLogLockWaitTime()
public void setChangeLogLockWaitTime(long changeLogLockWaitTime)
setChangeLogLockWaitTime in interface LockServicepublic void setChangeLogLockRecheckTime(long changeLogLockRecheckTime)
setChangeLogLockRecheckTime in interface LockServicepublic Long getChangeLogLockRecheckTime()
public void init()
throws DatabaseException
init in interface LockServiceDatabaseExceptionpublic boolean isDatabaseChangeLogLockTableInitialized(boolean tableJustCreated)
throws DatabaseException
DatabaseExceptionpublic boolean hasChangeLogLock()
hasChangeLogLock in interface LockServicepublic boolean hasDatabaseChangeLogLockTable()
throws DatabaseException
DatabaseExceptionpublic void waitForLock()
throws LockException
waitForLock in interface LockServiceLockExceptionpublic boolean acquireLock()
throws LockException
acquireLock in interface LockServiceLockExceptionpublic void releaseLock()
throws LockException
releaseLock in interface LockServiceLockExceptionpublic DatabaseChangeLogLock[] listLocks() throws LockException
listLocks in interface LockServiceLockExceptionpublic void forceReleaseLock()
throws LockException,
DatabaseException
LockServiceforceReleaseLock in interface LockServiceLockExceptionDatabaseExceptionpublic void reset()
LockServicereset in interface LockServicepublic void destroy()
throws DatabaseException
destroy in interface LockServiceDatabaseExceptionCopyright © 2018 Liquibase.org. All rights reserved.