SET TERM ^;
CREATE OR ALTER TRIGGER myTable__TR_BI
  FOR myTable
  ACTIVE
  BEFOR INSERT
  POSITION 0
AS
  DECLARE VARIABLE seqValue BIGINT DEFAULT NULL;
BEGIN
  .
  .
  .
  seqValue = GEN_LOCK(mySequence);    -- висим внутри функции, пока не заблокируем
                                      -- или пока наша транзакция не навернется по таймауту
  IF (NEW.Id IS NULL OR NEW.Id > :seqValue) THEN
    NEW.Id = GEN_ID(mySequence, 1);
  GEN_UNLOCK(mySequence);             -- освобождаем последовательность
  seqValue = NULL;
  .
  .
  .
  WHEN ANY DO
    BEGIN
      IF (:seqValue IS NOT NULL) THEN
        GEN_UNLOCK(mySequence);   -- Если 
      EXCEPTION;
    END
END^
SET TERM ;^

SET TERM ^;
CREATE OR ALTER TRIGGER myTable__TR_AD
  FOR myTable
  ACTIVE
  AFTER DELETE
  POSITION 32767
AS
  DECLARE VARIABLE seqValue BIGINT DEFAULT NULL;
BEGIN
  seqValue = GEN_LOCK(mySequence);    -- висим внутри функции, пока не заблокируем
                                      -- или пока наша транзакция не навернется по таймауту
  IF (NOT EXISTS(SELECT FIRST 1 * FROM myTable)) THEN
    seqValue = GEN_ID(mySequence, seqValue * -1)
  GEN_UNLOCK(mySequence);             -- освобождаем последовательность
  seqValue = NULL;
  WHEN ANY DO
    BEGIN
      IF (:seqValue IS NOT NULL) THEN
        GEN_UNLOCK(mySequence);
      EXCEPTION;
    END
END^
SET TERM ;^

SET TERM ^;
CREATE OR ALTER PROCEDURE shrinkMyTableId
AS
  DECLARE VARIABLE Id BIGINT DEFAULT NULL;
  DECLARE VARIABLE newId BIGINT DEFAULT 0;
  DECLARE VARIABLE seqValue BIGINT DEFAULT NULL;
BEGIN
  seqValue = GEN_LOCK(mySequence);   -- Блокируем изменение последовательности
  FOR
      SELECT Id, :newId + 1
        FROM myTable
        WHERE Id > 0
        ORDER BY Id ASC
        FOR UPDATE WITH LOCK
        INTO: Id, newId
    DO
      IF (:Id != :newId) THEN
        UPDATE myTable
          SET Id = :newId
          WHERE Id = :Id;
  seqValue = GEN_ID(mySequence, newId - seqValue);
  GEN_UNLOCK(mySequence);
  seqValue = NULL;
  WHEN ANY DO
    BEGIN
      IF (:seqValue IS NOT NULL) THEN
        GEN_UNLOCK(mySequence);
      EXCEPTION;
    END
END^
SET TERM ;^

struct SEQ
{
  volatile __int64 value;
  volatile __int64 lock_owner;
};

__int64 volatile gen_id(const char * seqName, __int64 delta)
{
  SEQ * seq;
  __int64 value,
          oldOwner,
          newOwner = fb::getCurrentTransactionId();
  
  if (NULL == (seq = fb::getSequenceByName(seqName))) throw (int)1;
  while (true)
  {
    oldOwner = ::InterlockedCompareExchange64(&seq->lock_owner, newOwner, 0);
    if (!oldOwner || newOwner == oldOwner) break;
    if (fb::isTransactionTimedOut(newOwner)) throw (int)2;
  }
  value = seq->value;
  if (delta)
  {
    value += delta;
    ::InterlockedExchange64(&seq->value, value);
  }
  if (!oldOwner) ::InterlockedCompareExchange64(&seq->lock_owner, 0, newOwner);
  return value;
}


__int64 volatile gen_lock(const char * seqName)
{
  SEQ * seq;
  __int64 value,
          oldOwner,
          newOwner = fb::getCurrentTransactionId();
  
  if (NULL == (seq = fb::getSequenceByName(seqName))) throw (int)1;
  while (true)
  {
    oldOwner = ::InterlockedCompareExchange64(&seq->lock_owner, newOwner, 0);
    if (!oldOwner || newOwner == oldOwner) break;
    if (fb::isTransactionTimedOut(newOwner)) throw (int)2;
  }
  return seq->value;
}


void volatile gen_unlock(const char * seqName)
{
  SEQ * seq;
  __int64 owner = fb::getCurrentTransactionId();

  if (NULL == (seq = fb::getSequenceByName(seqName))) throw (int)1;
  ::InterlockedCompareExchange64(&seq->lock_owner, 0, owner);
}