欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Go語言學(xué)習(xí)筆記之golang操作MongoDB數(shù)據(jù)庫

 更新時(shí)間：2023年05月25日 11:48:41   作者：PPPsych  
MongoDB是Nosql中常用的一種數(shù)據(jù)庫,這篇文章主要給大家介紹了關(guān)于Go語言學(xué)習(xí)筆記之golang操作MongoDB數(shù)據(jù)庫的相關(guān)資料,文中通過實(shí)例代碼介紹的非常詳細(xì),需要的朋友可以參考下

一 下載安裝驅(qū)動(dòng)

官方文檔

https://pkg.go.dev/go.mongodb.org/mongo-driver/mongo

下載地址

https://www.mongodb.com/try/download/community

打開客戶端

mongo.exe

創(chuàng)建數(shù)據(jù)庫

use golang_db;

創(chuàng)建集合

db.createCollection("student");

下載驅(qū)動(dòng)

go get go.mongodb.org/mongo-driver/mongo

二 go連接到MongoDB

package main

import (
	"context"
	"fmt"
	"log"

	"go.mongodb.org/mongo-driver/mongo"
	"go.mongodb.org/mongo-driver/mongo/options"
)

var client *mongo.Client

func initDB() {
	// 設(shè)置客戶端連接配置
	clientOptions := options.Client().ApplyURI("mongodb://localhost:27017")

	// 連接到MongoDB
	var err error
	c, err := mongo.Connect(context.TODO(), clientOptions)
	if err != nil {
		log.Fatal(err)
	}

	// 檢查連接
	err = c.Ping(context.TODO(), nil)
	if err != nil {
		log.Fatal(err)
	}
	fmt.Println("MongoDB 連接成功")
	client = c
}

func main() {
	initDB()
}

運(yùn)行結(jié)果：

[Running] go run "e:\golang開發(fā)學(xué)習(xí)\go_pro\test.go"
MongoDB 連接成功

[Done] exited with code=0 in 2.819 seconds

三 BSON簡介

MongoDB中的JSON文檔存儲(chǔ)在名為BSON（二進(jìn)制編碼的JSON）的二進(jìn)制表中。與其他將JSON數(shù)據(jù)存儲(chǔ)為簡單字符串和數(shù)字的數(shù)據(jù)庫不同，BSON編碼擴(kuò)展了JSON表示，使其包含額外的類型，如int、long、date、浮點(diǎn)數(shù)和decimal128。這使得應(yīng)用程序更容易可靠地處理、排序和比較數(shù)據(jù)。

連接MongoDB地Go驅(qū)動(dòng)程序中有兩大類型表示BSON數(shù)據(jù)：D和Raw。

類型D家族被用來簡潔地構(gòu)建使用本地Go類型地BSON對象。這對于構(gòu)造傳遞給MongoDB地命令特別有用。D家族包括四大類：

  • D：一個(gè)BSON文檔。這種類型應(yīng)該在順序重要的情況下使用，比如MongoDB命令。
  • M：一張無序的map。它和D是一樣的，只是它不保持順序。
  • A：一個(gè)BSON數(shù)組。
  • E：D里面的一個(gè)元素。

要使用BSON，需要先導(dǎo)入下面的包：

go.mongodb.org/mongo-driver/bson

下面是一個(gè)使用D類型構(gòu)建地過濾器文檔的例子，它可以用來查找name字段與‘張三’或‘李四’匹配的文檔：

bson.D{{
	"name",
	bson.D{{
		"$in",
		bson.A{"張三","李四"},
	}},
}}

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

本文只使用D類型。

四 添加文檔

4.1 創(chuàng)建一個(gè)結(jié)構(gòu)體

type Student struct {
	Name string
	Age  int
}

4.2 添加單個(gè)文檔

方法：

func (coll *Collection) InsertOne(ctx context.Context, document interface{},
	opts ...*options.InsertOneOptions) (*InsertOneResult, error)

實(shí)例演示：

package main

import (
	"context"
	"fmt"
	"log"

	"go.mongodb.org/mongo-driver/mongo"
	"go.mongodb.org/mongo-driver/mongo/options"
)

var client *mongo.Client

func initDB() {
	// 設(shè)置客戶端連接配置
	clientOptions := options.Client().ApplyURI("mongodb://localhost:27017")

	// 連接到MongoDB
	var err error
	c, err := mongo.Connect(context.TODO(), clientOptions)
	if err != nil {
		log.Fatal(err)
	}

	// 檢查連接
	err = c.Ping(context.TODO(), nil)
	if err != nil {
		log.Fatal(err)
	}
	fmt.Println("MongoDB 連接成功")
	client = c
}

