使用golang驱动操作MongoDB数据库
安装MongoDB驱动程序
mkdr mongodb
cd mongodb
go mod init
go get go.mongodb.org/mongo-driver/mongo
连接MongoDB
创建一个main.go文件
将以下包导入main.go文件中
package mainimport ("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 MongoDBclient, err := mongo.Connect(ctx, clientOptions)if err != nil {log.Fatal(err)}// Check the connectionerr = 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 document: {Name:wanger Age:24 City:北京}
Connection to MongoDB closed.
查询多个文档
查询多个文档使用collection.Find()函数,这个函数会返回一个游标,可以通过他来迭代并解码文档,当迭代完成后,关闭游标
- Find函数执行find命令并在集合中的匹配文档上返回Cursor。
- filter参数必须是包含查询运算符的文档,并且可以用于选择结果中包括哪些文档。不能为零。空文档(例如bson.D {})应用于包含所有文档。
opts参数可用于指定操作的选项,例如我们可以设置只返回五条文档的限制(https://godoc.org/go.mongodb.org/mongo-driver/mongo/options#Find)。
//定义返回文档数量 findOptions := options.Find() findOptions.SetLimit(5)//定义一个切片存储结果 var results []*sunshareboy//将bson.D{{}}作为一个filter来匹配所有文档 cur, err := collection.Find(context.TODO(), bson.D{{}}, findOptions) if err != nil {log.Fatal(err) } //查找多个文档返回一个游标 //遍历游标一次解码一个游标 for cur.Next(context.TODO()) {//定义一个文档,将单个文档解码为resultvar result sunshareboyerr := cur.Decode(&result)if err != nil {log.Fatal(err)}results = append(results, &result) } fmt.Println(result) if err := cur.Err(); err != nil {log.Fatal(err) } //遍历结束后关闭游标 cur.Close(context.TODO()) fmt.Printf("Found multiple documents (array of pointers): %+v\n", results)
返回结果如下
Connected to MongoDB!
{wanger 24 北京}
{张冬冬 29 成都}
{华仔 28 深圳}
{素心 24 甘肃}
{刘大仙 24 杭州}
Found multiple documents (array of pointers): &[0xc000266450 0xc000266510 0xc000266570 0xc0002665d0 0xc000266630]
Connection to MongoDB closed.
更新MongoDB文档
更新单个文档
更新单个文档使用collection.UpdateOne()函数,需要一个filter来匹配数据库中的文档,还需要使用一个update文档来更新操作
- filter参数必须是包含查询运算符的文档,并且可以用于选择要更新的文档。不能为零。如果过滤器不匹配任何文档,则操作将成功,并且将返回MatchCount为0的UpdateResult。如果过滤器匹配多个文档,将从匹配的集合中选择一个,并且MatchedCount等于1。
- update参数必须是包含更新运算符的文档(https://docs.mongodb.com/manual/reference/operator/update/),并且可以用于指定要对所选文档进行的修改。它不能为nil或为空。
- opts参数可用于指定操作的选项。
filter := bson.D{{"name","张冬冬"}} //如果过滤的文档不存在,则插入新的文档 opts := options.Update().SetUpsert(true) update := bson.D{ {"$set", bson.D{{"city", "北京"}}, }} result, err := collection.UpdateOne(context.TODO(), filter, update,opts) if err != nil { log.Fatal(err) } if result.MatchedCount != 0 { fmt.Printf("Matched %v documents and updated %v documents.\n", result.MatchedCount, result.ModifiedCount) } if result.UpsertedCount != 0 { fmt.Printf("inserted a new document with ID %v\n", result.UpsertedID) }
返回结果如下
Connected to MongoDB!
Matched 1 documents and updated 1 documents.
Connection to MongoDB closed.
更新多个文档
更新多个文档使用collection.UpdateOne()函数,参数与collection.UpdateOne()函数相同
filter := bson.D{{"city","北京"}}
//如果过滤的文档不存在,则插入新的文档
opts := options.Update().SetUpsert(true)
update := bson.D{
{"$set", bson.D{{"city", "铁岭"}},
}}
result, err := collection.UpdateMany(context.TODO(), filter, update,opts)
if err != nil {
log.Fatal(err)
}
if result.MatchedCount != 0 {
fmt.Printf("Matched %v documents and updated %v documents.\n", result.MatchedCount, result.ModifiedCount)
}
if result.UpsertedCount != 0 {
fmt.Printf("inserted a new document with ID %v\n", result.UpsertedID)
}
返回结果如下
Connected to MongoDB!
Matched 2 documents and updated 2 documents.
Connection to MongoDB closed.
删除MongoDB文档
可以使用collection.DeleteOne()
或collection.DeleteMany()
删除文档。如果你传递bson.D{{}}
作为过滤器参数,它将匹配数据集中的所有文档。还可以使用collection. drop()
删除整个数据集。
filter := bson.D{{"city","铁岭"}}
deleteResult, err := collection.DeleteMany(context.TODO(), filter)
if err != nil {
log.Fatal(err)
}
fmt.Printf("Deleted %v documents in the trainers collection\n", deleteResult.DeletedCount)
返回结果如下
Connected to MongoDB!
Deleted 2 documents in the trainers collection
Connection to MongoDB closed.
获取MongoDB服务状态
上面我们介绍了对MongoDB的CRUD,其实还支持很多对mongoDB的操作,例如聚合、事物等,接下来介绍一下使用golang获取MongoDB服务状态,执行后会返回一个bson.Raw类型的数据
ctx, _ = context.WithTimeout(context.Background(), 30*time.Second)
serverStatus, err := client.Database("admin").RunCommand(
ctx,
bsonx.Doc{{"serverStatus", bsonx.Int32(1)}},
).DecodeBytes()
if err != nil {
fmt.Println(err)
}
fmt.Println(serverStatus)
fmt.Println(reflect.TypeOf(serverStatus))
version, err := serverStatus.LookupErr("version")
fmt.Println(version.StringValue())
if err != nil {
fmt.Println(err)
}
参考链接
https://www.mongodb.com/blog/post/mongodb-go-driver-tutorial
https://godoc.org/go.mongodb.org/mongo-driver/mongo
使用golang驱动操作MongoDB数据库相关推荐
- 使用Golang驱动操作MongoDB
微信公众号:运维开发故事,作者:wanger 上篇文章我们介绍了使用pymongo对MongoDB进行CRUD,本篇将介绍使用Golang驱动操作MongoDB 安装MongoDB驱动程序 mkdr ...
- Lua 操作 MongoDB 数据库实例
最近有个工作是使用Nginx + Lua实现一个操作MongoDB数据库的API,主要实现其count和query功能.之前没有写过Lua,于是也就勉强着上手,在cloudwu的 lua-mongo ...
- Java操作MongoDB数据库(简明版)
除了通过启动 mongo 进程进如 Shell 环境访问数据库外,MongoDB 还提供了其他基于编程语言的访问数据库方法.MongoDB 官方提供了 Java 和 Python 语言的驱动包,利用这 ...
- 操作Mongodb数据库及性能测试
文章目录 操作Mongodb数据库,性能测试 引入mongodb模板 开启mongodb数据库 连接mongodb数据库 插入一条数据 查询全部数据 测试性能 操作Mongodb数据库,性能测试 目标 ...
- Python3操作MongoDB数据库
Python3操作MongoDB数据库 文章目录 Python3操作MongoDB数据库 0. 写在前面 1. 安装开源驱动库pymongo 2. 参考 0. 写在前面 Linux:Ubuntu Ky ...
- Java操作MongoDB数据库CRUD(增删查改)
Java操作MongoDB数据库CRUD(增删查改) 借助mongo-java-driver包,对MongoDB数据库的集合(DataTable)及文档(BSON对象数据)进行增删查改操作.本文的核心 ...
- nodejs操作mongodb数据库(mongoose)
准备 在上一篇的基础上,通过npm安装mongoose. 关于mongoose Mongoose是MongoDB的一个对象模型工具,是基于node-mongodb-native开发的MongoDB n ...
- Python 操作 MongoDB 数据库!
作者 |黄伟呢 来源 |数据分析与统计学之美 MongoDB是一个介于关系数据库和非关系数据库之间的产品,是非关系数据库当中功能最丰富,最像关系数据库的. 先来看看MySQL与MongoDB 概念区别 ...
- 58 Node.js中操作mongoDB数据库
技术交流 QQ 群:1027579432,欢迎你的加入! 欢迎关注我的微信公众号:CurryCoder 的程序人生 1.数据库概述及环境搭建 1.1 为什么要使用数据库 动态网站中的数据都是存储在数据 ...
最新文章
- 大数据调度平台Airflow(五):Airflow使用
- 自动释放池autoreleasepool
- 几个常用的Linux监控脚本
- Python的数据处理学习(三)
- java 循环结构和常用的类 总结笔记
- SAP UI5 应用开发教程之六十五 - 基于 OData V4 的 SAP UI5 表格控件如何实现创建,编辑和保存功能
- 内存分配方式以及堆和栈的区别
- 在实际项目开发中keil的调试方法
- vue使用webPack打包发布后页面显示空白
- 机器学习原理与算法(六) 支持向量机
- leetcode - 448. 找到所有数组中消失的数字
- window. onload=function(){} 与 $(function(){}) 的区别
- 让Jackson JSON生成的数据包含的中文以unicode方式编码
- C++11 —— 基于区间(range)的 for 循环
- centos7.4 安装配置rabbitmq-server 实操记录
- unity update 协程_[转载]【转载】unity3D中使用协程来做“多次调用一次更新”特性的一个大坑。...
- 半导体、芯片、集成电路、无尘车间具体释义及区别
- 基于Springboot实现高校社团管理系统
- 探索式测试方法的实践
- 编写程序,求柱体的体积: