【Oracle】更新するデータの件数を指定する方法｜ROWNUM・ROW_NUMBER・FETCH FIRSTの使い分け

この記事でわかること

• ROWNUM を使った基本的な件数制限UPDATE
• ソート後のN件を更新する方法（サブクエリ）
• ROW_NUMBER() OVER() による柔軟な件数指定
• FETCH FIRST N ROWS ONLY（Oracle 12c+）の活用
• UPDATE ... WHERE IN (サブクエリ) パターン
• 大量データのバッチ更新（分割更新）テクニック
• MySQL / SQL Server / PostgreSQL との比較
• トランザクションでの安全な更新手順

-- MySQLでは可能だが、Oracleではエラーになる
UPDATE employees
SET status = 'inactive'
LIMIT 100;  -- ORA-00933: SQL command not properly ended

注意：Oracleでは UPDATE文に LIMIT 句を直接使用できません。代わりに ROWNUM や分析関数を利用します。

-- 最初の100件だけを更新する
UPDATE employees
SET status = 'inactive'
WHERE department_id = 10
  AND ROWNUM <= 100;

実行結果

100行が更新されました。

注意：ROWNUMは行が返されるときに順番に振られるため、ROWNUM = 5 や ROWNUM > 5 のように「先頭を飛ばす」条件では結果が0件になります。ROWNUMは必ず1から始まる連番としてしか使えません。

-- 給与の低い順に100件更新したいが…
UPDATE employees
SET bonus = 5000
WHERE ROWNUM <= 100
ORDER BY salary ASC;  -- ORDER BYはROWNUMの後に評価される！

-- 給与が低い順に上位100件を更新
UPDATE employees
SET bonus = 5000
WHERE employee_id IN (
    SELECT employee_id
    FROM (
        SELECT employee_id
        FROM employees
        ORDER BY salary ASC
    )
    WHERE ROWNUM <= 100
);

ポイント：サブクエリの中で ORDER BY を実行し、外側のクエリで ROWNUM を使う「二重サブクエリ」構造がポイントです。内側でソートしてから外側で件数を絞ることで、正しい順序での上位N件を取得できます。

-- 部署10の社員のうち、入社日が古い順に50件を更新
UPDATE employees
SET status = 'senior'
WHERE employee_id IN (
    SELECT employee_id
    FROM (
        SELECT employee_id
        FROM employees
        WHERE department_id = 10
        ORDER BY hire_date ASC
    )
    WHERE ROWNUM <= 50
);

-- 給与が高い順に上位50件を更新
UPDATE employees
SET bonus = 10000
WHERE employee_id IN (
    SELECT employee_id
    FROM (
        SELECT employee_id,
               ROW_NUMBER() OVER (ORDER BY salary DESC) AS rn
        FROM employees
    )
    WHERE rn <= 50
);

-- 51件目〜100件目を更新（ページング的な更新）
UPDATE employees
SET processed_flag = 'Y'
WHERE employee_id IN (
    SELECT employee_id
    FROM (
        SELECT employee_id,
               ROW_NUMBER() OVER (ORDER BY employee_id) AS rn
        FROM employees
        WHERE processed_flag = 'N'
    )
    WHERE rn BETWEEN 51 AND 100
);

-- 部署ごとに給与上位3名のボーナスを更新
UPDATE employees
SET bonus = 20000
WHERE employee_id IN (
    SELECT employee_id
    FROM (
        SELECT employee_id,
               ROW_NUMBER() OVER (
                   PARTITION BY department_id
                   ORDER BY salary DESC
               ) AS rn
        FROM employees
    )
    WHERE rn <= 3
);

実行結果

部署10: 3名更新
部署20: 3名更新
部署30: 3名更新
合計: 9行が更新されました。

-- 給与が高い順に上位10件を取得
SELECT employee_id, last_name, salary
FROM employees
ORDER BY salary DESC
FETCH FIRST 10 ROWS ONLY;

-- FETCH FIRST を使って上位10件を更新（12c以降）
UPDATE employees
SET bonus = 15000
WHERE employee_id IN (
    SELECT employee_id
    FROM employees
    ORDER BY salary DESC
    FETCH FIRST 10 ROWS ONLY
);

