Rork 製アプリの expo-sqlite で、テーブル構造を変えてもデータを消さない — PRAGMA user_version で作る順次マイグレーション

// db/migrations.ts
import * as SQLite from 'expo-sqlite';
 
// 配列の index が「1つ前 → このバージョン」に対応します。
// index 0 が v0→v1、index 1 が v1→v2 …と続きます。
type Migration = (db: SQLite.SQLiteDatabase) => Promise<void>;
 
const MIGRATIONS: Migration[] = [
  // --- v0 → v1: 初期スキーマ ---
  async (db) => {
    await db.execAsync(`
      CREATE TABLE favorites (
        id           INTEGER PRIMARY KEY NOT NULL,
        wallpaper_id TEXT NOT NULL UNIQUE
      );
    `);
  },
 
  // --- v1 → v2: 追加日時を持たせる（カラム追加は ALTER TABLE で足りる） ---
  async (db) => {
    await db.execAsync(
      `ALTER TABLE favorites ADD COLUMN added_at INTEGER NOT NULL DEFAULT 0;`
    );
  },
 
  // --- v2 → v3: UNIQUE を外し、コレクション単位の複合ユニークに作り替える ---
  async (db) => {
    await rebuildFavoritesTable(db); // 再構築が要る変更（後述）
  },
];

// db/migrations.ts（続き）
export async function migrate(db: SQLite.SQLiteDatabase): Promise<void> {
  // 外部キーはマイグレーション中は必ず切ります。
  // ⚠️ この PRAGMA はトランザクションの外で実行しないと無視されます（後述の落とし穴）。
  await db.execAsync('PRAGMA foreign_keys = OFF');
 
  try {
    const row = await db.getFirstAsync<{ user_version: number }>(
      'PRAGMA user_version'
    );
    let current = row?.user_version ?? 0;
    const target = MIGRATIONS.length;
 
    // 将来の DB を古いコードで開いた場合は、書き込ませずに止めます。
    // ここで黙って進めると、新機能が作った列を旧コードが壊します。
    if (current > target) {
      throw new Error(
        `DB schema v${current} is newer than app-supported v${target}.`
      );
    }
 
    while (current < target) {
      const next = current + 1;
      // 1マイグレーション = 1トランザクション。途中で失敗したら丸ごと巻き戻します。
      await db.withTransactionAsync(async () => {
        await MIGRATIONS[current](db);
        // user_version の更新もトランザクション内で行い、適用と不可分にします。
        await db.execAsync(`PRAGMA user_version = ${next}`);
      });
      current = next;
    }
 
    // 参照の壊れた行が残っていないかを最後に検査します。
    const broken = await db.getAllAsync('PRAGMA foreign_key_check');
    if (broken.length > 0) {
      throw new Error(`foreign_key_check failed: ${broken.length} rows`);
    }
  } finally {
    await db.execAsync('PRAGMA foreign_keys = ON');
  }
}

-- rebuildFavoritesTable の中身（考え方）。foreign_keys は呼び出し側で OFF 済み。
-- 1. 新しい定義でテーブルを作る（UNIQUE を外し、複合ユニークインデックスに寄せる）
CREATE TABLE favorites_new (
  id           INTEGER PRIMARY KEY NOT NULL,
  wallpaper_id TEXT    NOT NULL,
  collection   TEXT    NOT NULL DEFAULT 'default',
  added_at     INTEGER NOT NULL DEFAULT 0
);
 
-- 2. 旧テーブルから、移せる列だけを SELECT して流し込む
INSERT INTO favorites_new (id, wallpaper_id, added_at)
SELECT id, wallpaper_id, added_at FROM favorites;
 
-- 3. 旧テーブルを捨て、新テーブルを正式名にリネームする
DROP TABLE favorites;
ALTER TABLE favorites_new RENAME TO favorites;
 
-- 4. インデックス・トリガー・ビューを新テーブルに対して作り直す
CREATE UNIQUE INDEX idx_fav_unique ON favorites (wallpaper_id, collection);

async function rebuildFavoritesTable(db: SQLite.SQLiteDatabase) {
  await db.execAsync(`
    CREATE TABLE favorites_new (
      id           INTEGER PRIMARY KEY NOT NULL,
      wallpaper_id TEXT    NOT NULL,
      collection   TEXT    NOT NULL DEFAULT 'default',
      added_at     INTEGER NOT NULL DEFAULT 0
    );
    INSERT INTO favorites_new (id, wallpaper_id, added_at)
      SELECT id, wallpaper_id, added_at FROM favorites;
    DROP TABLE favorites;
    ALTER TABLE favorites_new RENAME TO favorites;
    CREATE UNIQUE INDEX idx_fav_unique ON favorites (wallpaper_id, collection);
  `);
}

// 旧世代（v1）の DB を意図的に作り、データを1件入れておく
async function seedV1Database() {
  const db = await SQLite.openDatabaseAsync(':memory:');
  await db.execAsync(`
    CREATE TABLE favorites (
      id           INTEGER PRIMARY KEY NOT NULL,
      wallpaper_id TEXT NOT NULL UNIQUE
    );
    PRAGMA user_version = 1;
  `);
  await db.runAsync(
    'INSERT INTO favorites (wallpaper_id) VALUES (?)',
    'sunset-01'
  );
  return db;
}
 
// v1 の DB に migrate() を流し、データが保持されているかを検証する
const db = await seedV1Database();
await migrate(db);
 
const rows = await db.getAllAsync('SELECT * FROM favorites');
console.log(rows);
// 期待する出力:
// [{ id: 1, wallpaper_id: 'sunset-01', collection: 'default', added_at: 0 }]