diff --git a/src/main/java/com/repo/whopper/infrastructure/mongo/MongoUtils.java b/src/main/java/com/repo/whopper/infrastructure/mongo/MongoUtils.java index c63e1c95..c4bd2a08 100644 --- a/src/main/java/com/repo/whopper/infrastructure/mongo/MongoUtils.java +++ b/src/main/java/com/repo/whopper/infrastructure/mongo/MongoUtils.java @@ -1,9 +1,11 @@ package com.repo.whopper.infrastructure.mongo; +import org.springframework.data.mongodb.core.BulkOperations; import org.springframework.data.mongodb.core.query.Query; import java.util.stream.Stream; public interface MongoUtils { Stream find(Query query, Class targetClass); + BulkOperations bulkOps(Class targetClass); } diff --git a/src/main/java/com/repo/whopper/infrastructure/mongo/MongoUtilsImpl.java b/src/main/java/com/repo/whopper/infrastructure/mongo/MongoUtilsImpl.java index 28f6cbb7..2eb049f6 100644 --- a/src/main/java/com/repo/whopper/infrastructure/mongo/MongoUtilsImpl.java +++ b/src/main/java/com/repo/whopper/infrastructure/mongo/MongoUtilsImpl.java @@ -1,6 +1,7 @@ package com.repo.whopper.infrastructure.mongo; import lombok.RequiredArgsConstructor; +import org.springframework.data.mongodb.core.BulkOperations; import org.springframework.data.mongodb.core.MongoTemplate; import org.springframework.data.mongodb.core.query.Query; import org.springframework.stereotype.Component; @@ -12,7 +13,13 @@ public class MongoUtilsImpl implements MongoUtils { private final MongoTemplate mongoTemplate; + @Override public Stream find(Query query, Class targetClass) { return mongoTemplate.find(query, targetClass).stream(); } + + @Override + public BulkOperations bulkOps(Class targetClass) { + return mongoTemplate.bulkOps(BulkOperations.BulkMode.UNORDERED, targetClass); + } }