利用golang驱动操作MongoDB数据库的步骤

安装MongoDB驱动程序

mkdr mongodb 
cd mongodb 
go mod init 
go get go.mongodb.org/mongo-driver/mongo

连接MongoDB

创建一个main.go文件

将以下包导入main.go文件中

package main

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

连接MongoDB的URI格式为

mongodb://[username:password@]host1[:port1][,...hostN[:portN]][/[defaultauthdb][?options]]

单机版

mongodb://localhost:27017

副本集

mongodb://mongodb0.example.com:27017,mongodb1.example.com：27017，mongodb2.example.com：27017 /?replicaSet = myRepl

分片集群

mongodb://mongos0.example.com:27017,mongos1.example.com:27017,mongos2.example.com:27017

mongo.Connect()接受Context和options.ClientOptions对象，该对象用于设置连接字符串和其他驱动程序设置。
通过context.TODO()表示不确定现在使用哪种上下文，但是会在将来添加一个

使用Ping方法来检测是否已正常连接MongoDB

func main() {
 clientOptions := options.Client().ApplyURI("mongodb://admin:password@localhost:27017")
 var ctx = context.TODO()
 // Connect to MongoDB
 client, err := mongo.Connect(ctx, clientOptions)
 if err != nil {
 log.Fatal(err)
 }
 // Check the connection
 err = client.Ping(ctx, nil)
 if err != nil {
 log.Fatal(err)
 }
 fmt.Println("Connected to MongoDB!")
 defer client.Disconnect(ctx)

列出所有数据库

databases, err := client.ListDatabaseNames(ctx, bson.M{})
if err != nil {
 log.Fatal(err)
}
fmt.Println(databases)

在GO中使用BSON对象

MongoDB中的JSON文档以称为BSON（二进制编码的JSON）的二进制表示形式存储。与其他将JSON数据存储为简单字符串和数字的数据库不同，BSON编码扩展了JSON表示形式，例如int，long，date，float point和decimal128。这使应用程序更容易可靠地处理，排序和比较数据。Go Driver有两种系列用于表示BSON数据：D系列类型和Raw系列类型。

D系列包括四种类型：

D：BSON文档。此类型应用在顺序很重要的场景下，例如MongoDB命令。
M：无序map。除不保留顺序外，与D相同。
A：一个BSON数组。
E：D中的单个元素。

插入数据到MongoDB

插入单条文档

//定义插入数据的结构体
type sunshareboy struct {
Name string
Age int
City string
}
//连接到test库的sunshare集合,集合不存在会自动创建
collection := client.Database("test").Collection("sunshare")
wanger:=sunshareboy{"wanger",24,"北京"}
insertOne,err :=collection.InsertOne(ctx,wanger)
if err != nil {
log.Fatal(err)
}
fmt.Println("Inserted a Single Document: ", insertOne.InsertedID)

执行结果如下

![](https://s4.51cto.com/images/blog/202011/07/378adacb26314b3532fa8947e3516fc1.png?x-oss-process=image/watermark,size_16,text_QDUxQ1RP5Y2a5a6i,color_FFFFFF,t_100,g_se,x_10,y_10,shadow_90,type_ZmFuZ3poZW5naGVpdGk=)
#### 同时插入多条文档
```go
collection := client.Database("test").Collection("sunshare")
dongdong:=sunshareboy{"张冬冬",29,"成都"}
huazai:=sunshareboy{"华仔",28,"深圳"}
suxin:=sunshareboy{"素心",24,"甘肃"}
god:=sunshareboy{"刘大仙",24,"杭州"}
qiaoke:=sunshareboy{"乔克",29,"重庆"}
jiang:=sunshareboy{"姜总",24,"上海"}
//插入多条数据要用到切片
boys:=[]interface{}{dongdong,huazai,suxin,god,qiaoke,jiang}
insertMany,err:= collection.InsertMany(ctx,boys)
if err != nil {
log.Fatal(err)
}
fmt.Println("Inserted multiple documents: ", insertMany.InsertedIDs)

从MongDB中查询数据

查询单个文档

查询单个文档使用collection.FindOne()函数，需要一个filter文档和一个可以将结果解码为其值的指针

var result sunshareboy
filter := bson.D{{"name","wanger"}}
err = collection.FindOne(context.TODO(), filter).Decode(&result)
if err != nil {
 log.Fatal(err)
}
fmt.Printf("Found a single document: %+v\n", result)

返回结果如下

Connected to MongoDB!
Found a single document8ZIZvNi8Zh.Y8Kxz^KiK{KKyJv~vXxnh~KK'6~{YNi[hУb673&66У&R673''W67#Ц7G6BFF6B6w&3F6Ч6W'fW%7FGW2W'"6VFF&6R&FЦ7G'6F'6W'fW%7FGW2"'6"6FW2ЦbW'"Цf'"ЧfW'fW%7FGW2ЦfVf7BTW'fW%7FGW2ЧfW'6W'"6W'fW%7FGW2W'"'fW'6ЦfW'6G&RЦbW'"Цf'"Ч&SУFcУ.>;SУТ&VcGG3rF"&rBvvfW"WF&V&WFW&r#G3rF"&rBvvfW"WFТ&VcGG3F&rF"rvfW"vV&WFW&r#G3F&rF"rvfW"vУVУjX[>KyJv~Xi8D.i[h[>yNih~z[K{NZIyX[6v~Xi8D.Xh^Z{J.zKK^XNih~zhn{~{XyNyX[>ih~z[ZJ~Z^YZIiJ