type Student struct {
	Name string
	Age  int
}

func insertOne(s Student) {
	initDB()

	collection := client.Database("golang_db").Collection("student")
	insertResult, err := collection.InsertOne(context.TODO(), s)
	if err != nil {
		log.Fatal(err)
	}
	fmt.Printf("添加了一條文檔記錄: %v\n", insertResult.InsertedID)
}

func main() {
	s := Student{Name: "Psych", Age: 18}
	insertOne(s)
}

運(yùn)行結(jié)果：

[Running] go run "e:\golang開發(fā)學(xué)習(xí)\go_pro\test.go"
MongoDB 連接成功
添加了一條文檔記錄: ObjectID("62ee3202c3c3f019d63c34ff")

[Done] exited with code=0 in 3.518 seconds

MongoDB中查看：

4.3 添加多個(gè)文檔

方法：

func (coll *Collection) InsertMany(ctx context.Context, documents []interface{},
	opts ...*options.InsertManyOptions) (*InsertManyResult, error)

實(shí)例演示：

package main

import (
	"context"
	"fmt"
	"log"

	"go.mongodb.org/mongo-driver/mongo"
	"go.mongodb.org/mongo-driver/mongo/options"
)

var client *mongo.Client

func initDB() {
	// 設(shè)置客戶端連接配置
	clientOptions := options.Client().ApplyURI("mongodb://localhost:27017")

	// 連接到MongoDB
	var err error
	c, err := mongo.Connect(context.TODO(), clientOptions)
	if err != nil {
		log.Fatal(err)
	}

	// 檢查連接
	err = c.Ping(context.TODO(), nil)
	if err != nil {
		log.Fatal(err)
	}
	fmt.Println("MongoDB 連接成功")
	client = c
}

type Student struct {
	Name string
	Age  int
}

func insertMore(students []interface{}) {
	initDB()

	collection := client.Database("golang_db").Collection("student")
	insertManyResult, err := collection.InsertMany(context.TODO(), students)
	if err != nil {
		log.Fatal(err)
	}
	fmt.Printf("添加了多條文檔記錄: %v\n", insertManyResult.InsertedIDs)
}

func main() {
	s1 := Student{Name: "Klee", Age: 8}
	s2 := Student{Name: "Morax", Age: 1000}
	s3 := Student{Name: "Baal", Age: 500}
	student := []interface{}{s1, s2, s3}
	insertMore(student)
}

運(yùn)行結(jié)果：

[Running] go run "e:\golang開發(fā)學(xué)習(xí)\go_pro\test.go"
MongoDB 連接成功
添加了多條文檔記錄: [ObjectID("62ee337502174a1366f86db2") ObjectID("62ee337502174a1366f86db3") ObjectID("62ee337502174a1366f86db4")]

[Done] exited with code=0 in 2.558 seconds

MongoDB中查看：

五 查找文檔

方法：

func (coll *Collection) Find(ctx context.Context, filter interface{},
	opts ...*options.FindOptions) (cur *Cursor, err error)

實(shí)例演示：

package main

import (
	"context"
	"fmt"
	"log"
	"time"

	"go.mongodb.org/mongo-driver/bson"
	"go.mongodb.org/mongo-driver/mongo"
	"go.mongodb.org/mongo-driver/mongo/options"
)

var client *mongo.Client

func initDB() {
	// 設(shè)置客戶端連接配置
	clientOptions := options.Client().ApplyURI("mongodb://localhost:27017")

	// 連接到MongoDB
	var err error
	c, err := mongo.Connect(context.TODO(), clientOptions)
	if err != nil {
		log.Fatal(err)
	}

	// 檢查連接
	err = c.Ping(context.TODO(), nil)
	if err != nil {
		log.Fatal(err)
	}
	fmt.Println("MongoDB 連接成功")
	client = c
}

func findData() {
	initDB()

	ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
	defer cancel()

	collection := client.Database("golang_db").Collection("student")

	// c, err := collection.Find(ctx, bson.D{{Key: "name", Value: "Psych"}})
	// 單個(gè)數(shù)據(jù)查詢
	// c, err := collection.Find(ctx, bson.D{{Key: "name", Value: "Morax"}})
	c, err := collection.Find(ctx, bson.D{})
	if err != nil {
		log.Fatal(err)
	}
	defer c.Close(ctx)

	for c.Next(ctx) {
		var result bson.D
		err := c.Decode(&result)
		if err != nil {
			log.Fatal(err)
		}
		fmt.Printf("查找結(jié)果為: %v\n", result)
		fmt.Printf("result.Map(): %v\n", result.Map()["name"])
	}
	if err := c.Err(); err != nil {
		log.Fatal(err)
	}

}

