【Oracle】ROWID 完全ガイド｜構造の読み方・DBMS_ROWID・直接アクセス・重複行削除・バッチ UPDATE・UROWID まで実例で解説

-- テーブルの各行の ROWID を取得する
SELECT ROWID, employee_id, last_name
FROM employees
FETCH FIRST 5 ROWS ONLY;

-- 結果例（拡張ROWID: 18文字の Base64 文字列）
-- ROWID              EMPLOYEE_ID  LAST_NAME
-- AAAZAAAAEAAAABxAAA  100          King
-- AAAZAAAAEAAAABxAAB  101          Kochhar
-- AAAZAAAAEAAAABxAAC  102          De Haan
-- AAAZAAAAEAAAABxAAD  103          Hunold
-- AAAZAAAAEAAAABxAAE  104          Ernst

-- ROWID を各フィールドに分解する
SELECT
    ROWID,
    DBMS_ROWID.ROWID_OBJECT(ROWID)         AS object_no,    -- データオブジェクト番号
    DBMS_ROWID.ROWID_RELATIVE_FNO(ROWID)   AS file_no,      -- 相対ファイル番号
    DBMS_ROWID.ROWID_BLOCK_NUMBER(ROWID)   AS block_no,     -- ブロック番号
    DBMS_ROWID.ROWID_ROW_NUMBER(ROWID)     AS row_no        -- ブロック内の行番号（0始まり）
FROM employees
WHERE employee_id = 100;

-- オブジェクト番号から表名を確認
SELECT object_name, object_type
FROM dba_objects
WHERE data_object_id = 73482;   -- ↑ で得たオブジェクト番号

-- ROWID からブロック番号の範囲を調べる（パーティションやセグメント確認に使う）
SELECT
    DBMS_ROWID.ROWID_BLOCK_NUMBER(MIN(ROWID)) AS min_block,
    DBMS_ROWID.ROWID_BLOCK_NUMBER(MAX(ROWID)) AS max_block,
    COUNT(*) AS total_rows
FROM employees;

-- ① ROWID を取得して変数に保存し、後で直接アクセスする
DECLARE
    v_rowid ROWID;
    v_name  employees.last_name%TYPE;
BEGIN
    -- ROWID を取得（FOR UPDATE で行をロックしながら ROWID も保存）
    SELECT ROWID, last_name INTO v_rowid, v_name
    FROM employees
    WHERE employee_id = 100
    FOR UPDATE;

    -- ROWID で直接 UPDATE（インデックスを使わず最速）
    UPDATE employees
    SET salary = salary * 1.1
    WHERE ROWID = v_rowid;

    COMMIT;
END;
/

-- ② ROWID を文字列として保存・後から取得する（CHAR(18) で格納）
-- 用途: 処理対象行の一覧をテーブルに保存して後でバッチ処理する
CREATE TABLE work_rowids (
    rid UROWID   -- ROWID を格納する専用型
);

INSERT INTO work_rowids
SELECT ROWID FROM orders WHERE order_date < SYSDATE - 365;

-- 保存した ROWID で直接 UPDATE
UPDATE orders o
SET o.status = 'ARCHIVED'
WHERE ROWID IN (SELECT rid FROM work_rowids);

-- 重複確認: email が重複している行を探す
SELECT email, COUNT(*) AS cnt
FROM employees
GROUP BY email
HAVING COUNT(*) > 1;

-- ROWID を使った重複削除: 同じ email のうち最小 ROWID を持つ行だけ残す
DELETE FROM employees e1
WHERE ROWID > (
    SELECT MIN(ROWID)
    FROM employees e2
    WHERE e1.email = e2.email
);

-- 削除前に対象件数を確認する（DELETE 前に SELECT で件数チェック）
SELECT COUNT(*) AS delete_count
FROM employees e1
WHERE ROWID > (
    SELECT MIN(ROWID)
    FROM employees e2
    WHERE e1.email = e2.email
);

COMMIT;

-- ROW_NUMBER を使うと「最新の更新日を持つ行を残す」など細かく制御できる
DELETE FROM employees
WHERE ROWID IN (
    SELECT ROWID FROM (
        SELECT
            ROWID,
            ROW_NUMBER() OVER (
                PARTITION BY email
                ORDER BY hire_date DESC   -- 入社日が新しい行を残す（行1以外を削除）
            ) AS rn
        FROM employees
    )
    WHERE rn > 1   -- 2行目以降が重複行
);

COMMIT;

-- 削除後の確認（重複がなくなったことを確認）
SELECT email, COUNT(*) FROM employees
GROUP BY email HAVING COUNT(*) > 1;
-- → 行が返らなければ重複なし

-- DBMS_PARALLEL_EXECUTE を使った ROWID 分割バッチ処理
-- （Oracle 11g R2 以降）
DECLARE
    v_task   VARCHAR2(50) := 'UPDATE_SALARY_BATCH';
    v_sql    VARCHAR2(500);
    v_status NUMBER;
BEGIN
    -- タスクを作成
    DBMS_PARALLEL_EXECUTE.CREATE_TASK(v_task);

    -- テーブルを ROWID 範囲で分割（1チャンクあたり約 10000 行）
    DBMS_PARALLEL_EXECUTE.CREATE_CHUNKS_BY_ROWID(
        task_name   => v_task,
        table_owner => USER,
        table_name  => 'EMPLOYEES',
        by_row      => TRUE,
        chunk_size  => 10000   -- 1バッチの行数
    );

    -- 各チャンク（ROWID 範囲）で UPDATE を実行
    v_sql := 'UPDATE employees
              SET salary = salary * 1.05
              WHERE ROWID BETWEEN :start_id AND :end_id';

    DBMS_PARALLEL_EXECUTE.RUN_TASK(
        task_name      => v_task,
        sql_stmt       => v_sql,
        language_flag  => DBMS_SQL.NATIVE,
        parallel_level => 4    -- 4並列で実行
    );

    -- 完了状態を確認
    SELECT status INTO v_status
    FROM user_parallel_execute_tasks
    WHERE task_name = v_task;

    IF v_status = DBMS_PARALLEL_EXECUTE.FINISHED THEN
        DBMS_OUTPUT.PUT_LINE('完了');
        COMMIT;
    ELSE
        DBMS_OUTPUT.PUT_LINE('エラーあり: ステータス=' || v_status);
        ROLLBACK;
    END IF;

    DBMS_PARALLEL_EXECUTE.DROP_TASK(v_task);
END;
/

-- UROWID 型の列は通常テーブルにも格納できる
-- 用途: 処理済み行の ROWID を一時保存するワーク表
CREATE TABLE batch_processed_rows (
    batch_id    NUMBER,
    target_rowid UROWID,    -- ヒープ表の ROWID も IOT の UROWID も格納できる
    processed_at DATE DEFAULT SYSDATE
);

-- IOT の ROWID を確認すると論理アドレスになっていることが分かる
CREATE TABLE iot_sample (
    id   NUMBER PRIMARY KEY,
    name VARCHAR2(50)
) ORGANIZATION INDEX;   -- IOT として作成

INSERT INTO iot_sample VALUES (1, 'AAA');
INSERT INTO iot_sample VALUES (2, 'BBB');
COMMIT;

SELECT ROWID, id, name FROM iot_sample;
-- IOT の ROWID は可変長の文字列（主キー値が含まれる論理アドレス）