-- 11番目〜20番目の社員を更新
UPDATE employees
SET review_status = 'pending'
WHERE employee_id IN (
    SELECT employee_id
    FROM employees
    ORDER BY hire_date ASC
    OFFSET 10 ROWS FETCH NEXT 10 ROWS ONLY
);

ポイント：FETCH FIRST N ROWS ONLY は内部的に ROW_NUMBER() に変換されるため、パフォーマンスは同等です。可読性に優れているため、12c以降の環境ではこの構文がおすすめです。

-- 未処理データのうち最新200件を処理済みに更新
UPDATE orders
SET processed = 'Y',
    processed_date = SYSDATE
WHERE order_id IN (
    SELECT order_id
    FROM (
        SELECT order_id
        FROM orders
        WHERE processed = 'N'
        ORDER BY order_date DESC
    )
    WHERE ROWNUM <= 200
);

-- EXISTS を使った件数制限UPDATE
UPDATE employees e
SET e.bonus = 5000
WHERE EXISTS (
    SELECT 1
    FROM (
        SELECT employee_id
        FROM employees
        WHERE department_id = 20
          AND ROWNUM <= 50
    ) sub
    WHERE sub.employee_id = e.employee_id
);

DECLARE
    v_batch_size NUMBER := 1000;  -- 1回あたりの更新件数
    v_total      NUMBER := 0;
BEGIN
    LOOP
        UPDATE large_table
        SET status = 'processed'
        WHERE status = 'pending'
          AND ROWNUM <= v_batch_size;

        -- 更新件数を取得
        v_total := v_total + SQL%ROWCOUNT;

        -- 更新対象がなくなったら終了
        EXIT WHEN SQL%ROWCOUNT = 0;

        -- バッチごとにコミット
        COMMIT;

        DBMS_OUTPUT.PUT_LINE('累計更新件数: ' || v_total);
    END LOOP;

    COMMIT;
    DBMS_OUTPUT.PUT_LINE('完了: 合計 ' || v_total || ' 件更新');
END;
/

実行結果

累計更新件数: 1000
累計更新件数: 2000
累計更新件数: 3000
...
完了: 合計 50000 件更新

注意：バッチ更新でCOMMITを挟むと、途中でエラーが発生した場合に一部のみ更新された状態になります。データの整合性を重視する場合は、1トランザクションで更新するか、処理済みフラグなどで再実行可能な設計にしてください。

DECLARE
    TYPE id_table IS TABLE OF employees.employee_id%TYPE;
    v_ids id_table;
    CURSOR c_emp IS
        SELECT employee_id
        FROM employees
        WHERE status = 'pending';
BEGIN
    OPEN c_emp;
    LOOP
        FETCH c_emp BULK COLLECT INTO v_ids LIMIT 1000;
        EXIT WHEN v_ids.COUNT = 0;

        FORALL i IN 1 .. v_ids.COUNT
            UPDATE employees
            SET status = 'active'
            WHERE employee_id = v_ids(i);

        COMMIT;
    END LOOP;
    CLOSE c_emp;
END;
/

ポイント：FORALL は通常のFORループより数倍〜数十倍高速です。PL/SQLとSQLエンジン間のコンテキストスイッチを削減できるため、大量データの更新に適しています。

-- MySQL: UPDATE + LIMIT
UPDATE employees
SET status = 'inactive'
WHERE department_id = 10
ORDER BY hire_date ASC
LIMIT 100;

-- SQL Server: UPDATE TOP
UPDATE TOP(100) employees
SET status = 'inactive'
WHERE department_id = 10;

-- PostgreSQL: サブクエリ + LIMIT
UPDATE employees
SET status = 'inactive'
WHERE ctid IN (
    SELECT ctid
    FROM employees
    WHERE department_id = 10
    ORDER BY hire_date ASC
    LIMIT 100
);

-- ステップ1: 更新対象を事前に確認
SELECT COUNT(*) AS target_count
FROM employees
WHERE status = 'pending'
  AND ROWNUM <= 500;

-- ステップ2: 更新を実行
UPDATE employees
SET status = 'active',
    updated_at = SYSDATE