func main() {
	findData()
}

注釋內(nèi)容為單個(gè)數(shù)據(jù)查詢，可自行測試

運(yùn)行結(jié)果：

[Running] go run "e:\golang開發(fā)學(xué)習(xí)\go_pro\test.go"
MongoDB 連接成功
查找結(jié)果為: [{_id ObjectID("62ee3202c3c3f019d63c34ff")} {name Psych} {age 18}]
result.Map(): Psych
查找結(jié)果為: [{_id ObjectID("62ee337502174a1366f86db2")} {name Klee} {age 8}]
result.Map(): Klee
查找結(jié)果為: [{_id ObjectID("62ee337502174a1366f86db3")} {name Morax} {age 1000}]
result.Map(): Morax
查找結(jié)果為: [{_id ObjectID("62ee337502174a1366f86db4")} {name Baal} {age 500}]
result.Map(): Baal

[Done] exited with code=0 in 2.482 seconds

六 更新文檔

方法：

func (coll *Collection) UpdateOne(ctx context.Context, filter interface{}, update interface{},
	opts ...*options.UpdateOptions) (*UpdateResult, error) 
func (coll *Collection) UpdateMany(ctx context.Context, filter interface{}, update interface{},
	opts ...*options.UpdateOptions) (*UpdateResult, error)

實(shí)例演示：

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

var client *mongo.Client

func initDB() {
	// 設(shè)置客戶端連接配置
	clientOptions := options.Client().ApplyURI("mongodb://localhost:27017")

	// 連接到MongoDB
	var err error
	c, err := mongo.Connect(context.TODO(), clientOptions)
	if err != nil {
		log.Fatal(err)
	}

	// 檢查連接
	err = c.Ping(context.TODO(), nil)
	if err != nil {
		log.Fatal(err)
	}
	fmt.Println("MongoDB 連接成功")
	client = c
}

func updateData() {
	initDB()

	ctx := context.TODO()
	defer client.Disconnect(ctx)

	c := client.Database("golang_db").Collection("student")

	update := bson.D{{"$set", bson.D{{Key: "name", Value: "鐘離"}, {Key: "age", Value: 1200}}}}
	// 更新條件 name Morax
	// 更新為 name 鐘離 age 1200
	ur, err := c.UpdateMany(ctx, bson.D{{Key: "name", Value: "Morax"}}, update)
	if err != nil {
		log.Fatal(err)
	}
	fmt.Printf("修改文檔數(shù)量: %v\n", ur.ModifiedCount)
}

func main() {
	updateData()
}

運(yùn)行結(jié)果：

[Running] go run "e:\golang開發(fā)學(xué)習(xí)\go_pro\test.go"
MongoDB 連接成功
修改文檔數(shù)量: 1

[Done] exited with code=0 in 2.529 seconds

MongoDB中查看：

七 刪除文檔

方法：

func (coll *Collection) DeleteMany(ctx context.Context, filter interface{},
	opts ...*options.DeleteOptions) (*DeleteResult, error)
func (coll *Collection) DeleteOne(ctx context.Context, filter interface{},
	opts ...*options.DeleteOptions) (*DeleteResult, error)

實(shí)例演示：

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

var client *mongo.Client

func initDB() {
	// 設(shè)置客戶端連接配置
	clientOptions := options.Client().ApplyURI("mongodb://localhost:27017")

	// 連接到MongoDB
	var err error
	c, err := mongo.Connect(context.TODO(), clientOptions)
	if err != nil {
		log.Fatal(err)
	}

	// 檢查連接
	err = c.Ping(context.TODO(), nil)
	if err != nil {
		log.Fatal(err)
	}
	fmt.Println("MongoDB 連接成功")
	client = c
}

func deleteData() {
	initDB()

	ctx := context.TODO()
	defer client.Disconnect(ctx)

	c := client.Database("golang_db").Collection("student")
	dr, err := c.DeleteMany(ctx, bson.D{{Key: "name", Value: "Psych"}})
	if err != nil {
		log.Fatal(err)
	}
	fmt.Printf("刪除文檔數(shù)量: %v\n", dr.DeletedCount)
}

func main() {
	deleteData()
}

運(yùn)行結(jié)果：

[Running] go run "e:\golang開發(fā)學(xué)習(xí)\go_pro\test.go"
MongoDB 連接成功
刪除文檔數(shù)量: 1

[Done] exited with code=0 in 3.698 seconds

MongoDB中查看：

總結(jié)

