【Oracle】DBMS_LOCK完全ガイド｜ユーザー定義ロックで排他制御・バッチ二重起動防止まで解説

DECLARE
    v_lock_id  NUMBER;
BEGIN
    -- ロック名（最大 128 バイト）を一意なロック ID に変換する
    -- 同じ名前を複数セッションから呼び出しても同じ ID が返る
    DBMS_LOCK.ALLOCATE_UNIQUE(
        lockname        => 'BATCH_MONTHLY_SALES',   -- ロック名（任意の文字列）
        lockhandle      => v_lock_id,                  -- 出力: ロックハンドル（文字列）
        expiration_secs => 864000                       -- ロック ID の保持期間（秒）= 10 日間
    );
    -- v_lock_id はこのセッション内で REQUEST / RELEASE に使う

    DBMS_OUTPUT.PUT_LINE('Lock handle: ' || v_lock_id);
END;
/
-- 注意: ALLOCATE_UNIQUE は内部で COMMIT を実行する
-- ALLOCATE_UNIQUE の後に同一トランザクション内の DML を ROLLBACK すると消えてしまうため
-- ALLOCATE_UNIQUE はトランザクション開始前に呼び出すのが安全

-- DBMS_LOCK.REQUEST の戻り値
-- 0: 取得成功
-- 1: タイムアウト（timeout 秒以内に取得できなかった）
-- 2: デッドロック検出（Oracle がデッドロックを検知して自動解放）
-- 3: パラメータエラー
-- 4: 既に同じロックを保持している（ALREADY_OWN）
-- 5: 不正なロックハンドル

DECLARE
    v_lockhandle  VARCHAR2(128);
    v_result      INTEGER;
BEGIN
    -- ロックハンドルを取得する
    DBMS_LOCK.ALLOCATE_UNIQUE(
        lockname   => 'MY_BATCH_JOB',
        lockhandle => v_lockhandle
    );

    -- 排他ロックを取得する（最大 0 秒待機 = 即時取得を試みる）
    v_result := DBMS_LOCK.REQUEST(
        lockhandle        => v_lockhandle,
        lockmode          => DBMS_LOCK.X_MODE,  -- 排他ロック（Exclusive）
        timeout           => 0,                  -- 0 = 待機なし（NOWAIT 相当）
        release_on_commit => FALSE               -- COMMIT しても解放しない
    );

    IF v_result = 0 THEN
        DBMS_OUTPUT.PUT_LINE('ロック取得成功 - バッチ処理を開始します');
        -- バッチ処理をここに書く

        -- 処理完了後にロックを解放する
        v_result := DBMS_LOCK.RELEASE(v_lockhandle);
        IF v_result = 0 THEN
            DBMS_OUTPUT.PUT_LINE('ロック解放成功');
        END IF;

    ELSIF v_result = 1 THEN
        DBMS_OUTPUT.PUT_LINE('ロック取得タイムアウト - 他のセッションが処理中です');
    ELSIF v_result = 4 THEN
        DBMS_OUTPUT.PUT_LINE('既にロックを保持しています');
    ELSE
        DBMS_OUTPUT.PUT_LINE('ロック取得失敗: ' || v_result);
    END IF;
END;
/

CREATE OR REPLACE PROCEDURE run_monthly_batch AS
    v_lockhandle  VARCHAR2(128);
    v_result      INTEGER;
