ICode9

精准搜索请尝试: 精确搜索
首页 > 数据库> 文章详细

GoLang 中用 MongoDB Watch 监听指定字段的变化

2019-09-11 20:55:57  阅读:15  来源: 互联网

标签:mongo exists MongoDB Watch GoLang coll bson options match



需要 MongoDB 3.6 及以上, 需要 ReplicaSet 模式。
监听一个字段的变化:

func watch(coll *mongo.Collection) {
    match := bson.D{{"operationType", "update"},
        {"updateDescription.updatedFields.name", bson.D{{"$exists", true}}}}
    coll.Watch(context.Background(), mongo.Pipeline{{{"$match", match}}},
        options.ChangeStream().SetFullDocument(options.UpdateLookup))
}

监听两个字段的变化:

func watch(coll *mongo.Collection) {
    match := bson.D{
                {"operationType", "update"},
        {"$or", bson.A{
            bson.D{{"updateDescription.updatedFields.name", 
                                bson.D{{"$exists", true}},
                        }},
            bson.D{{"updateDescription.updatedFields.age", 
                                bson.D{{"$exists", true}},
                        }},
                }}

    coll.Watch(context.Background(), mongo.Pipeline{{{"$match", match}}},
        options.ChangeStream().SetFullDocument(options.UpdateLookup))
}

任意一个变化,用$or ,都变化,用$and。注意 bson.A 里面是 bson.D



标签:mongo,exists,MongoDB,Watch,GoLang,coll,bson,options,match

专注分享技术,共同学习,共同进步。侵权联系[admin#icode9.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有