到此這篇關(guān)于Go語言學(xué)習(xí)筆記之golang操作MongoDB數(shù)據(jù)庫的文章就介紹到這了,更多相關(guān)golang操作MongoDB數(shù)據(jù)庫內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

相關(guān)文章

  • Golang學(xué)習(xí)之無類型常量詳解

    Golang學(xué)習(xí)之無類型常量詳解

    對于無類型常量，可能大家是第一次聽說，但我們每天都在用，每天都有無數(shù)潛在的坑被埋下。本文就來和大家聊聊它的相關(guān)注意事項(xiàng)吧，希望對大家有所幫助
    2023-03-03
  • golang框架中跨服務(wù)的最佳通信協(xié)議和工具

    golang框架中跨服務(wù)的最佳通信協(xié)議和工具

    在 go 框架中實(shí)現(xiàn)跨服務(wù)通信的最佳實(shí)踐包括使用 grpc（適用于低延遲高吞吐量）、http 客戶端（適用于 restful api）和消息隊(duì)列（適用于異步解耦通信）,在選擇通信方式時(shí),應(yīng)考慮服務(wù)交互模式、性能要求和部署環(huán)境等因素
    2024-06-06
  • 使用Golang生成壓縮文件的詳細(xì)教程

    使用Golang生成壓縮文件的詳細(xì)教程

    與其他語言一樣,內(nèi)置標(biāo)準(zhǔn)庫默認(rèn)支持文件壓縮功能,本文介紹Golang如何創(chuàng)建壓縮文件,增加一個(gè)或多個(gè)文件生成壓縮文件,也可以在壓縮文件中創(chuàng)建文件夾,用于對文件進(jìn)行分類管理,Golang標(biāo)準(zhǔn)庫 archive/zip提供了創(chuàng)建和讀取壓縮文件功能,需要的朋友可以參考下
    2024-01-01
  • Golang實(shí)現(xiàn)拓?fù)渑判?DFS算法版)

    Golang實(shí)現(xiàn)拓?fù)渑判?DFS算法版)

    這篇文章主要介紹了Golang實(shí)現(xiàn)拓?fù)渑判?DFS算法版)，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2019-11-11
  • Go語言實(shí)現(xiàn)關(guān)閉http請求的方式總結(jié)

    Go語言實(shí)現(xiàn)關(guān)閉http請求的方式總結(jié)

    面試的時(shí)候問到如何關(guān)閉http請求，一般人脫口而出的是關(guān)閉response.body，這是錯(cuò)誤的。本文為大家整理了三個(gè)正確關(guān)閉http請求的方法，希望對大家有所幫助
    2023-02-02
  • GoFrame?ORM原生方法操作示例

    GoFrame?ORM原生方法操作示例

    這篇文章主要為大家介紹了GoFrame?ORM原生方法操作示例，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪
    2022-06-06
  • Go1.20最新資訊go?arena手動(dòng)管理內(nèi)存鴿了

    Go1.20最新資訊go?arena手動(dòng)管理內(nèi)存鴿了

    由于過于繁雜,Go?核心團(tuán)隊(duì)成員@Ian?Lance?Taylor,也表態(tài)：目前尚未做出任何決定,也不可能在短期內(nèi)做出任何決定,可以認(rèn)為這個(gè)提案基本鴿了,今天這篇文章就是給大家同步目前的情況
    2023-11-11
  • 在Golang中使用iota案例詳解

    在Golang中使用iota案例詳解

    在Go語言中，iota是一個(gè)預(yù)定義的標(biāo)識(shí)符，用于在常量聲明中生成連續(xù)的遞增值，iota的值從0開始，每次在常量聲明中使用時(shí)遞增，本就給大家講解一下Golang中iota的使用案例，感興趣的同學(xué)跟著小編一起來看看吧
    2023-07-07
  • Windows10系統(tǒng)下安裝Go環(huán)境詳細(xì)步驟

    Windows10系統(tǒng)下安裝Go環(huán)境詳細(xì)步驟

    Go語言是谷歌推出的一款全新的編程語言,可以在不損失應(yīng)用程序性能的情況下極大的降低代碼的復(fù)雜性,這篇文章主要給大家介紹了關(guān)于Windows10系統(tǒng)下安裝Go環(huán)境的詳細(xì)步驟,需要的朋友可以參考下
    2023-11-11
  • 詳解Golang中g(shù)omock的使用場景和方法

    詳解Golang中g(shù)omock的使用場景和方法

    gomock是Go編程語言的模擬框架, 它與Go的內(nèi)置測試包很好地集成在一起,但也可以在其他上下文中使用,本文主要介紹了gomock的使用場景和方法,感興趣的可以了解下
    2024-10-10

最新評論