8

认为这会很简单，但我的价值保持不变（0）。

我想做的是在用户收到他们尚未阅读的消息时增加我的 UnreadMessages 字段，然后在他们收到消息时减少它。所以我认为这样的代码会起作用：

var userHelper = new MongoHelper<User>();
//increment
userHelper.Collection.Update(Query.EQ("Id", userId.ToId()), Update.Inc("UnreadMessages", 1));
//decrement
userHelper.Collection.Update(Query.EQ("Id", userId.ToId()), Update.Inc("UnreadMessages", -1));

运行这些后，不会引发任何错误，但值也不会改变。不，我没有一个接一个地运行，因为上面的代码可以被解释:)

更新

这是我的助手类：

public class MongoHelper<T> : Sandbox.Services.IMongoHelper<T> where T : class
{
    public MongoCollection<T> Collection { get; private set; }

    public MongoHelper()
    {
        var con = new MongoConnectionStringBuilder(ConfigurationManager.ConnectionStrings["MongoDB"].ConnectionString);
        var server = MongoServer.Create(con);
        var db = server.GetDatabase(con.DatabaseName);
        Collection = db.GetCollection<T>(typeof(T).Name.ToLower());
    }
}

多亏了特拉维斯的回答，我才能做到这一点：

MongoHelper<UserDocument> userHelper = new MongoHelper<UserDocument>();
            var user = userHelper.Collection.FindAndModify(Query.EQ("Username", "a"), SortBy.Null, Update.Inc("MessageCount", 1), true).GetModifiedDocumentAs<UserDocument>();
4

1 回答 1

16

不确定你的助手是做什么的。这是我使用的一个工作片段：

        var query = Query.And(Query.EQ("_id", keyName));
        var sortBy = SortBy.Null;
        var update = Update.Inc("KeyValue", adjustmentAmount);
        var result = collection.FindAndModify(query, sortBy, update, true);

因此，“查询”查找文档，更新执行增量，FindAndModify 将它们放在一起并实际访问数据库。

于 2012-05-14T12:16:27.817 回答