Skip to content

카드 표시값 파생 조회의 전량 스캔 제거 #974

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
m-a-king wants to merge 1 commit into
base: dev
Choose a base branch
from
Open

카드 표시값 파생 조회의 전량 스캔 제거 #974

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
18 changes: 11 additions & 7 deletions src/main/kotlin/com/depromeet/piki/item/repository/ItemSnapshotJpaRepository.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -85,19 +85,23 @@ interface ItemSnapshotJpaRepository : JpaRepository<ItemSnapshot, Long> {
@Param("itemId") itemId: Long,
): ItemSnapshot?

// 카드 표시값 파생(#857)의 배치 조회 — item 별 마지막 기계(SERVER/SERVER_LLM) READY 하나씩.
// 서브쿼리로 item 별 max(id)만 골라, 이력이 긴 item 이 섞여도 행 수가 item 수를 넘지 않는다.
// 카드 표시값 파생(#857)의 배치 조회 1단계 — item 별 마지막 기계(SERVER/SERVER_LLM) READY 의 **id 만** 고른다.
// 출처 null(도입 전 행)은 기계 여부를 모르므로 제외한다 — 그 item 은 호출부가 포인터 버전으로 fallback 한다.
//
// 엔티티 조회(2단계)를 한 문장에 합치지 않는다. 합치면(`where s.id in (select max(s2.id) ...)`) MySQL 이
// 서브쿼리를 임시 테이블로 materialize 한 뒤 **바깥 테이블 전체를 훑으며 매 행을 대조**하는 계획을 고른다
// (부하테스트 #911 실측: 서브쿼리는 19행/76ms 로 정확한데 바깥이 10만 행 스캔, 합계 483ms).
// id 목록을 앱으로 받아 2단계에서 상수 IN 으로 넘기면 양쪽 모두 인덱스를 탄다. 왕복이 하나 늘지만
// 1단계가 0.24ms 라 그 비용을 크게 밑돈다.
@Query(
"select s from ItemSnapshot s where s.id in (" +
"select max(s2.id) from ItemSnapshot s2 where s2.itemId in :itemIds " +
"select max(s2.id) from ItemSnapshot s2 where s2.itemId in :itemIds " +
"and s2.status = com.depromeet.piki.item.domain.ItemStatus.READY " +
"and s2.source in (com.depromeet.piki.item.domain.ItemSnapshotSource.SERVER, com.depromeet.piki.item.domain.ItemSnapshotSource.SERVER_LLM) " +
"and s2.deletedAt is null group by s2.itemId)",
"and s2.deletedAt is null group by s2.itemId",
)
fun findLatestMachineReadyByItemIds(
fun findLatestMachineReadyIdsByItemIds(
@Param("itemIds") itemIds: Collection<Long>,
): List<ItemSnapshot>
): List<Long>

// 병합(#825) — 진(임시) item 의 모든 버전을 이긴 item 소속으로 재부모화한다. wish·tournament_item 은 snapshot 만
// 참조하므로 이 한 문장으로 참조가 자동 추종된다. native bulk 라 auditing 을 우회해 updated_at 을 직접 갱신한다.
Expand Down
10 changes: 8 additions & 2 deletions src/main/kotlin/com/depromeet/piki/item/repository/ItemSnapshotRepositoryImpl.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -20,8 +20,14 @@ class ItemSnapshotRepositoryImpl(

override fun findLatestMachineReadyByItemId(itemId: Long): ItemSnapshot? = itemSnapshotJpaRepository.findLatestMachineReadyByItemId(itemId)

override fun findLatestMachineReadyByItemIds(itemIds: Collection<Long>): List<ItemSnapshot> =
itemIds.takeIf { it.isNotEmpty() }?.let { itemSnapshotJpaRepository.findLatestMachineReadyByItemIds(it) }.orEmpty()
// 두 문장으로 나눠 실행한다(#911) — 한 문장으로 합치면 MySQL 이 바깥 테이블을 전량 스캔한다.
// 자세한 이유는 ItemSnapshotJpaRepository.findLatestMachineReadyIdsByItemIds 주석 참조.
override fun findLatestMachineReadyByItemIds(itemIds: Collection<Long>): List<ItemSnapshot> {
if (itemIds.isEmpty()) return emptyList()
val snapshotIds = itemSnapshotJpaRepository.findLatestMachineReadyIdsByItemIds(itemIds)
if (snapshotIds.isEmpty()) return emptyList()
return itemSnapshotJpaRepository.findAllById(snapshotIds)
}

override fun reparentAll(
fromItemId: Long,
Expand Down
Loading