golang如何操作MongoDB数据库_golang操作MongoDB数据库方法-Golang-PHP中文网

官方推荐使用 mongo-go-driver（go.mongodb.org/mongo-driver/mongo），连接需 context 和 uri，crud 操作须注意 bson.m 与结构体解码、updateone 的 $set 用法、aggregate 游标必须 close。

golang如何操作mongodb数据库_golang操作mongodb数据库方法

用 `mongo-go-driver` 连接并执行基本 CRUD

Go 官方推荐且唯一维护的 MongoDB 驱动是 go.mongodb.org/mongo-driver/mongo，别用已归档的 mgo。连接前先确保 MongoDB 服务在运行（如 mongodb://localhost:27017），并安装驱动：

go get go.mongodb.org/mongo-driver/mongo

连接和插入示例：

import (
    "context"
    "go.mongodb.org/mongo-driver/mongo"
    "go.mongodb.org/mongo-driver/mongo/options"
    "go.mongodb.org/mongo-driver/bson"
)

client, err := mongo.Connect(context.TODO(), options.Client().ApplyURI("mongodb://localhost:27017"))
if err != nil {
    panic(err)
}
defer client.Disconnect(context.TODO())

collection := client.Database("testdb").Collection("users")
res, err := collection.InsertOne(context.TODO(), bson.M{"name": "Alice", "age": 30})
if err != nil {
    panic(err)
}
// res.InsertedID 是新文档的 ObjectID

注意：context 不可传 nil，生产环境应带超时（如 context.WithTimeout）；bson.M 是 map[string]interface{} 的别名，字段名默认按字典序序列化，但不影响查询。

`Find` 和 `FindOne` 查询时如何正确解码结果

直接用 bson.M 接收查询结果最简单，但结构体更安全、易维护。关键点在于结构体字段必须导出（首字母大写），且用 bson tag 显式指定键名，否则无法映射：

type User struct {
    ID   primitive.ObjectID `bson:"_id,omitempty"`
    Name string             `bson:"name"`
    Age  int                `bson:"age"`
}

var user User
err := collection.FindOne(context.TODO(), bson.M{"name": "Alice"}).Decode(&user)

常见错误：

Golang Uber Dig

使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器，提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象，支持命名依赖等

下载

忘记加 & 导致 Decode 报 cannot decode BSON array into a *main.User
结构体字段未导出，解码后字段值全为零值（Name 为空字符串，Age 为 0）
查询无结果时 FindOne 返回 mongo.ErrNoDocuments，需显式检查，不能只看 err == nil

使用 `UpdateOne` 修改数据时的坑

UpdateOne 第二个参数是更新操作符（如 $set、$inc），不是原始文档。直接传 bson.M{"name": "Bob"} 会清空整个文档，只剩这个字段：

// ❌ 错误：覆盖整个文档
collection.UpdateOne(ctx, filter, bson.M{"name": "Bob"})

// ✅ 正确：只改 name 字段
collection.UpdateOne(ctx, filter, bson.M{"$set": bson.M{"name": "Bob"}})

// ✅ 正确：同时改多个字段
collection.UpdateOne(ctx, filter, bson.M{"$set": bson.M{"name": "Bob", "age": 31}, "$inc": bson.M{"score": 10}})

其他要点：

filter 必须是匹配条件（如 bson.M{"_id": id}），不能传空 bson.D{} 否则可能误更新第一条
若想插入不存在的文档，用 Upsert: true 选项
$setOnInsert 只在插入时生效，适合设置创建时间等默认字段

聚合查询（`Aggregate`）怎么写才不卡死

Aggregate 返回的是 *mongo.Cursor，必须调用 Next + Decode 迭代，且最后要 Close。漏掉 Close 会导致连接泄漏，尤其在高并发下：

cursor, err := collection.Aggregate(ctx, []bson.M{
    {"$match": bson.M{"age": bson.M{"$gt": 25}}},
    {"$group": bson.M{"_id": "$name", "count": bson.M{"$sum": 1}}},
})
if err != nil {
    panic(err)
}
defer cursor.Close(ctx) // ⚠️ 必须 close！

for cursor.Next(ctx) {
    var result bson.M
    if err := cursor.Decode(&result); err != nil {
        panic(err)
    }
    fmt.Println(result)
}
if err := cursor.Err(); err != nil { // 检查迭代过程中的错误
    panic(err)
}

容易忽略的点：