我有一个 SQL 语句，我正尝试使用 mongodb 数据库在 golang 中重新创建它。我试图重新创建的声明如下:

select date,
       sum(case when field1 = "true" then 1 else 0) trueField1,
       sum(case when field1 = "false" then 1 else 0) falseField1,
       sum(case when field2 = "true" then 1 else 0) trueField2,
       sum(case when field2 = "false" then 1 else 0) falseField2
from myTable
group by date

我需要在给定日期汇总一些组合并将它们转储出来，但我不确定如何通过 golang/mongodb 完成它。

已编辑:这是我根据上次请求的起点。从 o1 可以看出，它显示了我在第一个总和/计数上要追求的结果。我还想对另一个字段 isDelivered 求和，并在同一天对它们求和，返回同一天的计数。我可以就如何完成这项任务获得一些指导吗？

    o1 := bson.M{
        "$match" : bson.M {
            "retailer" : clientId,
            "isComplete" : true,
            "pkgStatus.finalized" : true,
            },
    }

    o2 := bson.M {
        "$project" : bson.M {
            "_id" : 1,
            "createdAt" : 1,
        },
    }

    o3 := bson.M{
        "$group": bson.M{
            "_id" : bson.M{ "$dayOfYear": "$createdAt" },
            "total" : bson.M{ "$sum" : 1},
            "first" : bson.M{ "$min" : "$createdAt" },
        },
    }

    o4 := bson.M {
        "$sort" : bson.M { "_id" : 1 },
    }

    totalMessages := []bson.M{msgsStarted, o2, o3, o4}

    operations := []bson.M{o1, o2, o3, o4}

    pipe := cMessages.Pipe(operations)

    results := []bson.M{}
    err := pipe.All(&results)

    if err != nil {
        fmt.Printf("Error: %s\n", err)
        return
    }

    for _, resultRec := range results {
        myDate := fmt.Sprintf("%s", resultRec["first"])
        fmt.Printf("%s, %d\n", myDate[0:10], resultRec["total"])
    }

EDIT2

模式定义

messages {
  "_id" : {
    "$oid" : bson.ObjectId
  },
  "isComplete" : bool,
  "status" : {
    "cancelled" : bool,
    "finalized" : bool,
    "delivered" : bool
  },
  "createdDate" : {
    "$date" : ISODate
  } 

我正在尝试采用您之前提供的指导的 $cond 语句并将其嵌套在 $and 命令中，以便我可以执行以下操作:

sum(case when isComplete = true and status.finalized = true then 1 else 0)

我一直在玩以下游戏:

tf1c := bson.M{"$cond": []interface{}{bson.M{"$eq": []interface{}{"iscomplete", true}}, 1, 0}}

但不确定语法是否准确。我相信它应该遵循这样的东西，但不确定如何准确翻译它(以下来自另一个 stackoverflow 线程)

"$cond": [{
    "$and": [{
      "$eq": ["isComplete", true]
    }, {
      "$eq": ["pkgStatus.finalized", true]
    }]
}, 1, 0]

再次感谢指导!

展开 map

如何展开 map ？

map[_id:map[date:2014-12-25 retailer:ObjectIdHex("548a9de8a4ea9d690f6df8e4")]] 

检索值。我尝试了以下但它返回 null。

fmt.Printf("%s\n", resultRec["_id.date"])

最佳答案

好的。这样更好，但是仍然没有关于您的数据库架构的信息来了解您正在使用的数据类型。如果所有字段都是字符串格式，下面是 Mongo 等效的 SQL 查询:

package main

import (
    "gopkg.in/mgo.v2"
    "gopkg.in/mgo.v2/bson"
    "fmt"
)

func main() {
    session, err := mgo.Dial("mongodb://127.0.0.1:27017/db")

    if err != nil {
        panic(err)
    }
    defer session.Close()
    session.SetMode(mgo.Monotonic, true)

    db := session.DB("db")
    c := db.C("MyTable")

    tf1c := bson.M{"$cond": []interface{}{bson.M{"$eq": []interface{}{"$field1", "true"}}, 1, 0}}
    ff1c := bson.M{"$cond": []interface{}{bson.M{"$eq": []interface{}{"$field1", "false"}}, 1, 0}}
    tf2c := bson.M{"$cond": []interface{}{bson.M{"$eq": []interface{}{"$field2", "true"}}, 1, 0}}
    ff2c := bson.M{"$cond": []interface{}{bson.M{"$eq": []interface{}{"$field2", "false"}}, 1, 0}}

    pipe := c.Pipe(
        []bson.M{
            bson.M{
                "$group": bson.M{
                    "_id": "$date",
                    "trueField1": bson.M{"$sum": tf1c},
                    "falseField1": bson.M{"$sum": ff1c},
                    "trueField2": bson.M{"$sum": tf2c},
                    "falseField2": bson.M{"$sum": ff2c},
                },
            },
            bson.M{
                "$sort": bson.M{"_id": -1},
            },
        },
    )
    result := []bson.M{}
    err = pipe.All(&result)
    if err != nil {
        panic(err)
    }
    fmt.Printf("%+v", result)
}

更新:

pipe := c.Pipe(
        []bson.M{
            bson.M{
                "$project": bson.M{
                    "year": bson.M{"$year": "$createdDate"},
                    "month": bson.M{"$month": "$createdDate"},
                    "day": bson.M{"$dayOfMonth": "$createdDate"},
                    "val": bson.M{"$cond":[]interface{}{
                        bson.M{
                            "$and": []interface{}{
                                bson.M{"$eq": []interface{}{"$isComplete", true}},
                                bson.M{"$eq": []interface{}{"$status.finalized", true}},
                            },
                        },
                        1,
                        0,
                    }},
                },
            },
            bson.M{
                "$group": bson.M{
                    "_id": bson.M{
                        "$concat": []interface{}{
                            bson.M{"$substr": []interface{}{"$year", 0, -1}},
                            "-",
                            bson.M{"$substr": []interface{}{"$month", 0, -1}},
                            "-",
                            bson.M{"$substr": []interface{}{"$day", 0, -1}},
                        },
                    },
                    "cnt": bson.M{"$sum": "$val"},
                },
            },
            bson.M{
                "$sort": bson.M{"_id": -1},
            },
        },
    )

关于mongodb - golang mongodb 聚合中的 Transact-SQL 等价物，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/38449780/