【Oracle】Data Pump のパラレル処理で高速化する方法｜parallel・%U・パラレル度の決め方・動的変更・効かないケースまで解説

# パラレル度 4 でスキーマをエクスポート
expdp hr/password \
    directory=DP_DIR \
    dumpfile=hr_export_%U.dmp \
    logfile=hr_export.log \
    schemas=HR \
    parallel=4

# 結果: hr_export_01.dmp, hr_export_02.dmp, ... が生成される

# パラレル度 4 でインポート
impdp hr/password \
    directory=DP_DIR \
    dumpfile=hr_export_%U.dmp \
    logfile=hr_import.log \
    schemas=HR \
    parallel=4

# NG: %U がない → パラレルが実質的に効かない
expdp hr/password dumpfile=export.dmp parallel=4
# → ファイルが 1 つのため、ワーカーが順番待ちになる

# OK: %U でファイルを分割
expdp hr/password dumpfile=export_%U.dmp parallel=4
# → export_01.dmp, export_02.dmp, ... が並列に書き込まれる

# 複数ファイルを明示的に指定する方法も可
expdp hr/password dumpfile=exp01.dmp,exp02.dmp,exp03.dmp,exp04.dmp parallel=4

# 実行中のジョブに接続
expdp hr/password attach=SYS_EXPORT_SCHEMA_01

# 対話モードで以下を実行
Export> PARALLEL=8
# → ワーカー数が 4 → 8 に動的に増加

Export> PARALLEL=2
# → ワーカー数を 2 に縮小（負荷を下げたい場合）

Export> STATUS
# → 現在の進捗を確認

-- Data Pump ワーカーの状態を確認
SELECT owner_name, job_name, operation, job_mode,
       state, degree  -- degree = 現在のパラレル度
FROM dba_datapump_jobs
WHERE state = 'EXECUTING';

-- ワーカープロセスの詳細
SELECT sid, serial#, program
FROM v$session
WHERE program LIKE '%DW%'    -- DW = Data Pump Worker
   OR program LIKE '%DM%';   -- DM = Data Pump Master

# パラレル + 圧縮でエクスポート（高速 + 省スペース）
expdp hr/password \
    directory=DP_DIR \
    dumpfile=hr_compressed_%U.dmp \
    logfile=hr_compressed.log \
    schemas=HR \
    parallel=4 \
    compression=ALL

# compression=ALL: メタデータ + データの両方を圧縮
# ファイルサイズが 50%〜80% 削減される（データ内容による）
# 注意: Advanced Compression Option のライセンスが必要（DATA_ONLY 圧縮の場合）

# インポート前にテーブルを NOLOGGING にする
-- ALTER TABLE hr.employees NOLOGGING;

# パラレルインポート + transform で NOLOGGING を強制
impdp hr/password \
    directory=DP_DIR \
    dumpfile=hr_export_%U.dmp \
    logfile=hr_import.log \
    schemas=HR \
    parallel=4 \
    transform=DISABLE_ARCHIVE_LOGGING:Y

# DISABLE_ARCHIVE_LOGGING: インポート時にアーカイブログを抑制
# （Oracle 12c 以降で利用可能）

# インポート後に LOGGING に戻す
-- ALTER TABLE hr.employees LOGGING;

# 1 ファイルあたり 2GB に制限（NFS やクラウドストレージの制約対策）
expdp hr/password \
    directory=DP_DIR \
    dumpfile=hr_export_%U.dmp \
    logfile=hr_export.log \
    schemas=HR \
    parallel=4 \
    filesize=2G

# 2GB を超えると自動的に次のファイル（%U の番号が進む）が作成される
# parallel=4 + filesize=2G → 最大数十ファイルになることもある

-- Data Pump ジョブの進捗（パーセント）
SELECT sl.sid, sl.serial#,
       sl.sofar, sl.totalwork,
       ROUND(sl.sofar / NULLIF(sl.totalwork, 0) * 100, 1) AS pct_done,
       sl.elapsed_seconds, sl.time_remaining
FROM v$session_longops sl
WHERE sl.opname LIKE 'SYS_EXPORT%' OR sl.opname LIKE 'SYS_IMPORT%'
ORDER BY sl.start_time DESC;

-- ワーカーの CPU / I/O 状況
SELECT s.sid, s.program,
       st.value AS cpu_used
FROM v$session s
JOIN v$sesstat st ON s.sid = st.sid
JOIN v$statname sn ON st.statistic# = sn.statistic#
WHERE s.program LIKE '%DW%'
  AND sn.name = 'CPU used by this session'
ORDER BY st.value DESC;

# 夜間バッチ: フルエクスポート（パラレル + 圧縮 + 日付付きファイル名）
expdp system/password \
    directory=DP_DIR \
    dumpfile=full_$(date +%Y%m%d)_%U.dmp \
    logfile=full_$(date +%Y%m%d).log \
    full=y \
    parallel=8 \
    compression=ALL

# 10GB 超のテーブルをパラレルエクスポート
expdp hr/password \
    directory=DP_DIR \
    dumpfile=orders_%U.dmp \
    logfile=orders_export.log \
    tables=HR.ORDERS \
    parallel=4 \
    filesize=2G \
    flashback_time="TO_TIMESTAMP(SYSDATE)"

# 移行元でパラレルエクスポート
expdp system/password \
    directory=DP_DIR \
    dumpfile=migration_%U.dmp \
    logfile=migration_exp.log \
    schemas=HR,SALES,INVENTORY \
    parallel=8 \
    compression=ALL

# ダンプファイルを移行先に転送
# scp migration_*.dmp targetserver:/oracle/dpdir/

# 移行先でパラレルインポート
impdp system/password \
    directory=DP_DIR \
    dumpfile=migration_%U.dmp \
    logfile=migration_imp.log \
    parallel=8 \
    transform=DISABLE_ARCHIVE_LOGGING:Y