如何使用GoLang在MongoDB中执行插入操作？

哈喽！今天心血来潮给大家带来了《如何使用GoLang在MongoDB中执行插入操作？》，想必大家应该对Golang都不陌生吧，那么阅读本文就都不会很困难，以下内容主要涉及到，若是你正在学习Golang，千万别错过这篇文章~希望能帮助到你！

我有一个存储大量数据的数组，我需要将这些数据插入到 mongodb 中。

我可以使用下面的代码来实现这一点。但需要1.5分钟。我需要在几分之一秒内推动。还有其他方法可以将大量数组数据推送到 mongodb 中吗？

headdet是一个数组，有300万条记录。

session, err := mgo.Dial(“localhost”)
if err != nil {
  panic(err)
}
defer session.Close()
// Optional. Switch the session to a monotonic behavior.
session.SetMode(mgo.Monotonic, true)

c := session.DB("Test").C("Indicators")

for i := 0; i < len(HeadDet); i++ {
  err = c.Insert(HeadDet[i])
}
if err != nil {
  log.Fatal(err)
}

我已引用此链接

解决方案

首先，删除 labix.org/mgo （又名 gopkg.in/mgo.v2），它已经过时，无人维护。请改用社区支持的分叉：github.com/globalsign/mgo。

接下来，要批量执行插入或更新，请使用 Bulk API introduced in MongoDB 2.6。mgo 驱动程序支持使用 mgo.Bulk 类型的批量操作。

您想要插入“300 万条记录”。对于那些不知道的人来说，"lakh" 是印度编号系统中的一个单位，等于十万 (100,000)。所以 300 万等于 300 万。

使用批量 api，您可以通过以下方式有效地插入所有这些内容：

c := session.db("test").c("indicators")

// bulk, ordered
bulk := c.bulk()
for i := 0; i < len(headdet); i++ {
    bulk.insert(headdet[i])
}
res, err := bulk.run()

请注意，如果您不关心插入的顺序，则可以将批量操作置于无序模式，这可能会加快速度：

// BULK, UNORDERED
bulk := c.Bulk()
bulk.Unordered()
for i := 0; i < len(HeadDet); i++ {
    bulk.Insert(HeadDet[i])
}
res, err := bulk.Run()

作为比较，在我的计算机上（客户端服务器是同一台计算机，因此没有网络延迟），包含 300 万个单独插入的循环需要 5 分 43 秒。

插入 300 万个文档的有序批量操作需要 18.6 秒！

插入 300 万个文档的无序批量操作需要 18.22 秒！

好了，本文到此结束，带大家了解了《如何使用GoLang在MongoDB中执行插入操作？》，希望本文对你有所帮助！关注golang学习网公众号，给大家分享更多Golang知识！