個人開発者のためのコスト削減術：Supabase 1つのデータベースで複数プロジェクトを運用する

// drizzle.config.ts
export default defineConfig({
  // ... その他の設定
  schemaFilter: ['my_project_schema'], // <--- 重要：スキーマ名を指定
});

// lib/db/schema.ts
import { pgSchema } from 'drizzle-orm/pg-core';

// 1. スキーマを定義
export const myProjectSchema = pgSchema('my_project_schema'); // <--- drizzle.config.ts の名前と一致させる

// 2. pgTable を myProjectSchema.table に置き換え
// 旧: export const user = pgTable('user', { ... })
// 新:
export const user = myProjectSchema.table('user', {
  id: uuid('id').primaryKey().defaultRandom(),
  // ... その他のカラム
});

// 3. Enum もスキーマにスコープする必要があります
// 旧: export const roleEnum = pgEnum('role', ['admin', 'user'])
// 新:
export const roleEnum = myProjectSchema.enum('role', ['admin', 'user']);

import { drizzle } from 'drizzle-orm/postgres-js';
import postgres from 'postgres';
import * as schema from '../lib/db/schema';
import * as dotenv from 'dotenv';
import { getTableConfig } from 'drizzle-orm/pg-core';

dotenv.config();

const { OLD_DB_URL, NEW_DB_URL } = process.env;

// 移行順序を定義（外部キーの依存関係を考慮：基本テーブルを先に）
const tables = [
  { name: 'user', table: schema.user }, // 基本テーブル
  { name: 'pricing_plans', table: schema.pricingPlans },
  { name: 'orders', table: schema.orders }, // user と pricing_plans に依存
  // ... その他のテーブル
];

async function main() {
  const sourceClient = postgres(OLD_DB_URL!, { max: 1 });
  const destClient = postgres(NEW_DB_URL!, { max: 1 });
  const destDb = drizzle(destClient, { schema });

  for (const t of tables) {
    console.log(`テーブルを移行中: ${t.name}...`);

    // 1. カラムマッピングを構築（db_column -> schema_property）
    const columnMapping: Record<string, string> = {};
    const tableColumns = t.table;
    for (const key in tableColumns) {
      // @ts-ignore
      const col = tableColumns[key];
      // スキーマプロパティキーは通常 camelCase（例：cardTitle）
      // col.name は実際の DB カラム（例：card_title）
      if (col && typeof col === 'object' && 'name' in col) {
        columnMapping[col.name] = key;
      }
    }

    // 2. 古いデータベースからデータを取得（public スキーマを想定）
    const rows = await sourceClient`SELECT * FROM public.${sourceClient(t.name)}`;
    
    if (rows.length === 0) continue;

    // 3. データを変換（snake_case -> camelCase）
    const transformRow = (row: any) => {
      const newRow: any = {};
      for (const dbColName in row) {
        const schemaKey = columnMapping[dbColName];
        // スキーマキーが定義されていればそれを使用、なければ元のカラム名を維持
        newRow[schemaKey || dbColName] = row[dbColName];
      }
      return newRow;
    };

    // 4. 新しいデータベースにバッチ挿入
    const batchSize = 100;
    for (let i = 0; i < rows.length; i += batchSize) {
      const batch = rows.slice(i, i + batchSize).map(transformRow);
      await destDb.insert(t.table).values(batch).onConflictDoNothing();
    }
  }

  await sourceClient.end();
  await destClient.end();
  console.log('移行完了！');
}

main();

DATABASE_URL=your-new-supabase-connection-string