Bulk & History

대량 쓰기 목적에 따라 insert, ID upsert, 업무 키 upsert와 snapshot을 구분합니다.

Bulk API 선택

saveAll

각 entity를 save로 처리하는 Flux

saveAllBulk

입력을 모아 insertAll로 신규 문서를 insert

saveAllBulkUpsert

@Id 또는 id field 기준. id가 null이면 insert, 있으면 upsert

saveAllBulkUpsertByKey

하나 이상의 업무 field를 composite key로 사용

deleteBulk

id 기준 unordered bulk delete. 선택적으로 {collection}_remove에 backup

업무 키 upsert

java

field 이름은 Java declared field 기준

saveAllBulkUpsertByKey는 reflection으로 entity declared field를 찾습니다. Mongo raw field alias가 아니라 Java field 이름을 전달합니다. 키 값 하나라도 null이면 현재 구현은 해당 entity를 insert합니다.

History snapshot

java

기본 collection suffix는 _history입니다. snapshot은 deep clone 후 id를 null로 지워 새 history 문서로 insert합니다. createHistory(entity, "audit")처럼 suffix를 바꿀 수 있습니다.

대량 stream 주의

bulk operation은 내부 작업을 쌓은 뒤 한 번 execute

무한 Flux를 그대로 넘기지 말고 batch 단위로 window/buffer를 나누세요. saveAllBulk는 전체 입력을 list로 모으므로 특히 크기 제한이 필요합니다.