如何查看MongoDB Go驱动中collection.Aggregate()执行的查询语句？

可以通过两种方式查看聚合管道的实际执行内容，实现类似Hibernate的查询日志功能：

• 开启驱动Debug日志
  通过配置MongoDB客户端的日志级别为Debug，驱动会输出所有发送到服务器的命令，包括聚合管道的完整BSON结构。示例代码：

  import (
      "context"
      "log"
      "go.mongodb.org/mongo-driver/mongo"
      "go.mongodb.org/mongo-driver/mongo/options"
      "go.mongodb.org/mongo-driver/bson"
      "go.mongodb.org/mongo-driver/bson/primitive"
  )
  
  func main() {
      ctx := context.TODO()
      // 配置客户端开启Debug日志
      clientOpts := options.Client().ApplyURI("mongodb://localhost:27017").
          SetLogger(log.Default()).
          SetLogLevel(options.LogLevelDebug)
  
      client, err := mongo.Connect(ctx, clientOpts)
      if err != nil {
          log.Fatal(err)
      }
  
      collection := client.Database("your_db").Collection("your_coll")
      expireTimeLimit := // 你的过期时间变量
      pipeline := mongo.Pipeline{
          {{"$match", bson.D{
              {"created_time", bson.D{{"$lt", primitive.NewDateTimeFromTime(expireTimeLimit)}}},
              {"archived", bson.D{{"$eq", true}}},
          }}},
      }
  
      aggregateCursor, err := collection.Aggregate(ctx, pipeline)
      // 后续处理逻辑
  }
  

  运行后，日志会输出类似command=aggregate的条目，其中包含完整的聚合管道参数，对应实际执行的查询语句。

• 手动将管道转换为JSON字符串
  如果你想在执行前验证管道结构，可以将mongo.Pipeline转换为易读的JSON格式，无需发送请求到MongoDB。示例代码：

  pipeline := mongo.Pipeline{
      {{"$match", bson.D{
          {"created_time", bson.D{{"$lt", primitive.NewDateTimeFromTime(expireTimeLimit)}}},
          {"archived", bson.D{{"$eq", true}}},
      }}},
  }
  
  jsonBytes, err := bson.MarshalExtJSON(pipeline, false, false)
  if err != nil {
      log.Fatal(err)
  }
  log.Println("聚合管道内容:", string(jsonBytes))
  

  输出的JSON字符串和MongoDB Shell中使用的聚合语法基本一致，方便你直接对照验证。

内容的提问来源于stack exchange，提问作者Dean Schulze