golang操作mongodb数据库

下载安装驱动并连接数据库

下载地址https://www.mongodb.com/try/download/community

打开客户端

mongo.exe

创建数据库

use go_db;

创建集合

 db.createCollection("student");

下载驱动https://pkg.go.dev/go.mongodb.org/mongo-driver

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() {
	// 设置客户端连接配置
	co := options.Client().ApplyURI("mongodb://localhost:27017")
	// 连接到MongoDB
	var err error
	c, err2 := mongo.Connect(context.TODO(), co)
	if err2 != nil {
		log.Fatal(err2)
	}
	// 检查连接
	err3 := c.Ping(context.TODO(), nil)
	if err != nil {
		log.Fatal(err3)
	}
	fmt.Println("mongodb connected")
}

func main() {
	initDB()
}

添加文档

添加一条文档

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() {
	// 设置客户端连接配置
	co := options.Client().ApplyURI("mongodb://localhost:27017")
	// 连接到MongoDB
	var err error
	c, err2 := mongo.Connect(context.TODO(), co)
	if err2 != nil {
		log.Fatal(err2)
	}
	// 检查连接
	err3 := c.Ping(context.TODO(), nil)
	if err != nil {
		log.Fatal(err3)
	}
	fmt.Println("mongodb connected")
	client = c
}

type Student struct {
	Name string
	Age  int
}

func insertOne(s Student) {
	initDB()
	c := client.Database("go_db").Collection("student")
	ior, err := c.InsertOne(context.TODO(), s)
	if err != nil {
		log.Fatal(err)
	}
	fmt.Printf("ior.InsertedID: %vn", ior.InsertedID)
}
func main() {
	s := Student{Name: "wang fan", Age: 26}
	insertOne(s)
}

通过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() {
	// 设置客户端连接配置
	co := options.Client().ApplyURI("mongodb://localhost:27017")
	// 连接到MongoDB
	var err error
	c, err2 := mongo.Connect(context.TODO(), co)
	if err2 != nil {
		log.Fatal(err2)
	}
	// 检查连接
	err3 := c.Ping(context.TODO(), nil)
	if err != nil {
		log.Fatal(err3)
	}
	fmt.Println("mongodb connected")
	client = c
}

type Student struct {
	Name string
	Age  int
}

func insertOne(s Student) {
	initDB()
	c := client.Database("go_db").Collection("student")
	ior, err := c.InsertOne(context.TODO(), s)
	if err != nil {
		log.Fatal(err)
	}
	fmt.Printf("ior.InsertedID: %vn", ior.InsertedID)
}
func insertMore(students []interface{}) {
	initDB()
	c := client.Database("go_db").Collection("student")
	imr, err := c.InsertMany(context.TODO(), students)
	if err != nil {
		log.Fatal(err)
	}
	fmt.Printf("imr.InsertedIDs: %vn", imr.InsertedIDs)
}
func main() {
	s1 := Student{Name: "wang fan1", Age: 26}
	s2 := Student{Name: "wang fan2", Age: 26}
	s3 := Student{Name: "wang fan3", Age: 26}
	students := []interface{}{s1, s2, s3}
	insertMore(students)
}

通过MongoDB可视化工具查看有数据哦

查找文档

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() {
	// 设置客户端连接配置
	co := options.Client().ApplyURI("mongodb://localhost:27017")
	// 连接到MongoDB
	var err error
	c, err2 := mongo.Connect(context.TODO(), co)
	if err2 != nil {
		log.Fatal(err2)
	}
	// 检查连接
	err3 := c.Ping(context.TODO(), nil)
	if err != nil {
		log.Fatal(err3)
	}
	fmt.Println("mongodb connected")
	client = c
}

type Student struct {
	Name string
	Age  int
}

func insertOne(s Student) {
	initDB()
	c := client.Database("go_db").Collection("student")
	ior, err := c.InsertOne(context.TODO(), s)
	if err != nil {
		log.Fatal(err)
	}
	fmt.Printf("ior.InsertedID: %vn", ior.InsertedID)
}
func insertMore(students []interface{}) {
	initDB()
	c := client.Database("go_db").Collection("student")
	imr, err := c.InsertMany(context.TODO(), students)
	if err != nil {
		log.Fatal(err)
	}
	fmt.Printf("imr.InsertedIDs: %vn", imr.InsertedIDs)
}
func findData() {
	initDB()
	defer client.Disconnect(context.TODO())
	c := client.Database("go_db").Collection("student")
	// c2, _ := c.Find(context.Background(), bson.D{{Key: "name", Value: "wang fan"}})
	// c2, _ := c.Find(context.Background(), bson.D{{"name", "wang fan"}})
	c2, _ := c.Find(context.Background(), bson.D{})
	defer c2.Close(context.Background())
	for c2.Next(context.Background()) {
		var result bson.D
		err := c2.Decode(&result)
		if err != nil {
			log.Fatal(err)
		}
		fmt.Printf("result: %vn", result)
		fmt.Printf("result.Map(): %vn", result.Map())
		fmt.Printf("result.Map()["name"]: %vn", result.Map()["name"])
	}
	if err := c2.Err(); err != nil {
		log.Fatal(err)
	}
}
func main() {
	
	findData()
}

注意注释的两行，可打开后进行测试

更新文档

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() {
	// 设置客户端连接配置
	co := options.Client().ApplyURI("mongodb://localhost:27017")
	// 连接到MongoDB
	var err error
	c, err2 := mongo.Connect(context.TODO(), co)
	if err2 != nil {
		log.Fatal(err2)
	}
	// 检查连接
	err3 := c.Ping(context.TODO(), nil)
	if err != nil {
		log.Fatal(err3)
	}
	fmt.Println("mongodb connected")
	client = c
}