BEGIN
    -- ロックハンドルを確保する（バッチ名を使う）
    DBMS_LOCK.ALLOCATE_UNIQUE(
        lockname        => 'BATCH:MONTHLY_SALES_AGGREGATE',
        lockhandle      => v_lockhandle,
        expiration_secs => 86400   -- 1 日
    );

    -- 排他ロックを即時取得する（待機しない）
    v_result := DBMS_LOCK.REQUEST(
        lockhandle        => v_lockhandle,
        lockmode          => DBMS_LOCK.X_MODE,
        timeout           => 0,
        release_on_commit => FALSE  -- COMMIT してもロックを保持し続ける
    );

    IF v_result != 0 THEN
        -- ロック取得失敗 = 別プロセスが実行中
        DBMS_OUTPUT.PUT_LINE(
            '[SKIP] バッチは既に実行中です（result=' || v_result || ')');
        RETURN;   -- 正常終了（エラーにしない）
    END IF;

    -- ロック取得成功 = このセッションだけが処理を実行する
    BEGIN
        DBMS_OUTPUT.PUT_LINE('[START] 月次集計バッチを開始します');

        -- バッチのメイン処理
        INSERT INTO monthly_summary
        SELECT TRUNC(sale_date, 'MM'), SUM(amount)
        FROM sales
        WHERE TRUNC(sale_date, 'MM') = TRUNC(SYSDATE, 'MM')
        GROUP BY TRUNC(sale_date, 'MM');
        COMMIT;

        DBMS_OUTPUT.PUT_LINE('[DONE] 月次集計バッチが完了しました');

    EXCEPTION
        WHEN OTHERS THEN
            ROLLBACK;
            DBMS_OUTPUT.PUT_LINE('[ERROR] ' || SQLERRM);
            -- エラー時も必ずロックを解放する
    END;

    -- 処理完了後にロックを解放する
    v_result := DBMS_LOCK.RELEASE(v_lockhandle);

EXCEPTION
    WHEN OTHERS THEN
        -- 予期しないエラーでもロックを解放する
        IF v_lockhandle IS NOT NULL THEN
            v_result := DBMS_LOCK.RELEASE(v_lockhandle);
        END IF;
        RAISE;
END run_monthly_batch;
/

DECLARE
    v_lockhandle  VARCHAR2(128);
    v_result      INTEGER;
BEGIN
    DBMS_LOCK.ALLOCATE_UNIQUE(
        lockname   => 'RESOURCE:EXTERNAL_API_SLOT_1',
        lockhandle => v_lockhandle
    );

    -- 最大 30 秒待機してロックを取得する
    v_result := DBMS_LOCK.REQUEST(
        lockhandle        => v_lockhandle,
        lockmode          => DBMS_LOCK.X_MODE,
        timeout           => 30,    -- 30 秒待機
        release_on_commit => FALSE
    );

    CASE v_result
        WHEN 0 THEN
            -- 処理実行
            process_api_call;
            v_result := DBMS_LOCK.RELEASE(v_lockhandle);
        WHEN 1 THEN
            RAISE_APPLICATION_ERROR(-20001, '30秒待機後もロックを取得できませんでした');
        WHEN 2 THEN
            RAISE_APPLICATION_ERROR(-20002, 'デッドロックを検出しました');
        ELSE
            RAISE_APPLICATION_ERROR(-20003, 'ロック取得エラー: ' || v_result);
    END CASE;
END;
/
-- DBMS_LOCK.REQUEST の timeout に DBMS_LOCK.MAXWAIT（32767）を指定すると無限待機になる

-- ユーザー定義ロック（type='UL'）を確認する
SELECT
    l.sid,
    s.username,
    s.program,
    l.type,         -- 'UL' = User Lock（DBMS_LOCK が作成したロック）
    l.lmode,        -- 現在保持しているロックモード（6=X_MODE）
    l.request,      -- 待機中のロックモード（0=待機なし）
    l.block,        -- 1=他セッションをブロックしている
    l.id1,          -- DBMS_LOCK_ALLOCATED.lockid に対応
    l.id2
FROM V$LOCK l
JOIN V$SESSION s ON l.sid = s.sid
WHERE l.type = 'UL'
ORDER BY l.block DESC, l.sid;

-- DBMS_LOCK_ALLOCATED でロック名と ID の対応を確認する
SELECT lockid, name, expiration
FROM DBMS_LOCK_ALLOCATED
WHERE name LIKE 'BATCH:%'
ORDER BY name;