[스프링] 5. 동적 정렬과 필터링

실제 API에서는 "최신순", "좋아요순" 같은 정렬 옵션과 "맑음 필터", "키워드 검색" 같은 필터가 함께 들어온다. 커서 조회에 이런 동적 조건을 어떻게 결합하는지 다룬다.

SortBy Enum 설계

정렬 기준을 문자열로 받으면 오타나 잘못된 값이 들어올 수 있다. Enum으로 정의하면 컴파일 타임에 안전하게 관리할 수 있다.

@Getter
@RequiredArgsConstructor
public enum SortBy {
    CREATED_AT("createdAt"),
    LIKE_COUNT("likeCount");

    private final String value;
}

각 enum 상수에 실제 엔티티 필드명을 매핑해둔다. QueryDSL에서 동적 정렬을 만들 때 이 값을 사용한다.

SortDirection은 단순히 방향만 나타내면 된다.

public enum SortDirection {
    ASCENDING,
    DESCENDING
}

동적 OrderSpecifier 생성

QueryDSL의 orderBy는 OrderSpecifier를 받는다. 클라이언트가 보낸 SortBy와 SortDirection에 따라 런타임에 정렬 조건을 만들어야 한다.

private OrderSpecifier<?> createOrderSpecifier(
        SortBy sortBy, SortDirection direction) {

    Order order = direction == SortDirection.ASCENDING
            ? Order.ASC : Order.DESC;

    return switch (sortBy) {
        case CREATED_AT -> new OrderSpecifier<>(order, feed.createdAt);
        case LIKE_COUNT -> new OrderSpecifier<>(order, feed.likeCount);
    };
}

switch 표현식으로 enum 값마다 Q클래스의 경로를 매핑한다. 새로운 정렬 기준이 추가되면 enum 상수와 case만 추가하면 된다.

실제 쿼리에서는 보조 정렬을 항상 함께 건다.

return queryFactory
        .selectFrom(feed)
        .where(/* ... */)
        .orderBy(
                createOrderSpecifier(condition.sortBy(), condition.sortDirection()),
                new OrderSpecifier<>(Order.DESC, feed.id)
        )
        .limit(condition.limit() + 1)
        .fetch();

보조 정렬로 id를 추가하는 이유는 1차 정렬 값이 동일한 행이 있을 때 순서를 보장하기 위해서다.

커서 조건과 정렬의 연동

정렬 기준이 바뀌면 커서 조건도 함께 바뀌어야 한다. created_at 기준 정렬이면 커서도 created_at으로, like_count 기준이면 커서도 like_count로 비교해야 한다.

private BooleanExpression cursorCondition(
        SortBy sortBy, SortDirection direction,
        String cursor, UUID idAfter) {

    if (cursor == null || idAfter == null) {
        return null;
    }

    return switch (sortBy) {
        case CREATED_AT -> timeCursorCondition(
                Instant.parse(cursor), idAfter, direction);
        case LIKE_COUNT -> countCursorCondition(
                Long.parseLong(cursor), idAfter, direction);
    };
}

각 정렬 기준별로 커서 조건 메서드를 분리하면 가독성이 좋아진다.

private BooleanExpression timeCursorCondition(
        Instant cursor, UUID idAfter, SortDirection direction) {

    if (direction == SortDirection.DESCENDING) {
        return feed.createdAt.lt(cursor)
                .or(feed.createdAt.eq(cursor)
                        .and(feed.id.lt(idAfter)));
    }
    return feed.createdAt.gt(cursor)
            .or(feed.createdAt.eq(cursor)
                    .and(feed.id.gt(idAfter)));
}

정렬 방향에 따라 비교 연산자가 바뀌는 것에 주의하자. DESC면 lt, ASC면 gt다.

동적 필터 조건

필터는 BooleanExpression을 반환하는 메서드로 각각 분리한다. 값이 null이면 null을 반환해서 조건을 무시한다.

private BooleanExpression keywordLike(String keyword) {
    if (keyword == null || keyword.isBlank()) {
        return null;
    }
    return feed.content.containsIgnoreCase(keyword);
}

private BooleanExpression skyStatusEqual(SkyStatus skyStatus) {
    if (skyStatus == null) {
        return null;
    }
    return feed.weather.skyStatus.eq(skyStatus);
}

private BooleanExpression precipitationTypeEqual(PrecipitationType type) {
    if (type == null) {
        return null;
    }
    return feed.weather.precipitationType.eq(type);
}

private BooleanExpression authorIdEqual(UUID authorId) {
    if (authorId == null) {
        return null;
    }
    return feed.author.id.eq(authorId);
}

QueryDSL의 where에 이 메서드들을 나열하면 null인 조건은 자동으로 제외된다.

.where(
        cursorCondition(condition.sortBy(), condition.sortDirection(),
                        condition.cursor(), condition.idAfter()),
        keywordLike(condition.keywordLike()),
        skyStatusEqual(condition.skyStatusEqual()),
        precipitationTypeEqual(condition.precipitationTypeEqual()),
        authorIdEqual(condition.authorIdEqual())
)

이 패턴이 QueryDSL의 가장 큰 장점이다. 필터가 추가될 때마다 메서드 하나만 만들고 where에 추가하면 된다. if-else 체인으로 쿼리를 조립할 필요가 없다.

전체 쿼리 조립

지금까지 만든 조각들을 합치면 완성된 Repository 메서드가 된다.

@Override
public List<Feed> searchFeeds(FeedSearchCondition condition) {
    return queryFactory
            .selectFrom(feed)
            .join(feed.author, user).fetchJoin()
            .join(feed.weather, weather).fetchJoin()
            .where(
                    cursorCondition(condition.sortBy(), condition.sortDirection(),
                                    condition.cursor(), condition.idAfter()),
                    keywordLike(condition.keywordLike()),
                    skyStatusEqual(condition.skyStatusEqual()),
                    precipitationTypeEqual(condition.precipitationTypeEqual()),
                    authorIdEqual(condition.authorIdEqual())
            )
            .orderBy(
                    createOrderSpecifier(condition.sortBy(),
                                         condition.sortDirection()),
                    new OrderSpecifier<>(Order.DESC, feed.id)
            )
            .limit(condition.limit() + 1)
            .fetch();
}

각 조건이 독립적인 메서드로 분리되어 있어서, 어떤 조건이 적용되는지 한눈에 파악할 수 있다.

자주 하는 실수

---