快捷導(dǎo)航

Golang實(shí)現(xiàn)Mongo數(shù)據(jù)庫(kù)增刪改查操作

更新時(shí)間：2024年01月09日 11:38:58 作者：Amctwd

本文主要介紹了Golang實(shí)現(xiàn)Mongo數(shù)據(jù)庫(kù)增刪改查操作,我們使用了 MongoDB的官方Go驅(qū)動(dòng)程序,實(shí)現(xiàn)了插入、查詢、更新和刪除操作,感興趣的可以了解一下

本文將通過一個(gè)簡(jiǎn)單的 Go 語(yǔ)言示例，介紹如何使用 MongoDB 進(jìn)行基本的數(shù)據(jù)操作，包括插入、查詢、更新和刪除操作。我們將使用 MongoDB 的官方 Go 驅(qū)動(dòng)程序來與數(shù)據(jù)庫(kù)進(jìn)行交互。

一、引言

MongoDB 是一款流行的 NoSQL 數(shù)據(jù)庫(kù)，它使用文檔存儲(chǔ)結(jié)構(gòu)，可以存儲(chǔ)非常復(fù)雜的數(shù)據(jù)類型。Go 語(yǔ)言以其簡(jiǎn)潔和高效的特性，成為越來越多開發(fā)者選擇的編程語(yǔ)言。在本文中，我們將結(jié)合 Go 語(yǔ)言和 MongoDB，展示如何實(shí)現(xiàn)基本的數(shù)據(jù)操作。

二、環(huán)境準(zhǔn)備

安裝 MongoDB：請(qǐng)參考 MongoDB 的官方文檔進(jìn)行安裝。

安裝 Go 語(yǔ)言環(huán)境：請(qǐng)參考 Go 語(yǔ)言的官方文檔進(jìn)行安裝。

安裝 MongoDB Go 驅(qū)動(dòng)程序：在終端中運(yùn)行 go get go.mongodb.org/mongo-driver/mongo。

三、代碼實(shí)現(xiàn)

以下是一個(gè)簡(jiǎn)單的 Go 語(yǔ)言示例，展示了如何使用 MongoDB 進(jìn)行數(shù)據(jù)操作。

1. 連接到 MongoDB

func MongoClient() *mongo.Client {
	clientOptions := options.Client().ApplyURI("mongodb://10.90.45.1:27017/?connect=direct")
	client, err := mongo.Connect(context.TODO(), clientOptions)
	if err != nil {
		log.Fatal(err)
	}
	return client
}

2. 插入數(shù)據(jù)

func InsertOne(client *mongo.Client, databaseName string, collectionName string, doc bson.M) error {
	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
	defer cancel()
	collection := client.Database(databaseName).Collection(collectionName)
	_, err := collection.InsertOne(ctx, doc)
	return err
}
func InsertMany(client *mongo.Client, databaseName string, collectionName string, doc []interface{}) error {
	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
	defer cancel()
	collection := client.Database(databaseName).Collection(collectionName)
	_, err := collection.InsertMany(ctx, doc)
	return err
}

3. 查詢數(shù)據(jù)

func Find(client *mongo.Client, databaseName string, collectionName string, filter bson.M) ([]bson.M, error) {
	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
	defer cancel()
	collection := client.Database(databaseName).Collection(collectionName)
	cur, err := collection.Find(ctx, filter)
	if err != nil {
		return nil, err
	}
	defer cur.Close(ctx)
	var results []bson.M
	for cur.Next(ctx) {
		var result bson.M
		err := cur.Decode(&result)
		if err != nil {
			return nil, err
		}
		results = append(results, result)
	}
	if err := cur.Err(); err != nil {
		return nil, err
	}
	return results, nil
}

4. 更新數(shù)據(jù)

func UpdateOne(client *mongo.Client, databaseName string, collectionName string, filter bson.M, update bson.M) error {
	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
	defer cancel()
	collection := client.Database(databaseName).Collection(collectionName)
	_, err := collection.UpdateOne(ctx, filter, bson.M{"$set": update})
	return err
}
func UpdateMany(client *mongo.Client, databaseName string, collectionName string, filter bson.M, update bson.M) error {
	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
	defer cancel()
	collection := client.Database(databaseName).Collection(collectionName)
	_, err := collection.UpdateMany(ctx, filter, bson.M{"$set": update})
	return err
}

5. 刪除數(shù)據(jù)

func DeleteOne(client *mongo.Client, databaseName string, collectionName string, filter bson.M) error {
	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
	defer cancel()
	collection := client.Database(databaseName).Collection(collectionName)
	_, err := collection.DeleteOne(ctx, filter)
	return err
}
func DeleteMany(client *mongo.Client, databaseName string, collectionName string, filter bson.M) error {
	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
	defer cancel()
	collection := client.Database(databaseName).Collection(collectionName)
	_, err := collection.DeleteMany(ctx, filter)
	return err
}

6.Main執(zhí)行

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

func main() {
	client := MongoClient()
	defer client.Disconnect(context.TODO())

	dbName := "mydatabase"
	dcName := "mycollection"

	// 插入操作
	record := bson.M{"name": "John Doe", "age": 30}
	if err := InsertOne(client, dbName, dcName, record); err != nil {
		log.Fatal(err)
	}
	records := []interface{}{
		bson.M{"name": "Taylor Smith", "sex": "male", "age": 27},
		bson.M{"name": "Lisa Rune", "sex": "female", "age": 28},
		bson.M{"name": "Lily", "sex": "female", "age": 28},
		bson.M{"name": "Alex", "sex": "female", "age": 26},
		bson.M{"name": "Alisa", "sex": "female", "age": 19},
		bson.M{"name": "Tom", "sex": "male", "age": 28},
		bson.M{"name": "Felix", "sex": "male", "age": 32},
		bson.M{"name": "Richard", "sex": "male", "age": 30},
	}
	if err := InsertMany(client, dbName, dcName, records); err != nil {
		log.Fatal(err)
	}
	// 查詢操作
	results, err := Find(client, dbName, dcName, bson.M{"age": 30})
	if err != nil {
		log.Fatal(err)
	}
	for _, result := range results {
		fmt.Println(result)
	}
	// 更新操作
	if err := UpsertOne(client, dbName, dcName, bson.M{"name": "Lisa Rune"}, bson.M{"age": 31}); err != nil {
		log.Fatal(err)
	}
	if err := UpdateMany(client, dbName, dcName, bson.M{"sex": "male"}, bson.M{"age": 31}); err != nil {
		log.Fatal(err)
	}
	// 刪除操作
	if err := DeleteOne(client, dbName, dcName, bson.M{"name": "John Doe"}); err != nil {
		log.Fatal(err)
	}
	if err := DeleteMany(client, dbName, dcName, bson.M{"sex": "female"}); err != nil {
		log.Fatal(err)
	}
}

7.結(jié)果

在這里插入圖片描述

四、總結(jié)

本文通過一個(gè)簡(jiǎn)單的 Go 語(yǔ)言示例，介紹了如何使用 MongoDB 進(jìn)行基本的數(shù)據(jù)操作。我們使用了 MongoDB 的官方 Go 驅(qū)動(dòng)程序，實(shí)現(xiàn)了插入、查詢、更新和刪除操作。希望這個(gè)示例能夠幫助您更好地了解如何在 Go 語(yǔ)言中使用 MongoDB 進(jìn)行數(shù)據(jù)操作。

到此這篇關(guān)于Golang實(shí)現(xiàn)Mongo數(shù)據(jù)庫(kù)增刪改查操作的文章就介紹到這了,更多相關(guān)Golang Mongo增刪改查內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: