利用golang驅(qū)動操作MongoDB數(shù)據(jù)庫的步驟

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

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://[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

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)

//定義插入數(shù)據(jù)的結(jié)構(gòu)體
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)

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)

//定義返回文檔數(shù)量
findOptions := options.Find()
findOptions.SetLimit(5)

//定義一個切片存儲結(jié)果
var results []*sunshareboy

//將bson.D{{}}作為一個filter來匹配所有文檔
cur, err := collection.Find(context.TODO(), bson.D{{}}, findOptions)
if err != nil {
 log.Fatal(err)
}
//查找多個文檔返回一個游標(biāo)
//遍歷游標(biāo)一次解碼一個游標(biāo)
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)
}
//遍歷結(jié)束后關(guān)閉游標(biāo)
cur.Close(context.TODO())
fmt.Printf("Found multiple documents (array of pointers): %+v\n", results)

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)
}

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)
}

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)

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)
}