3TB 규모 데이터베이스를 마이그레이션할 때 계획을 세우는 방법

-- 対象: MySQL 5.7 / 8.0、Aurora MySQL 2.x / 3.x
-- 権限: information_schema の参照権限
-- 変更作業: なし（参照のみ）
-- Production 実行: 可能
SELECT
    TABLE_SCHEMA,
    TABLE_NAME,
    ENGINE,
    TABLE_ROWS                                              AS estimated_rows,
    ROUND(DATA_LENGTH        / 1024 / 1024 / 1024, 2)       AS data_gb,
    ROUND(INDEX_LENGTH       / 1024 / 1024 / 1024, 2)       AS index_gb,
    ROUND(DATA_FREE          / 1024 / 1024 / 1024, 2)       AS free_gb,
    ROUND((DATA_LENGTH + INDEX_LENGTH) / 1024 / 1024 / 1024, 2) AS total_gb
FROM information_schema.TABLES
WHERE TABLE_TYPE = 'BASE TABLE'
  AND TABLE_SCHEMA NOT IN ('mysql', 'information_schema', 'performance_schema', 'sys')
ORDER BY (DATA_LENGTH + INDEX_LENGTH) DESC;

-- スキーマ単位の合計（全体像の把握用）
SELECT
    TABLE_SCHEMA,
    COUNT(*)                                                     AS table_count,
    ROUND(SUM(DATA_LENGTH + INDEX_LENGTH) / 1024 / 1024 / 1024, 2) AS total_gb
FROM information_schema.TABLES
WHERE TABLE_TYPE = 'BASE TABLE'
  AND TABLE_SCHEMA NOT IN ('mysql', 'information_schema', 'performance_schema', 'sys')
GROUP BY TABLE_SCHEMA
ORDER BY total_gb DESC;

-- 対象: SQL Server 2012 以降（RDS / Azure SQL Managed Instance を含む）
-- 権限: VIEW DATABASE STATE
-- 変更作業: なし（参照のみ）
-- Production 実行: 可能
SELECT
    SCHEMA_NAME(t.schema_id)                                            AS schema_name,
    t.name                                                              AS table_name,
    SUM(CASE WHEN ps.index_id IN (0, 1) THEN ps.row_count ELSE 0 END)   AS row_count,
    SUM(ps.reserved_page_count) * 8.0 / 1024 / 1024                     AS reserved_gb,
    SUM(ps.used_page_count)     * 8.0 / 1024 / 1024                     AS used_gb
FROM sys.dm_db_partition_stats AS ps
INNER JOIN sys.tables AS t
        ON t.object_id = ps.object_id
GROUP BY t.schema_id, t.name
ORDER BY SUM(ps.reserved_page_count) DESC;

# 対象: MySQL 5.7 / 8.0、Aurora MySQL（mysqldump / mydumper）
# 権限: 対象スキーマへの SELECT
# 変更作業: なし（移行元は参照のみ）。ただし読み取り負荷がかかる
# Production 実行: 負荷を許容できる時間帯で実施すること

# 1) 単一テーブルで所要時間を実測する（--no-tablespaces は MySQL 8.0 で
#    PROCESS 権限を要求されるのを避けるため）
time mysqldump \
  --single-transaction \
  --quick \
  --no-tablespaces \
  --host example-rds-endpoint \
  --user sample_user \
  --password \
  SampleDB sample_table \
  | gzip > /var/tmp/sample_table.sql.gz

# 2) 並列ダンプで実測する場合（資格情報はコマンドラインに書かず設定ファイルで渡す）
mydumper \
  --defaults-file /etc/mysql/sample-migration.cnf \
  --database SampleDB \
  --threads 8 \
  --rows 500000 \
  --compress \
  --outputdir /var/tmp/dump-sample

# 3) 出力サイズを確認し、テーブルサイズとの比率を記録する
du -sh /var/tmp/dump-sample

-- 対象: MySQL 5.7 / 8.0、Aurora MySQL（移行元・移行先の双方で同じSQLを実行する）
-- 権限: 対象テーブルへの SELECT
-- 変更作業: なし（参照のみ）。ただし全行を読むため I/O 負荷がかかる
-- Production 実行: 停止中または低負荷時間帯に実施すること

-- 1) 行数の一致を確認する（最も軽い検証。ここが合わなければ先へ進まない）
SELECT 'sample_table' AS table_name, COUNT(*) AS row_count
FROM SampleDB.sample_table;

-- 2) 主要列の値までを含めた突き合わせ（同一エンジン間の比較に使う）
SELECT
    COUNT(*)                                                   AS row_count,
    SUM(CRC32(CONCAT_WS('|', id, name, DATE_FORMAT(updated_at, '%Y-%m-%d %H:%i:%s')))) AS crc_sum
FROM SampleDB.sample_table;

-- 3) テーブル単位のチェックサム（全行を読む。大きな表では時間がかかる）
CHECKSUM TABLE SampleDB.sample_table EXTENDED;

-- 対象: MySQL 5.7 / 8.0、Aurora MySQL
-- 権限: information_schema の参照権限
-- 変更作業: なし（参照のみ）
-- Production 実行: 可能

-- 1) 直近に定義が変わったテーブル（凍結期間中に変更が入っていないかの確認に使う）
SELECT TABLE_SCHEMA, TABLE_NAME, CREATE_TIME, UPDATE_TIME
FROM information_schema.TABLES
WHERE TABLE_TYPE = 'BASE TABLE'
  AND TABLE_SCHEMA NOT IN ('mysql', 'information_schema', 'performance_schema', 'sys')
ORDER BY CREATE_TIME DESC;

-- 2) 二次インデックスの一覧（ロード後に作り直す対象の洗い出し）
SELECT
    TABLE_SCHEMA,
    TABLE_NAME,
    INDEX_NAME,
    GROUP_CONCAT(COLUMN_NAME ORDER BY SEQ_IN_INDEX) AS index_columns,
    MAX(NON_UNIQUE)                                 AS non_unique
FROM information_schema.STATISTICS
WHERE TABLE_SCHEMA NOT IN ('mysql', 'information_schema', 'performance_schema', 'sys')
  AND INDEX_NAME <> 'PRIMARY'
GROUP BY TABLE_SCHEMA, TABLE_NAME, INDEX_NAME
ORDER BY TABLE_SCHEMA, TABLE_NAME, INDEX_NAME;