从游标访问数据
Overview
在本指南中,可以了解如何使用游标访问数据。
游标是一种机制,允许应用程序遍历数据库结果,同时在给定时间内只在内存中保留其中的一个子集。匹配多个文档的读取操作会使用游标分批返回这些文档,而不是一次性返回所有文档。
示例游标
每个部分都使用以下 cursor
变量,它是一个包含集合中所有文档的 Cursor
结构体:
cursor, err := coll.Find(context.TODO(), bson.D{}) if err != nil { panic(err) }
在本指南的示例中,驱动程序将 cursor
变量中保存的文档解码到示例 MyStruct
结构。
重要
游标不是 goroutine 安全的。请勿在多个 goroutine 中同时使用同一游标。
分别检索文档
要在阻止当前 goroutine 的同时从游标单独检索文档,请使用 Next()
方法。
如果满足所有以下条件,该方法返回一个文档:
当前已提供或稍后会提供文档。
驱动程序没有报告任何错误。
上下文未过期。
for cursor.Next(context.TODO()) { var result MyStruct if err := cursor.Decode(&result); err != nil { log.Fatal(err) } fmt.Printf("%+v\n", result) } if err := cursor.Err(); err != nil { log.Fatal(err) }
可追加游标
要尝试从可追加游标检索文档,请使用 TryNext()
方法。
如果满足所有以下条件,该方法返回一个文档:
当前有文档可供使用。
驱动程序没有报告任何错误。
上下文未过期。
for { if cursor.TryNext(context.TODO()) { var result MyStruct if err := cursor.Decode(&result); err != nil { log.Fatal(err) } fmt.Printf("%+v\n", result) continue } if err := cursor.Err(); err != nil { log.Fatal(err) } if cursor.ID() == 0 { break } }
检索所有文档
要将所有查询结果填充到数组中,请使用 All()
方法:
var results []MyStruct if err = cursor.All(context.TODO(), &results); err != nil { panic(err) } for _, result := range results { fmt.Printf("%+v\n", result) }
关闭游标
当应用程序不再需要游标时,请使用 Close()
方法关闭游标。此方法能够释放游标在客户端应用程序和 MongoDB 服务器中消耗的资源。
defer cursor.Close(context.TODO())
更多信息
要了解有关本指南中讨论的操作的更多信息,请参阅以下指南:
API 文档
如需进一步了解游标以及如何访问游标元素,请参阅以下 API 文档: