Fixture 로딩하기

pnpm sonamu fixture import [entityId] [recordIds]

# User ID 1, 2, 3을 Fixture DB로 가져오기
pnpm sonamu fixture import User 1,2,3

# Post ID 42를 Fixture DB로 가져오기
pnpm sonamu fixture import Post 42

// sonamu/src/testing/fixture-manager.ts
async function importFixture(entityId: string, ids: number[]) {
  const queries = await Promise.all(
    ids.map(async (id) => {
      // 각 ID에 대한 import 쿼리 생성
      return await this.getImportQueries(entityId, "id", id);
    }),
  );

  // 쿼리 실행
  const wdb = BaseModel.getDB("w");
  for (const query of queries) {
    await wdb.raw(query);
  }
}

# User #1을 가져오면...
pnpm sonamu fixture import User 1

# 자동으로 가져옴:
# - User #1
# - User #1의 Profile (OneToOne)
# - Profile의 관련 데이터

async function getImportQueries(entityId: string, field: string, id: number): Promise<string[]> {
  // 순환 참조 방지
  const recordKey = `${entityId}#${field}#${id}`;
  if (this.visitedRecords.has(recordKey)) {
    return [];
  }
  this.visitedRecords.add(recordKey);

  // 레코드 가져오기
  const entity = EntityManager.get(entityId);
  const [row] = await wdb(entity.table).where(field, id).limit(1);

  if (!row) {
    throw new Error(`${entityId}#${id} row를 찾을 수 없습니다.`);
  }

  // BelongsTo 관계 처리
  const relatedQueries = [];
  for (const [, relation] of Object.entries(entity.relations)) {
    if (isBelongsToOneRelationProp(relation)) {
      const relatedId = row[`${relation.name}_id`];
      if (relatedId) {
        // 재귀적으로 관련 데이터 가져오기
        relatedQueries.push(...(await this.getImportQueries(relation.with, "id", relatedId)));
      }
    }
  }

  // INSERT 쿼리 생성
  const selfQuery = `INSERT IGNORE INTO fixture.${entity.table} 
    (SELECT * FROM production.${entity.table} WHERE id = ${id})`;

  return [...relatedQueries, selfQuery];
}

async function fixture_import(entityId: string, recordIds: number[]) {
  await setupFixtureManager();

  // 1. 프로덕션 → Fixture DB
  await FixtureManager.importFixture(entityId, recordIds);

  // 2. Fixture DB → Test DB
  await FixtureManager.sync();
}

pnpm sonamu fixture import User 1,2,3

{ entityId: 'User', field: 'id', id: 1 }
{ entityId: 'Profile', field: 'id', id: 1 }
INSERT IGNORE INTO fixture.profiles ...
INSERT IGNORE INTO fixture.users ...

{ entityId: 'User', field: 'id', id: 2 }
{ entityId: 'Profile', field: 'id', id: 2 }
INSERT IGNORE INTO fixture.profiles ...
INSERT IGNORE INTO fixture.users ...

✅ Import complete! Syncing to test DB...

$ pnpm sonamu fixture import Post 42

{ entityId: 'Post', field: 'id', id: 42 }
{ entityId: 'User', field: 'id', id: 5 }
{ entityId: 'Profile', field: 'id', id: 5 }
{ entityId: 'Category', field: 'id', id: 10 }

INSERT IGNORE INTO fixture.profiles ...
INSERT IGNORE INTO fixture.users ...
INSERT IGNORE INTO fixture.categories ...
INSERT IGNORE INTO fixture.posts ...

✅ Import complete!

# User #1과 그의 모든 Posts를 가져오려면
# 1. User 가져오기
pnpm sonamu fixture import User 1

# 2. User의 Posts를 별도로 가져오기
pnpm sonamu fixture import Post 10,11,12

# HasMany는 자동으로 추적되지 않음
# (너무 많은 데이터가 가져와질 수 있음)

# Post #1과 관련 Tags를 가져오려면
# 1. Post 가져오기
pnpm sonamu fixture import Post 1

# 2. 중간 테이블 데이터는 수동으로 처리
# (또는 fixture.ts에서 직접 생성)

# User #1을 두 번 가져와도 안전
pnpm sonamu fixture import User 1
pnpm sonamu fixture import User 1

# 결과: User #1은 한 번만 저장됨

// 순환 참조 예시:
// User #1 → Profile #1
// Profile #1 → User #1 (역참조)

// 방문 기록으로 방지
private visitedRecords = new Set<string>();

const recordKey = `${entityId}#${field}#${id}`;
if (this.visitedRecords.has(recordKey)) {
  return []; // 이미 방문함 - 스킵
}
this.visitedRecords.add(recordKey);

# ✅ 올바른 방법: 필요한 것만
pnpm sonamu fixture import User 1,2

# ❌ 잘못된 방법: 너무 많은 데이터
pnpm sonamu fixture import User 1,2,3,4,5,6,7,8,9,10,11,12,13,14,15

# 다양한 케이스를 포함하는 데이터 선택
pnpm sonamu fixture import User 1    # 일반 사용자
pnpm sonamu fixture import User 100  # 관리자
pnpm sonamu fixture import User 500  # 프리미엄 사용자

// api/src/testing/fixture.ts
import { createFixtureLoader } from "sonamu/test";

export const loadFixtures = createFixtureLoader({
  // 프로덕션에서 가져온 실제 데이터 사용
  realUser01: async () => {
    const userModel = new UserModel();
    // ID 1은 이미 fixture DB에 있다고 가정
    const { user } = await userModel.getUser("C", 1);
    return user;
  },

  // 테스트용 새 데이터 생성
  testUser: async () => {
    const userModel = new UserModel();
    const { user } = await userModel.create({
      username: "test",
      email: "test@example.com",
      password: "password",
    });
    return user;
  },
});

Error: User#999 row를 찾을 수 없습니다.

Error: Access denied for user 'readonly'

-- Fixture DB 사용자에게 쓰기 권한 부여
GRANT ALL PRIVILEGES ON fixture.* TO 'user'@'%';

# 한 번에 너무 많은 ID를 가져오면 느림
pnpm sonamu fixture import User 1,2,3,...,100

# 해결: 여러 번 나눠서 실행
pnpm sonamu fixture import User 1,2,3,4,5
pnpm sonamu fixture import User 6,7,8,9,10