mikro-orm 알아보기

// 변경 감지 예시 const article = await em.findOne(Article, 1); article.content = '업데이트된 내용'; await em.flush(); // 변경된 필드만 업데이트

const user = new User('John Doe'); em.persist(user); // 관리 상태로 표시됨

const user = await em.findOne(User, 1); user.email = 'foo@bar.com'; const car = new Car(); user.cars.add(car); // 양방향 캐스케이딩 덕분에 user 엔티티만 영속화하면 됨 // flush는 트랜잭션을 생성하고, 새 car를 삽입하고, user의 이메일을 업데이트함 await em.flush();

// 여러 엔티티 처리를 위한 패턴 const users = []; for (let i = 0; i < 1000; i++) { const user = new User(`user${i}@example.com`); users.push(user); em.persist(user); } // 모든 1000명의 사용자가 효율적인 배치로 삽입됨 await em.flush();

// 기본 인스턴스화 const user = new User('John Doe'); // em.create를 통한 인스턴스화 const user = em.create(User, { name: 'John Doe', email: 'john@example.com' }); await em.flush();

const { AsyncLocalStorage } = require('node:async_hooks'); const asyncLocalStorage = new AsyncLocalStorage(); function logWithId(msg) { const id = asyncLocalStorage.getStore(); console.log(`${id !== undefined ? id : '-'}:`, msg); } // 요청 처리 중 ID 유지 asyncLocalStorage.run(requestId, () => { logWithId('시작'); // 비동기 작업... setImmediate(() => { logWithId('종료'); // 여전히 같은 ID에 접근 가능 }); });

// 미들웨어에서 요청 컨텍스트 생성 app.use((req, res, next) => { RequestContext.create(orm.em, next); }); app.get('/', async (req, res) => { // 비동기 컨텍스트에서 자동으로 fork 사용 const authors = await orm.em.find(Book, {}); res.json(authors); });

// 1. 엔티티 수정 (flush 미실행) const author = await em.findOne(Author, 1); author.name = 'Dirty Data'; // 2. 비-PK 조회 실행 const authors = await em.find(Author, { email: 'test@test.com' }); // 3. 결과 분석 console.log(em.getUnitOfWork().getScheduledCollections()); // ▶️ 스케줄링된 flush 작업 존재 확인 (flush가 아직 안 된 상태)

// 미들웨어로 요청 컨텍스트 설정 app.addHook('onRequest', (request, reply, done) => { RequestContext.create(orm.em, done); }); // 각 요청은 자체 Identity Map을 가짐 app.get('/article', async request => { const { limit, offset } = request.query as { limit?: number; offset?: number }; const [items, total] = await db.article.findAndCount({}, { limit, offset, }); return { items, total }; });

@Injectable() export class MyService { constructor(private readonly orm: MikroORM) { } @CreateRequestContext() async doSomething() { // 별도의 컨텍스트에서 실행됨 // ... } }

// 1. 초기 조회 및 변경 const author1 = await authorRepository.findOne(1); // DB에서 '원본' 값 로드 author1.name = 'Wow'; // 변경 사항 기록 (아직 DB 반영 X) // 2. 트랜잭션 블록 em.transactional(async () => { const author = await authorRepository.findOne(1); // Identity Map에서 동일 인스턴스 획득 author.name = 'Hello'; // 즉시 author1에도 반영됨 }); // 트랜잭션 종료 시 암시적 flush 발생 → DB에 'Hello' 저장 // 3. 출력 시점 console.log(author1.name); // 'Hello' 출력 // 4. 추가 변경 및 명시적 flush author1.name = 'Good'; await em.flush(); // 최종적으로 'Good'이 DB에 저장

// 1. 초기 엔티티 로드 const author1 = await authorRepository.findOne(1); // 원본 Identity Map에 저장 author1.name = 'Wow'; // 변경 사항 추적 시작 // 2. fork()로 생성된 새 EntityManager에서 작업 em.fork().transactional(async (forkedEm) => { const author = await forkedEm.findOne(Author, 1); // 분리된 Identity Map에서 새 인스턴스 로드 author.name = 'Hello'; // fork된 인스턴스만 수정 }); // 트랜잭션 종료 시 fork된 인스턴스의 변경사항('Hello') DB 반영 // 3. 출력 시점 console.log(author1.name); // 'Wow' 출력 → 원본 인스턴스 영향 없음 // 4. 원본 인스턴스 추가 수정 author1.name = 'Good'; await em.flush(); // 원본 인스턴스의 'Good'이 최종 저장

const author = await em.findOne(Author, 1); // PK 조회 → Identity Map 사용 author.name = 'Changed'; // 변경 사항 기록 (아직 flush 안 됨) // 비-PK 조건으로 조회 const authors = await em.find(Author, { name: 'Changed' }); // 1. DB 쿼리 실행 (변경 전 데이터 조회) // 2. Identity Map과 병합 → author 인스턴스의 변경 사항('Changed')이 우선 적용 // 3. flush 발생 ❌ (단순 병합만 수행)

const orm = await MikroORM.init({ autoFlush: true, // 모든 쿼리 전 자동 flush }); // 변경 사항이 있을 경우 모든 조회 전 자동 flush author.name = 'New Value'; const result = await em.find(Author, { name: 'New Value' }); // 자동 flush 발생 → 변경 사항 DB 반영