IT数码 购物 网址 头条 软件 日历 阅读 图书馆
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓ 		图片批量下载器
↓批量下载图片,美女图库↓ 		图片自动播放器
↓图片自动播放器↓ 		一键清除垃圾
↓轻轻一点,清除系统垃圾↓
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁
 
   -> 大数据 -> golang操作mongodb数据库 -> 正文阅读

[大数据]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: %v\n", 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: %v\n", 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: %v\n", 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: %v\n", 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: %v\n", 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: %v\n", result)
		fmt.Printf("result.Map(): %v\n", result.Map())
		fmt.Printf("result.Map()[\"name\"]: %v\n", result.Map()["name"])
	}
	if err := c2.Err(); err != nil {
		log.Fatal(err)
	}
}
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) */
	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: %v\n", 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: %v\n", 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: %v\n", result)
		fmt.Printf("result.Map(): %v\n", result.Map())
		fmt.Printf("result.Map()[\"name\"]: %v\n", 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: %v\n", 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: %v\n", 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: %v\n", 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: %v\n", result)
		fmt.Printf("result.Map(): %v\n", result.Map())
		fmt.Printf("result.Map()[\"name\"]: %v\n", 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: %v\n", 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: %v\n", dr.DeletedCount)
}
func main() {
	delete()
}

在这里插入图片描述查一下MongoDB可视化工具
在这里插入图片描述

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

https://pkg.go.dev/go.mongodb.org/mongo-driver/mongo#section-documentation
  大数据 最新文章
实现Kafka至少消费一次
亚马逊云科技：还在苦于ETL？Zero ETL的时代
初探MapReduce
【SpringBoot框架篇】32.基于注解+redis实现
Elasticsearch：如何减少 Elasticsearch 集
Go redis操作
Redis面试题
专题五 Redis高并发场景
基于GBase8s和Calcite的多数据源查询
Redis——底层数据结构原理
上一篇文章      下一篇文章      查看所有文章
加:2022-03-08 22:34:18  更:2022-03-08 22:36:18 
 
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁

360图书馆 购物 三丰科技 阅读网 日历 万年历 2024年11日历 -2024/11/24 9:28:49-

图片自动播放器
↓图片自动播放器↓ 		TxT小说阅读器
↓语音阅读,小说下载,古典文学↓ 		一键清除垃圾
↓轻轻一点,清除系统垃圾↓ 		图片批量下载器
↓批量下载图片,美女图库↓
  网站联系: qq:121756557 email:121756557@qq.com  IT数码