快速参考

此页面显示Go驱动程序中多个MongoDB操作的驱动程序语法，并提供相关参考和API文档的链接。

操作

语法

err = coll.FindOne(context.TODO(), bson.D{{"firstName", Mike}}).Decode(&result)

[{firstName Mike}, {lastName Smith} ...]

查找多个文档

API 文档
 查找文档指南

cursor, err := coll.Find(context.TODO(), bson.D{{"age", bson.D{{"$gte", 46}}}})

[{firstName Kyle}, {age 51}, ... ]
[{firstName Omar}, {age 47}, ... ]

插入文档

API 文档
 插入文档指南

result, err := coll.InsertOne(
    context.TODO(),
    bson.D{
        {"firstName", "Aliya"},
        {"lastName", "Sanders"}
    }
)

插入多个文档

API 文档
 插入文档指南

docs := []any {
    bson.D{{"firstName", "Erik"}, {"age", 27}},
    bson.D{{"firstName", "Mohammad"}, {"lastName", "Ahmad"}, {"age", 10}},
    bson.D{{"firstName", "Todd"}},
    bson.D{{"firstName", "Juan"}, {"lastName", "Pablo"}}
 }
result, err := coll.InsertMany(context.TODO(), docs)

更新文档

API 文档
 更新文档指南

result, err := coll.UpdateOne(
    context.TODO(),
    bson.D{{"firstName", "Erik"}},
    bson.D{{"$set", bson.D{{"age", 28}}}}
)
fmt.Printf("Number of modified documents: %d\n", result.ModifiedCount)

更新多个文档

API 文档
 更新文档指南

result, err := coll.UpdateMany(
    context.TODO(),
    bson.D{{"age", bson.D{{"$gte", 65}}}},
    bson.D{{"$set", bson.D{{"classification", "senior"}}}}
)
fmt.Printf("Number of modified documents: %d\n", result.ModifiedCount)

更新文档中的数组

API 文档
 Update Arrays Guide

result, err := coll.UpdateMany(
    context.TODO(),
    bson.D{},
    bson.D{{"$push", bson.D{{"hobbies", "painting"}}}}
)

[{firstName Xiao}, {hobbies ["painting"]}, ... ]
[{firstName Omar}, {hobbies ["kayaking", "painting"]}, ... ]
...

替换文档

API 文档
 替换文档指南

result, err := coll.ReplaceOne(
    context.TODO(),
    bson.D{{"firstName", "Mick"}, {"lastName", "Salazar"}},
    bson.D{{"firstName", "Michael"}, {"lastName", "Salazar Jr."}}
)

[{{firstName Michael}, {lastName Salazar Jr.} }]

删除文档

API 文档
 删除文档指南

result, err := coll.DeleteOne(
    context.TODO(),
    bson.D{{"firstName", "Xiao"}}
)

删除多个文档

API 文档
 删除文档指南

results, err := coll.DeleteMany(
    context.TODO(),
    bson.D{{"age", bson.D{{"$lte", 12}}}}
)

批量写入

API 文档
 批量操作指南

models := []mongo.WriteModel{
    mongo.NewInsertOneModel().SetDocument(bson.D{{"firstName", "John"}, {"age", 5}}),
    mongo.NewUpdateOneModel().SetFilter(bson.D{{"firstName", "Juan"}}).
        SetUpdate(bson.D{{"$set", bson.D{{"age", 12}}}}),
}
opts := options.BulkWrite().SetOrdered(true)
results, err := coll.BulkWrite(context.TODO(), models, opts)

[{firstName John}, {age 5} ... ]
[{firstName Juan}, {age 12} ... ]

监控数据变化

API 文档
 Change Streams 指南

pipeline := mongo.Pipeline{bson.D{{"$match", bson.D{{"operationType", "insert"}}}}}
cs, err := coll.Watch(context.TODO(), pipeline)

从游标迭代访问数据

API 文档
 分别检索文档参考

cursor, err := coll.Find(context.TODO(), bson.D{})
for cursor.Next(context.TODO()) {
    var result bson.D
    if err := cursor.Decode(&result); err != nil {
        log.Fatal(err)
    }
    fmt.Println(result)
}

[{firstName Doug} ... ]
[{firstName Erik} ...]
[{firstName Oleg} ...]
...

以数组形式访问游标中的数据

API 文档
 检索所有文档参考

cursor, err := coll.Find(context.TODO(), bson.D{})
var results []bson.D
if err = cursor.All(context.TODO(), &results); err != nil {
    panic(err)
}

[{firstName Mike} ... ]
[{firstName Edgar} ...]
[{firstName Freddie} ...]
...

计算文档

API 文档
 计数文档指南

count, err := coll.CountDocuments(context.TODO(), bson.D{})

列出不同字段值

API 文档
 Distinct Values Guide

var results []string
err = coll.Distinct(context.TODO(), "firstName", bson.D{}).Decode(&results)

限制检索的文档数量

API 文档
 限制文档参考

cursor, err := coll.Find(context.TODO(), bson.D{}, options.Find().SetLimit(2))

[{firstName Xiao} ... ]
[{firstName Oleg} ...]

跳过检索到的文档

API 文档
 跳过文档引用

// the collection has 6 documents
cursor, err := coll.Find(context.TODO(), bson.D{}, options.Find().SetSkip(4))

[{firstName Sandy} ... ]
[{firstName Michael} ...]

Sort Retrieved Documents

API 文档
 对文档参考进行排序

cursor, err := coll.Find(context.TODO(), bson.D{}, options.Find().SetSort(bson.D{{"age", 1}}))

[{firstName Dev} {age 5} ... ]
[{firstName Jose} {age 7} ... ]
[{firstName Om} {age 8} ... ]

结果中的项目文档字段

API 文档
 投影指南

cursor, err := coll.Find(
    context.TODO(),
    bson.D{},
    options.Find().SetProjection(
        bson.D{{"age", 0}, {"_id",0}}
    )
)

[{firstName Lester} {lastName Franklin}]
[{firstName Wendall} {lastName Griffin}]
...

创建索引

API 文档
 Indexes Guide

model := mongo.IndexModel{Keys: bson.D{{"firstName", 1}, {"lastName", -1}}}
name, err := coll.Indexes().CreateOne(context.TODO(), model)

搜索文本

API 文档
 搜索文本指南

// Only searches on fields covered by text indexes
cursor, err := coll.Find(context.TODO(), bson.D{{"$text", bson.D{{"$search", "arts"}}}})

[{"firstName": "Emily" , "biography": "I am involved with arts and culture in my community."} ... ]
[{"firstName": "Juan" , "biography": "I attended the School of Arts for cello performance."} ... ]