java - 如何从java并发读取和更新mongodb的字段

Question

让我们以 Facebook 帖子为例，其中多个用户对某个帖子点赞。现在，对于某些帖子，当前数据库存储了 10 个赞，如果两个用户同时喜欢该帖子，那么两个用户都会读取 10 作为当前赞，并一一更新 11，但正确的值应该是 12。如何使用 mongodb 和 java 实现这一点。

Answer 1

检查运营商$inc .

这是 link 中的示例代码:

// connect to MongoDB server.
Mongo mongo = new Mongo("localhost", 27017);
DB database = mongo.getDB("mydb");
DBCollection collection = database.getCollection("testCollection");

// create a simple db object where counter value is 0
DBObject temp = new BasicDBObject("name", "someName").append("counter", 0);

// insert it into the collection
collection.insert(temp);

// create an increment query
DBObject modifier = new BasicDBObject("counter", 1);
DBObject incQuery = new BasicDBObject("$inc", modifier);

// create a search query
DBObject searchQuery = new BasicDBObject("name", "someName");

// increment a counter value atomically
WriteResult upRes = collection.update(searchQuery, incQuery);