GraphQL N+1: 쿼리 비용과 올바른 설계 방향

1[Query] 12ms  SELECT * FROM post
2[Query] 3ms   SELECT * FROM comment WHERE post_id = 1
3[Query] 3ms   SELECT * FROM comment WHERE post_id = 2
4[Query] 3ms   SELECT * FROM comment WHERE post_id = 3
5...

11번:  SELECT * FROM post               → post 20개 반환
22번:  SELECT * FROM comment WHERE post_id = 1
33번:  SELECT * FROM comment WHERE post_id = 2
4...
521번: SELECT * FROM comment WHERE post_id = 20
6
7총 쿼리: 1 + 20 = 21번

1query {
2  posts {
3    content
4    comments {
5      content
6    }
7  }
8}

1@Resolver(() => Post) // "이 클래스는 Post 타입의 필드 resolver야"
2export class PostResolver {
3  @Query(() => [Post])
4  async posts() {
5    return this.postService.findAll();
6    // SELECT * FROM post
7  }
8
9  @ResolveField(() => [Comment])
10  async comments(@Parent() post: Post) {
11    // GraphQL이 Post.comments 필드를 만날 때마다 이 함수를 호출한다
12    return this.commentService.findByPostId(post.id);
13    // SELECT * FROM comment WHERE post_id = ?
14  }
15}

11. posts() 실행
2   → SELECT * FROM post
3   → [post1, post2, post3] 반환
4
52. GraphQL: "post1의 comments 필드 필요"
6   → comments(parent: post1) 실행
7   → SELECT * FROM comment WHERE post_id = 1
8
93. GraphQL: "post2의 comments 필드 필요"
10   → comments(parent: post2) 실행
11   → SELECT * FROM comment WHERE post_id = 2
12
134. GraphQL: "post3의 comments 필드 필요"
14   → comments(parent: post3) 실행
15   → SELECT * FROM comment WHERE post_id = 3
16
17총 쿼리: 1 + 3 = 4번

1posts 1000개: 쿼리 1001번 → 약 1-3초
2posts 5000개: 쿼리 5001번 → 타임아웃

1query {
2  posts {
3    # 20개
4    comments {
5      # 각 post마다 10개 → 200개
6      author {
7        # 각 comment마다 → 쿼리 201번 추가
8        name
9      }
10    }
11  }
12}

1posts 조회:    1번
2comments 조회: 20번  (post 개수만큼)
3author 조회:   200번 (comment 개수만큼)
4
5총 쿼리: 221번

1query {
2  posts {
3    content
4    comments {
5      content
6    }
7  }
8}

1@Query(() => [Post])
2async posts() {
3  return this.postService.findAll({
4    relations: ['comments']
5  });
6}

1SELECT post.id, post.content,
2       comment.id, comment.content, comment.post_id
3FROM post
4LEFT JOIN comment ON comment.post_id = post.id

1query {
2  posts {
3    content # comments 요청 안 함
4  }
5}

1-- 프론트가 comments 안 요청해도
2SELECT post.*, comment.*   -- 항상 이렇게 실행됨
3FROM post LEFT JOIN comment ON ...

1return this.postService.findAll({
2  relations: ["comments", "tags", "author", "attachments"],
3});
4// 프론트가 뭘 요청하든 항상 4개 테이블 JOIN

1@Resolver(() => Post)
2export class PostResolver {
3  @Query(() => [Post])
4  async posts() {
5    return this.postService.findAll();
6    // SELECT * FROM post — post만, JOIN 없음
7  }
8
9  @ResolveField(() => [Comment])
10  async comments(@Parent() post: Post) {
11    return this.commentService.findByPostId(post.id);
12  }
13}

1-- 1번: posts 조회
2SELECT * FROM post
3
4-- 2번: post 1의 comments
5SELECT * FROM comment WHERE post_id = 1
6
7-- 3번: post 2의 comments
8SELECT * FROM comment WHERE post_id = 2
9
10-- 4번: post 3의 comments
11SELECT * FROM comment WHERE post_id = 3

1페이지네이션 없이 all: posts 1000개 → 쿼리 1001번  ← 위험
2페이지당 20개:         posts 20개   → 쿼리 21번    ← indexed 쿼리라 수십 ms

1@Injectable()
2export class CommentLoader {
3  private loader = new DataLoader<number, Comment[]>(
4    async (postIds: readonly number[]) => {
5      const comments = await this.commentService.findByPostIds([...postIds]);
6      // SELECT * FROM comment WHERE post_id IN (1, 2, 3)
7
8      // 각 postId에 해당하는 comments를 매핑해서 반환
9      return postIds.map((id) => comments.filter((c) => c.postId === id));
10    }
11  );
12
13  load(postId: number) {
14    return this.loader.load(postId);
15  }
16}

1@ResolveField(() => [Comment])
2async comments(@Parent() post: Post) {
3  return this.commentLoader.load(post.id);
4  // 개별 호출처럼 보이지만 DataLoader가 모아서 처리
5}

1-- 1번: posts 조회
2SELECT * FROM post
3
4-- 2번: 모든 post의 comments 한 번에
5SELECT * FROM comment WHERE post_id IN (1, 2, 3)

1// 가벼운 resolver — comments 없음
2@Query(() => [Post])
3async posts() {
4  return this.postService.findAll();
5}
6
7// 무거운 resolver — comments JOIN 포함
8@Query(() => [Post])
9async postsWithComments() {
10  return this.postService.findAll({ relations: ['comments'] });
11}

1posts()                          // 기본
2postsWithComments()              // comments 포함
3postsWithCommentsAndAuthor()     // comments + author 포함
4postsWithTags()                  // tags 포함
5postsForFeedPage()               // 피드 페이지용
6postsForAdminPage()              // 어드민 페이지용