如何通过其中包含 javascript 的 mongo_go_driver 运行聚合查询？

怎么入门Golang编程？需要学习哪些知识点？这是新手们刚接触编程时常见的问题；下面golang学习网就来给大家整理分享一些知识点，希望能够给初学者一些帮助。本篇文章就来介绍《如何通过其中包含 javascript 的 mongo_go_driver 运行聚合查询？》，涉及到，有需要的可以收藏一下

我正在使用 mongo-go-driver (https://godoc.org/github.com/mongodb/mongo-go-driver/mongo)，我正在尝试做相当于

db.getcollection('mycollection').aggregate([
    { $lookup: {
        from: "anothercollection",
        localfield: "_id",
        foreignfield: "foreignid",
        as: "matched_docs"
    }},
    { $match: { "matched_docs": { $eq: [] } } },
    { $project: { "matched_docs": 0 } },
    { $match: {"datetimegmt":{$lt: (new date(date.now()-1000*60*60*24)).toisostring()}} }
])

我不知道如何使用此方法放置 javascript 命令。

pipeline := bson.newarray(
    bson.vc.documentfromelements(
        bson.ec.subdocumentfromelements( 
        //yada, yada, yada...
cursor, err := collection.aggregate(ctx, pipeline)

（总的来说，我不喜欢这种方法。我希望能够在 robo 3t 中设计查询并将它们复制到我的代码中，就像使用 mysql workbench 和 php 一样）

此方法在管道中产生一个空的 *bson.array

pipelineJSON := `[
    { $lookup: {
        from: "anothercollection",
        localField: "_id",
        foreignField: "interactionID",
        as: "matched_docs"
    }},
    { $match: { "matched_docs": { $eq: [] } } },
    { $project: { "matched_docs": 0 } },
    { $match: {"dateTimeGMT":{$lt: (new Date(Date.now()-1000*60*60*24)).toISOString()}} }
]`
pipeline, err = bson.ParseExtJSONArray(pipelineJSON)

如果有一种方法可以将命令作为字符串发送给 mongo（就像我将其输入 robo 3t 中一样）并返回 *mongo.cursor，我真的很喜欢它。我应该使用更好的驱动程序（仍然有人支持）吗？我需要自己编写代码吗？

谢谢！

解决方案

我不知道如何使用此方法放入 javascript 命令。

虽然我知道这不是您用例的首选方法，但这是使用 mongo-go-driver v1.0 将 aggregation pipeline 构造为 bson.D 的方法：

pipeline := mongo.pipeline{
    {{"$lookup", bson.d{
        {"from", "tour"}, 
        {"localfield", "_id"}, 
        {"foreignfield", "foreignid"}, 
        {"as", "matched_docs"},
    }}},
    {{"$match", bson.d{
        {"matched_docs", bson.d{
            {"$eq", bson.a{}}},
        }, 
    }}},
    {{"$project", bson.d{
        {"matched_docs", 0}, 
    }}},        
    {{"$match", bson.d{
        {"datetimegmt", bson.d{
            {"$lt", time.now().adddate(0, 0, -1).utc().format(time.rfc3339)},
            }, 
        },
    }}},  
}

{ $project: { "matched_docs": 0 } },

您还可以将两个 $match 组合成一个管道阶段，然后在末尾附加 $project 。例如：

db.collection.aggregate([
    { "$lookup":{
        "from":"anothercollection",
        "localfield":"_id",
        "foreignfield":"foreignid",
        "as":"matched_docs"}
    }, 
    { "$match": { "matched_docs": { "$eq": [] }, 
                  "datetimegmt": { "$lt": (new date(date.now()-1000*60*60*24)).toisostring() } 
                } 
    }, 
    { "$project": { "matched_docs": 0 } }
]);

{ $match: {"datetimegmt":{$lt: (new date(date.now()-1000*60*60*24)).toisostring()}} }

根据 $match 值，您似乎将日期存储为 string 而不是 Date 对象。我建议将日期存储为正确的 date 对象，以获得更好的索引性能。

使用 parseextjsonarray 确实有效，但是与 mongo shell 不同，您不能包含 js 或不带引号的聚合阶段/表达式运算符

mongo shell 提供了一些方便的方法/类型，即 objectid() 等来构造 MongoDB Extended JSON。 mongo shell 不仅仅是一个 javascript shell。

如果您的目标只是评估 javascript 表达式，您可以使用 go 的 javascript 解释器 (otto)。一个粗略的例子是：

// note the unquoted fields, as json is javascript native. 
raw := `[
    { "$lookup": {
        from: "anothercollection",
        localfield: "_id",
        foreignfield: "foreignid",
        as: "matched_docs"
    }},
    { $match: { "matched_docs": { $eq: [] },
                "datetimegmt":{$lt: (new date(date.now()-1000*60*60*24)).toisostring() }, 
              }
    },
    { $project: { "matched_docs": 0 } },
]`
vm := otto.new()
// evaluate js expression
jsvalue, err := vm.eval(raw)

// export to go interface{}
output, err := jsvalue.export()

// convert interface{} to bson.document bytes 
bsonbytes, err := bson.marshal(output)

// convert bson.document bytes to bson.document
pipeline, err := bson.unmarshaldocument(bsonbytes)

请注意，如上所述，有一些对象无法被普通 javascript 解释器识别，即 ObjectId()

我希望能够在 robo 3t 中设计查询并将其复制到我的代码中，就像使用 mysql workbench 和 php 一样

虽然目前不支持go，但值得一提的是MongoDB Compass有一个功能到Export Query to Language。当前版本（1.15）支持java、node、c#和python3。希望 go 将来会出现。

使用 parseextjsonarray 确实有效，但是与 mongo shell 不同，您不能包含 js 或不带引号的聚合阶段/表达式运算符。请注意，比较的 iso 日期是在 golang 中计算的，并且聚合阶段和聚合表达式运算符已用引号引起来。

pipelineJSON := fmt.Sprintf(`[
    { "$lookup": {
        "from": "another_collection",
        "localField": "_id",
        "foreignField": "interactionID",
        "as": "matched_docs"
    }},
    { "$match": { "matched_docs": { "$eq": [] } } },
    { "$project": { "matched_docs": 0 } },
    { "$match": {"dateTimeGMT":{"$lt": "%s"}} }
]`, time.Now().AddDate(0, 0, -1).UTC().Format(time.RFC3339))
pipeline, err = bson.ParseExtJSONArray(pipelineJSON)

对于我询问的驱动程序，这就是答案。

终于介绍完啦！小伙伴们，这篇关于《如何通过其中包含 javascript 的 mongo_go_driver 运行聚合查询？》的介绍应该让你收获多多了吧！欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识，快来关注吧！