jlzzjlzz亚洲乱熟在线播放

系統城裝機大師 - 固鎮縣祥瑞電腦科技銷售部宣傳站!

當前位置:首頁 > 腳本中心 > 其它 > 詳細頁面

golang連接MongoDB數據庫及數據庫操作指南

時間:2022-09-12來源:www.farandoo.com作者:電腦系統城

  • 總結

安裝配置MongoDB驅動

安裝驅動

1 go get -u github.com/mongodb/mongo-go-driver

初始化模塊

1 go mod init 模塊名稱

執行go mod tidy

1 go mod tidy

導入驅動

1
2
3
4
5
6
import (
    "context"
    "go.mongodb.org/mongo-driver/bson"    //BOSN解析包
    "go.mongodb.org/mongo-driver/mongo"    //MongoDB的Go驅動包
    "go.mongodb.org/mongo-driver/mongo/options"
)

獲得數據庫連接

初始化連接

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
package main
 
import (
    "context"
    "fmt"
    "go.mongodb.org/mongo-driver/mongo"
    "go.mongodb.org/mongo-driver/mongo/options"
)
 
var client *mongo.Client
 
func initDB() (err error) {
    // 設置客戶端連接配置
    clientOptions := options.Client().ApplyURI("mongodb://ip:port")
    // 連接到MongoDB
    client, err = mongo.Connect(context.TODO(), clientOptions)
    if err != nil {
        return err
    }
    // 檢查連接
    err = client.Ping(context.TODO(), nil)
    if err != nil {
        return err
    }
    return nil
}
 
func main() {
    err := initDB() // 調用輸出化數據庫的函數
    if err != nil {
        fmt.Printf("初始化失??!,err:%v\n", err)
        return
    }else{
        fmt.Println("Connected to MongoDB!")
    }
}

連接MongoDB的Go驅動程序中有兩大類型表示BSON數據:D和Raw。

類型D家族被用來簡潔地構建使用本地Go類型的BSON對象。這對于構造傳遞給MongoDB的命令特別有用。D家族包括四類:

D:一個BSON文檔。這種類型應該在順序重要的情況下使用,比如MongoDB命令。

1 bson.D{{"foo", "bar"}, {"hello", "world"}, {"pi", 3.14159}}

M:一張無序的map。它和D是一樣的,只是它不保持順序。

1 bson.M{"foo": "bar", "hello": "world", "pi": 3.14159}

A:一個BSON數組。

1 bson.A{"hello", "world", 3.14159, bson.D{{"abcde", 12345}}}

E:D里面的一個元素。

要使用BSON,需要先導入下面的包:

1 import "go.mongodb.org/mongo-driver/bson"

Raw類型家族用于驗證字節切片。你還可以使用Lookup()從原始類型檢索單個元素。如果你不想要將BSON反序列化成另一種類型的開銷,那么這是非常有用的。

 

數據庫操作

添加文檔

添加單個文檔

使用collection.InsertOne()方法插入一條文檔記錄:

1
2
3
4
5
6
7
8
9
func insertOne(s interface{}) (err error) {
    collection := client.Database("datebase").Collection("collection")
    insertResult, err := collection.InsertOne(context.TODO(), s)
    if err != nil {
        return err
    }
    fmt.Println("Inserted a single document: ", insertResult.InsertedID)
    return nil
}

測試:

1
2
3
4
5
6
7
s := struct{name string
    age int
}{"tom", 20}
err := insertOne(s)
if err != nil{
    fmt.Printf("添加文檔失??!,err:%v\n", err)
}

添加多個文檔

使用collection.InsertMany()方法插入多條文檔記錄:

1
2
3
4
5
6
7
8
9
10
func insertMore(s []interface{}) (err error) {
    //students := []interface{}{s2, s3}
    collection := client.Database("datebase").Collection("collection")
    insertManyResult, err := collection.InsertMany(context.TODO(), s)
    if err != nil {
        return err
    }
    fmt.Println("Inserted multiple documents: ", insertManyResult.InsertedIDs)
    return nil
}

測試:

1
2
3
4
5
6
7
8
9
10
11
12
type Student struct {
    name string
    age int
}
s1 := Student{name: "tom", age: 20}
s2 := Student{name: "kite", age: 21}
s3 := Student{name: "rose", age: 22}
ss := []interface{}{s1, s2, s3}
insertMore(ss)
if err != nil{
    fmt.Printf("添加多個文檔失??!,err:%v\n", err)
}

查找文檔

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
func find() (err error){
    ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
    defer cancel()
    collection := client.Database("datebase").Collection("collection")
    cur, err := collection.Find(ctx, bson.D{})
    if err != nil {
        return err
    }
    defer cur.Close(ctx)
    for cur.Next(ctx) {
        var result bson.D
        err := cur.Decode(&result)
        if err != nil {
            return err
        }
        fmt.Printf("result: %v\n", result)
    }
    if err := cur.Err(); err != nil {
        return err
    }
    return nil
}

更新文檔

1
2
3
4
5
6
7
8
9
10
11
12
13
14
func update() (err error) {
    ctx := context.TODO()
    defer client.Disconnect(ctx)
    c := client.Database("datebase").Collection("collection")
 
    update := bson.D{{"$set", bson.D{{"attr1", "value1"}, {"attr2", "value2"}}}}
 
    ur, err := c.UpdateMany(ctx, bson.D{{"old_attr1", "old_value1"}}, update)
    if err != nil {
        return err
    }
    fmt.Printf("ur.ModifiedCount: %v\n", ur.ModifiedCount)
    return nil
}

刪除文檔

1
2
3
4
5
6
7
8
9
10
11
12
func del() (err error) {
    c := client.Database("datebase").Collection("collection")
    ctx := context.TODO()
 
    dr, err := c.DeleteMany(ctx, bson.D{{"attr1", "value1"}})
 
    if err != nil {
        return err
    }
    fmt.Printf("ur.ModifiedCount: %v\n", dr.DeletedCount)
    return nil
}

總結

到此這篇關于golang連接MongoDB數據庫及數據庫操作指南的文章就介紹到這了

分享到:

相關信息

系統教程欄目

欄目熱門教程

人氣教程排行

站長推薦

熱門系統下載