Go语言学习笔记之golang操作MongoDB数据库
作者：PPPsych 发布时间：2024-01-27 05:06:23
标签：golang,mongodb,数据库
一 下载安装驱动
官方文档
https://pkg.go.dev/go.mongodb.org/mongo-driver/mongo
下载地址
https://www.mongodb.com/try/download/community
打开客户端
mongo.exe
创建数据库
use golang_db;
创建集合
db.createCollection("student");
下载驱动
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() {
// 设置客户端连接配置
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()
}
运行结果：
[Running] go run "e:\golang开发学习\go_pro\test.go"
MongoDB 连接成功[Done] exited with code=0 in 2.819 seconds
三 BSON简介
MongoDB中的JSON文档存储在名为BSON（二进制编码的JSON）的二进制表中。与其他将JSON数据存储为简单字符串和数字的数据库不同，BSON编码扩展了JSON表示，使其包含额外的类型，如int、long、date、浮点数和decimal128。这使得应用程序更容易可靠地处理、排序和比较数据。
连接MongoDB地Go驱动程序中有两大类型表示BSON数据：D和Raw。
类型D家族被用来简洁地构建使用本地Go类型地BSON对象。这对于构造传递给MongoDB地命令特别有用。D家族包括四大类：
D：一个BSON文档。这种类型应该在顺序重要的情况下使用，比如MongoDB命令。
M：一张无序的map。它和D是一样的，只是它不保持顺序。
A：一个BSON数组。
E：D里面的一个元素。
要使用BSON，需要先导入下面的包：
go.mongodb.org/mongo-driver/bson
下面是一个使用D类型构建地过滤器文档的例子，它可以用来查找name字段与‘张三’或‘李四’匹配的文档：
bson.D{{
"name",
bson.D{{
"$in",
bson.A{"张三","李四"},
}},
}}
Raw类型家族用于验证字节切片。还可以使用Lookup()从原始类型检索单个元素。如果不想将BSON反序列化成另一种类型的开销，那么这是非常有用的。
本文只使用
D类型。
四 添加文档
4.1 创建一个结构体
type Student struct {
Name string
Age int
}
4.2 添加单个文档
方法：
func (coll *Collection) InsertOne(ctx context.Context, document interface{},
opts ...*options.InsertOneOptions) (*InsertOneResult, error)
实例演示：
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() {
// 设置客户端连接配置
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)
}
运行结果：
[Running] go run "e:\golang开发学习\go_pro\test.go"
MongoDB 连接成功
添加了一条文档记录: ObjectID("62ee3202c3c3f019d63c34ff")[Done] exited with code=0 in 3.518 seconds
MongoDB中查看：
4.3 添加多个文档
方法：
func (coll *Collection) InsertMany(ctx context.Context, documents []interface{},
opts ...*options.InsertManyOptions) (*InsertManyResult, error)
实例演示：
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() {
// 设置客户端连接配置
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)
}
运行结果：
[Running] go run "e:\golang开发学习\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)
实例演示：
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() {
// 设置客户端连接配置
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"}})
// 单个数据查询
// 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("查找结果为: ％v\n", result)
fmt.Printf("result.Map(): ％v\n", result.Map()["name"])
}
if err := c.Err(); err != nil {
log.Fatal(err)
}
}
func main() {
findData()
}
注释内容为单个数据查询，可自行测试
运行结果：
[Running] go run "e:\golang开发学习\go_pro\test.go"
MongoDB 连接成功
查找结果为: [{_id ObjectID("62ee3202c3c3f019d63c34ff")} {name Psych} {age 18}]
result.Map(): Psych
查找结果为: [{_id ObjectID("62ee337502174a1366f86db2")} {name Klee} {age 8}]
result.Map(): Klee
查找结果为: [{_id ObjectID("62ee337502174a1366f86db3")} {name Morax} {age 1000}]
result.Map(): Morax
查找结果为: [{_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)
实例演示：
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() {
// 设置客户端连接配置
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("修改文档数量: ％v\n", ur.ModifiedCount)
}
func main() {
updateData()
}
运行结果：
[Running] go run "e:\golang开发学习\go_pro\test.go"
MongoDB 连接成功
修改文档数量: 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)
实例演示：
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() {
// 设置客户端连接配置
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("删除文档数量: ％v\n", dr.DeletedCount)
}
func main() {
deleteData()
}
运行结果：
[Running] go run "e:\golang开发学习\go_pro\test.go"
MongoDB 连接成功
删除文档数量: 1[Done] exited with code=0 in 3.698 seconds
MongoDB中查看：
来源：https://blog.csdn.net/qq_39280718/article/details/126199197
0
投稿猜你喜欢
一、react-reduxreact-redux依赖于redux工作。 运行安装命令：npm i react-redux：使用： 将Prov- 简单的for循环打印三角形1，for循环方法实现星星三角代码：for i in range(0,5):for j in range(i+1)
- 最近一段时间一直比较忙，已经有好几个月没有打理博客了。现将一个最近在项目中制作的一个菜单实例整理出来，共享一下。在后台或OA系统中最常用到的
- 对设计“以人为本”和“绿色设计”两个观点的反思——兼与设计界同仁商榷Reflection of Two Views: “People-ori
- 前言SQLite是一个进程内的库，实现了自给自足的、无服务器的、零配置的、事务性的 SQL 数据库引擎。它是一个零配置的数据库，这意味着与其
- 一, 当新增节点后刷新当前节点node.loaded = false;node.expand(); //新建子节点是刷新一次本节点的展开请求
- 一.设置客户端网络实用工具点击“开始”－“程序”，在“Microsoft SQL Server”菜单中选择“客户端网络实用工具”。 在“别名
- 如下所示：# #### dict中将key相同的字典合并在一个对象里"""a = {"a"
- 前言小程序跳一跳最近很火，之前爆出微信游戏小程序漏洞，网上也不乏大神。这里就用一大神的python脚本来刷下高分。 跳一跳python脚本传
- 前言上项目的时候，遇见一次需求，需要把在线的 其中一个 collection 里面的数据迁移到另外一个collection下，于是就百度了看
- 如下代码：<div id="vue_det"> <
- 本程序将使用字典来构建有向无环图，然后遍历图将其转换为对应的Excel文件最终结果如下：代码：(py3) [root@7-o-1 py-da
- 我就把我学习Createjs的一些心得体会向大家分享下：一.什么是CreateJS?createjs是一个轻量级的javascript库，是
- 简 介： 根据文档安装指南 介绍了在本机安装PaddlePaddle的步骤。关键词： PaddlePaddle，pip，安装§01 安装Pa
- 谷歌驱动下载地址：http://chromedriver.storage.googleapis.com/index.html一、seleni
- 代码如下:<％ FunctIon DownloadFIle(StrFIle) StrFIlename=StrFIle Response
- 无聊统计了下列表去重到底有多少种方法。下面小编给大家总结一下，具体内容详情如下；开发中对数组、列表去重是非常常见的需求，对一个list中的i
- （一）什么是json：JSON(JavaScript Object Notation) 是一种轻量级的数据交换格式。易于人阅读和编写。同时也
- 如下所示：logging: config: classpath:spring-logback.xml pattern: console: &
- 在基于互联网的应用中，程序经常需要自动地发送电子邮件。如：一个网站的注册系统会在用户注册时发送一封邮件来确认注册；当用户忘记登陆密码的时候，
