io.flamingock.store.sql.internal

Class SqlLockDialectHelper

java.lang.Object

io.flamingock.store.sql.internal.SqlLockDialectHelper

public final class SqlLockDialectHelper
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
SqlLockDialectHelper(java.sql.Connection connection)

Method Summary

Modifier and Type	Method and Description
java.lang.String	getCreateTableSqlString(java.lang.String tableName)
java.lang.String	getDeleteLockSqlString(java.lang.String tableName)
java.lang.String	getInsertOrUpdateLockSqlString(java.lang.String tableName)
java.lang.String	getSelectLockSqlString(java.lang.String tableName)
io.flamingock.internal.common.sql.SqlDialect	getSqlDialect()
void	upsertLockEntry(java.sql.Connection conn, java.lang.String tableName, java.lang.String key, java.lang.String owner, java.time.LocalDateTime expiresAt)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SqlLockDialectHelper

public SqlLockDialectHelper(java.sql.Connection connection)
                     throws java.sql.SQLException

Throws:

java.sql.SQLException

Method Detail

getCreateTableSqlString

public java.lang.String getCreateTableSqlString(java.lang.String tableName)

getSelectLockSqlString

public java.lang.String getSelectLockSqlString(java.lang.String tableName)

getInsertOrUpdateLockSqlString

public java.lang.String getInsertOrUpdateLockSqlString(java.lang.String tableName)

getDeleteLockSqlString

public java.lang.String getDeleteLockSqlString(java.lang.String tableName)

upsertLockEntry

public void upsertLockEntry(java.sql.Connection conn,
                            java.lang.String tableName,
                            java.lang.String key,
                            java.lang.String owner,
                            java.time.LocalDateTime expiresAt)
                     throws java.sql.SQLException

Throws:

java.sql.SQLException

getSqlDialect

public io.flamingock.internal.common.sql.SqlDialect getSqlDialect()