CODEWITHSUNDEEP
mongodbspring-data-mongodbmongo-java-drivermongo-java
Shibankar
Shibankar

Reputation: 846

Java - Insert/Update with MongoDB collection bulkWrite

I am very new to MongoDB. Trying to understand the best option to perform Bulk Write in MongoDB. I want to periodically refresh my Application collection. The key's for documents are AppID, AppName and AppStatus. Below are the actions I want to perform in every run -

  1. Find the AppID in Application collection.
  2. If not exists, perform an insert
  3. If exists, only update the value of AppStatus key.
List<Application> applist = getAppList(); // List contains All the Application

private final MongoClient mongoClient;

private final MongoTemplate mongoTemplate;

MongoCollection<Document> collection =
                  mongoTemplate.getDb().getCollection("Application");
collection.bulkWrite (????);

How do I loop over the appList and perform a bulk insert/update ?

Upvotes: 2

Views: 2925

Answers (1)

Harshit
Harshit

Reputation: 1382

You can use org.springframework.data.mongodb.core.BulkOperations to perform bulk update/insert/upsert/delete operations.

List<Application> applist = getAppList();

List<Pair<Query, Update>> updates = new ArrayList<>(applist.size());
applist.forEach(application -> {
    Query query = Query.query(Criteria.where("AppID").is(application.getAppID()));

    Update update = new Update();
    update.set("AppID", application.getAppID());
    update.set("AppName", application.getAppName());
    update.set("AppStatus", application.getAppStatus());

    updates.add(Pair.of(query, update));
});

BulkOperations bulkOperations = mongoTemplate.bulkOps(BulkOperations.BulkMode.UNORDERED, "Application");
bulkOperations.upsert(updates);
bulkOperations.execute();

Upvotes: 6

Related Questions