WHERE status = 'pending'
  AND ROWNUM <= 500;

-- ステップ3: 更新件数を確認
-- SQL%ROWCOUNT または SQL*Plusの出力で確認

-- ステップ4: 問題なければコミット、問題があればロールバック
COMMIT;    -- または ROLLBACK;

-- SAVEPOINTで段階的に更新
SAVEPOINT before_update;

UPDATE employees
SET salary = salary * 1.05
WHERE employee_id IN (
    SELECT employee_id
    FROM (
        SELECT employee_id
        FROM employees
        WHERE department_id = 10
        ORDER BY performance_score DESC
    )
    WHERE ROWNUM <= 20
);

-- 結果を確認して問題があれば部分ロールバック
-- ROLLBACK TO before_update;

-- 問題なければコミット
COMMIT;

-- NG: UPDATE文にLIMITは使えない
UPDATE employees SET status = 'X' LIMIT 100;
-- ORA-00933: SQL command not properly ended

-- OK: ROWNUMで件数を制限
UPDATE employees SET status = 'X' WHERE ROWNUM <= 100;

-- NG: = は単一行しか受け取れない
UPDATE employees
SET bonus = 5000
WHERE employee_id = (
    SELECT employee_id FROM employees WHERE ROWNUM <= 10
);
-- ORA-01427: single-row subquery returns more than one row

-- OK: IN を使う
UPDATE employees
SET bonus = 5000
WHERE employee_id IN (
    SELECT employee_id FROM employees WHERE ROWNUM <= 10
);

-- NG: ROWNUM = 5 は結果が0件になる
UPDATE employees SET bonus = 5000 WHERE ROWNUM = 5;
-- 0行が更新されました（意図と異なる）

-- OK: ROW_NUMBER() を使って特定の行を指定
UPDATE employees
SET bonus = 5000
WHERE employee_id IN (
    SELECT employee_id
    FROM (
        SELECT employee_id,
               ROW_NUMBER() OVER (ORDER BY employee_id) AS rn
        FROM employees
    )
    WHERE rn = 5
);

-- テスト用に先頭10件だけステータスを変更
UPDATE test_orders
SET order_status = 'SHIPPED',
    ship_date = SYSDATE
WHERE order_status = 'PENDING'
  AND ROWNUM <= 10;

-- 作成日が古い順に1000件をアーカイブ対象に
UPDATE log_table
SET archive_flag = 'Y'
WHERE log_id IN (
    SELECT log_id
    FROM (
        SELECT log_id
        FROM log_table
        WHERE archive_flag = 'N'
        ORDER BY created_at ASC
    )
    WHERE ROWNUM <= 1000
);

-- 優先度が高い順に50件を処理中に変更
UPDATE task_queue
SET status = 'PROCESSING',
    started_at = SYSDATE
WHERE task_id IN (
    SELECT task_id
    FROM (
        SELECT task_id,
               ROW_NUMBER() OVER (
                   ORDER BY priority DESC, created_at ASC
               ) AS rn
        FROM task_queue
        WHERE status = 'WAITING'
    )
    WHERE rn <= 50
);

-- データ移行: 新カラムに値を設定（段階的実行）
DECLARE
    v_count NUMBER;
BEGIN
    LOOP
        UPDATE customers
        SET full_name = last_name || ' ' || first_name
        WHERE full_name IS NULL
          AND ROWNUM <= 5000;

        v_count := SQL%ROWCOUNT;
        COMMIT;
        EXIT WHEN v_count = 0;
    END LOOP;
END;
/

この記事のまとめ

• OracleにはMySQLのような UPDATE ... LIMIT 構文がない
• 最もシンプルな方法は WHERE ROWNUM <= N
• ソート後のN件を更新するにはサブクエリでORDER BYを先に評価する
• ROW_NUMBER() OVER() は範囲指定やPARTITION BYに対応する最も柔軟な方法
• Oracle 12c以降なら FETCH FIRST N ROWS ONLY が直感的
• 大量データはバッチ更新（PL/SQLのLOOP + COMMIT）で分割処理する
• 本番更新ではSAVEPOINTを活用し、確認してからCOMMITする