type Student struct {
	Name string
	Age  int
}

func insertOne(s Student) {
	initDB()
	c := client.Database("go_db").Collection("student")
	ior, err := c.InsertOne(context.TODO(), s)
	if err != nil {
		log.Fatal(err)
	}
	fmt.Printf("ior.InsertedID: %vn", ior.InsertedID)
}
func insertMore(students []interface{}) {
	initDB()
	c := client.Database("go_db").Collection("student")
	imr, err := c.InsertMany(context.TODO(), students)
	if err != nil {
		log.Fatal(err)
	}
	fmt.Printf("imr.InsertedIDs: %vn", imr.InsertedIDs)
}
func findData() {
	initDB()
	defer client.Disconnect(context.TODO())
	c := client.Database("go_db").Collection("student")
	// c2, _ := c.Find(context.Background(), bson.D{{Key: "name", Value: "wang fan"}})
	// c2, _ := c.Find(context.Background(), bson.D{{"name", "wang fan"}})
	c2, _ := c.Find(context.Background(), bson.D{})
	defer c2.Close(context.Background())
	for c2.Next(context.Background()) {
		var result bson.D
		err := c2.Decode(&result)
		if err != nil {
			log.Fatal(err)
		}
		fmt.Printf("result: %vn", result)
		fmt.Printf("result.Map(): %vn", result.Map())
		fmt.Printf("result.Map()["name"]: %vn", result.Map()["name"])
	}
	if err := c2.Err(); err != nil {
		log.Fatal(err)
	}
}
func update() {
	initDB()
	defer client.Disconnect(context.TODO())
	c := client.Database("go_db").Collection("student")
	update := bson.D{{"$set", bson.D{{Key: "name", Value: "王帆"}, {Key: "age", Value: 18}}}}
	// 更新条件 name wang fan 更新问 王帆 年龄 18
	ur, err := c.UpdateMany(context.TODO(), bson.D{{"name", "wang fan"}}, update)
	if err != nil {
		log.Fatal(err)
	}
	fmt.Printf("ur.ModifiedCount: %vn", ur.ModifiedCount)
}
func main() {
	update()
}

通过MongoDB可视化工具进行查看

删除文档

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() {
	// 设置客户端连接配置
	co := options.Client().ApplyURI("mongodb://localhost:27017")
	// 连接到MongoDB
	var err error
	c, err2 := mongo.Connect(context.TODO(), co)
	if err2 != nil {
		log.Fatal(err2)
	}
	// 检查连接
	err3 := c.Ping(context.TODO(), nil)
	if err != nil {
		log.Fatal(err3)
	}
	fmt.Println("mongodb connected")
	client = c
}

type Student struct {
	Name string
	Age  int
}

func insertOne(s Student) {
	initDB()
	c := client.Database("go_db").Collection("student")
	ior, err := c.InsertOne(context.TODO(), s)
	if err != nil {
		log.Fatal(err)
	}
	fmt.Printf("ior.InsertedID: %vn", ior.InsertedID)
}
func insertMore(students []interface{}) {
	initDB()
	c := client.Database("go_db").Collection("student")
	imr, err := c.InsertMany(context.TODO(), students)
	if err != nil {
		log.Fatal(err)
	}
	fmt.Printf("imr.InsertedIDs: %vn", imr.InsertedIDs)
}
func findData() {
	initDB()
	defer client.Disconnect(context.TODO())
	c := client.Database("go_db").Collection("student")
	// c2, _ := c.Find(context.Background(), bson.D{{Key: "name", Value: "wang fan"}})
	// c2, _ := c.Find(context.Background(), bson.D{{"name", "wang fan"}})
	c2, _ := c.Find(context.Background(), bson.D{})
	defer c2.Close(context.Background())
	for c2.Next(context.Background()) {
		var result bson.D
		err := c2.Decode(&result)
		if err != nil {
			log.Fatal(err)
		}
		fmt.Printf("result: %vn", result)
		fmt.Printf("result.Map(): %vn", result.Map())
		fmt.Printf("result.Map()["name"]: %vn", result.Map()["name"])
	}
	if err := c2.Err(); err != nil {
		log.Fatal(err)
	}
}
func update() {
	initDB()
	defer client.Disconnect(context.TODO())
	c := client.Database("go_db").Collection("student")
	update := bson.D{{"$set", bson.D{{Key: "name", Value: "王帆"}, {Key: "age", Value: 18}}}}
	// 更新条件 name wang fan 更新问 王帆 年龄 18
	ur, err := c.UpdateMany(context.TODO(), bson.D{{"name", "wang fan"}}, update)
	if err != nil {
		log.Fatal(err)
	}
	fmt.Printf("ur.ModifiedCount: %vn", ur.ModifiedCount)
}
func delete() {
	initDB()
	defer client.Disconnect(context.TODO())
	c := client.Database("go_db").Collection("student")
	dr, err := c.DeleteMany(context.TODO(), bson.D{{Key: "name", Value: "王帆"}})
	if err != nil {
		log.Fatal(err)
	}
	fmt.Printf("dr.DeletedCount: %vn", dr.DeletedCount)
}
func main() {
	delete()
}

查一下MongoDB可视化工具

一定要看官方文档！！！！

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

golang操作mongodb数据库

Go语言相关栏目本月热门文章