public abstract class AbstractDistributedLockDialect extends Object implements JdbcDistributedLockDialect
Constructor and Description |
---|
AbstractDistributedLockDialect() |
Modifier and Type | Method and Description |
---|---|
void |
createTable(JdbcClientPool connections,
Options options) |
abstract String |
getCreateTableSql() |
abstract String |
getLockAcquireSql() |
abstract String |
getReleaseLockSql() |
abstract String |
getTryReleaseTimedOutLock() |
boolean |
lockAcquire(JdbcClientPool connections,
String lockId,
long timeoutMillSeconds) |
boolean |
releaseLock(JdbcClientPool connections,
String lockId) |
int |
tryReleaseTimedOutLock(JdbcClientPool connections,
String lockId) |
public void createTable(JdbcClientPool connections, Options options) throws SQLException, InterruptedException
createTable
in interface JdbcDistributedLockDialect
SQLException
InterruptedException
public abstract String getCreateTableSql()
public boolean lockAcquire(JdbcClientPool connections, String lockId, long timeoutMillSeconds) throws SQLException, InterruptedException
lockAcquire
in interface JdbcDistributedLockDialect
SQLException
InterruptedException
public abstract String getLockAcquireSql()
public boolean releaseLock(JdbcClientPool connections, String lockId) throws SQLException, InterruptedException
releaseLock
in interface JdbcDistributedLockDialect
SQLException
InterruptedException
public abstract String getReleaseLockSql()
public int tryReleaseTimedOutLock(JdbcClientPool connections, String lockId) throws SQLException, InterruptedException
tryReleaseTimedOutLock
in interface JdbcDistributedLockDialect
SQLException
InterruptedException
public abstract String getTryReleaseTimedOutLock()
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.