Class PostgreSqlSelectForUpdateLockHandler

Namespace

Quartz.Impl.AdoJobStore

Assembly

Quartz.dll

PostgreSQL-specific row lock handler that uses INSERT ... ON CONFLICT DO NOTHING to handle race conditions when multiple threads try to insert the same lock row.

public class PostgreSqlSelectForUpdateLockHandler : SelectForUpdateLockHandler, ILockHandler

Inheritance

object

DbLockHandler

SelectForUpdateLockHandler

PostgreSqlSelectForUpdateLockHandler

Implements

ILockHandler

Inherited Members

SelectForUpdateLockHandler.SelectForLock

SelectForUpdateLockHandler.InsertLock

SelectForUpdateLockHandler.MaxRetry

SelectForUpdateLockHandler.RetryPeriod

SelectForUpdateLockHandler.ExecuteSql(Guid, ConnectionAndTransactionHolder, string, string, string, CancellationToken)

DbLockHandler.Initialize(LockHandlerContext)

DbLockHandler.AcquireLock(Guid, ConnectionAndTransactionHolder, SchedulerLock, CancellationToken)

DbLockHandler.ReleaseLock(Guid, SchedulerLock, CancellationToken)

DbLockHandler.RequiresConnection

DbLockHandler.LockSql

DbLockHandler.InsertSql

DbLockHandler.SchedulerName

DbLockHandler.TablePrefix

DbLockHandler.TimeProvider

DbLockHandler.PrepareCommand(ConnectionAndTransactionHolder, string)

DbLockHandler.AddCommandParameter(DbCommand, string, object)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Remarks

This implementation fixes the transaction abort issue that occurs in PostgreSQL when two threads simultaneously attempt to insert a lock row, causing a primary key violation that aborts the transaction.

Constructors

PostgreSqlSelectForUpdateLockHandler(IDbProvider)

Initializes a new instance of the PostgreSqlSelectForUpdateLockHandler class.

public PostgreSqlSelectForUpdateLockHandler(IDbProvider dbProvider)

Parameters

dbProvider IDbProvider

PostgreSqlSelectForUpdateLockHandler(string, string, string?, IDbProvider)

Initializes a new instance of the PostgreSqlSelectForUpdateLockHandler class.

public PostgreSqlSelectForUpdateLockHandler(string tablePrefix, string schedulerName, string? selectWithLockSql, IDbProvider dbProvider)

Parameters

tablePrefix string

The table prefix.

schedulerName string

the scheduler name

selectWithLockSql string

The select with lock SQL.

dbProvider IDbProvider

The db provider.