利用golang驅動操作MongoDB數據庫的步驟
安裝MongoDB驅動程序
mkdr mongodb cd mongodb go mod init go get go.mongodb.org/mongo-driver/mongo
連接MongoDB
創(chuàng)建一個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集合,集合不存在會自動創(chuàng)建
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)
執(zhí)行結果如下
#### 同時插入多條文檔
```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函數執(zhí)行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()) {
//定義一個文檔，將單個文檔解碼為result
var result sunshareboy
err := 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服務狀態(tài)
上面我們介紹了對MongoDB的CRUD，其實還支持很多對mongoDB的操作，例如聚合、事物等，接下來介紹一下使用golang獲取MongoDB服務狀態(tài)，執(zhí)行后會返回一個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內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
相關文章
Mongodb的通配符索引,為靈活可變的Mongodb數據結構提供了高效的查詢方法,本文結合Mongodb官方文檔,詳細介紹在嵌入式文檔和數組上,通配符索引的結構,感興趣的朋友一起看看吧2024-07-07
這篇文章主要介紹了mongodb運維的相關知識，非常不錯，具有參考借鑒價值，需要的的朋友參考下吧2017-08-08
MongoDB 索引創(chuàng)建和查詢優(yōu)化的方法
這篇文章主要介紹了MongoDB 索引創(chuàng)建和查詢優(yōu)化的方法,本文給大家介紹的非常詳細,感興趣的朋友跟隨小編一起看看吧2024-07-07
這篇文章主要介紹了cgroup限制mongodb進程內存大小,需要的朋友可以參考下2014-07-07
MongoDB中聚合(aggregate)主要用于處理數據(諸如統計平均值,求和等),并返回計算后的數據結果,下面這篇文章主要給大家介紹了關于MongoDB中aggregate()方法的相關資料,需要的朋友可以參考下2023-01-01
MongoDB的復合通配符索引為處理復雜和多變的數據結構提供了靈活的索引解決方案,通過合理使用復合通配符索引,可以顯著提高查詢效率并減少索引維護成本,本文給大家介紹MongoDB的復合通配符索引,感興趣的朋友跟隨小編一起看看吧2024-08-08
MongoDB排序時內存大小限制與創(chuàng)建索引的注意事項詳解
在數據量超大的情形下,任何數據庫系統在創(chuàng)建索引時都是一個耗時的大工程,下面這篇文章主要給大家介紹了關于MongoDB排序時內存大小限制與創(chuàng)建索引的注意事項的相關資料,需要的朋友可以參考下2022-05-05
springboot + mongodb 通過經緯度坐標匹配平面區(qū)域的方法
這篇文章主要介紹了springboot + mongodb 通過經緯度坐標匹配平面區(qū)域的方法,文中通過實例代碼給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2021-10-10
這篇文章主要給大家介紹了關于mongodb中按天進行聚合查詢的相關資料，文中通過示例代碼介紹的非常詳細，對大家學習或者使用mongodb具有一定的參考學習價值，需要的朋友們下面來一起學習學習吧2019-07-07
SpringBoot系列之MongoDB?Aggregations用法詳解
MongoDB?中使用聚合（Aggregations）來分析數據并從中獲取有意義的信息，本文重點給大家介紹SpringBoot系列之MongoDB?Aggregations用法，感興趣的朋友跟隨小編一起看看吧2022-02-02