首页 > 数据库 >【Go - mongodb - bson / schema】

【Go - mongodb - bson / schema】

时间:2024-07-29 23:28:33浏览次数:14  
标签:mongo err nil mongodb ctx Go bson log

Bson是什么

bson 是 MongoDB 使用的一种二进制编码格式,全称为 Binary JSON。它用于存储和传输 JSON 风格的文档数据。bson 提供了一种高效的方式来表示 JSON 数据,同时支持更多的数据类型,例如日期和二进制数据。

在 Go 语言中,bson 是由 MongoDB 官方驱动包 go.mongodb.org/mongo-driver/bson 提供的一个包,用于处理 BSON 数据。这个包提供了多种类型和函数来编码和解码 BSON 数据。

Bson常用类型与示例

  • bson.D:有序的 BSON 文档,适用于需要保持字段顺序的场景。
  • bson.M:无序的 BSON 文档,适用于不需要保持字段顺序的场景。
  • bson.A:BSON 数组,适用于表示数组的场景。
  • bson.E:键值对,常用于构建 bson.D

以下是一个包含bson.D,bson.M,bson.A,bson.E的示例

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() {
	// 连接到 MongoDB
	client, err := mongo.Connect(context.TODO(), options.Client().ApplyURI("mongodb://localhost:27017"))
	if err != nil {
		log.Fatal(err)
	}
	defer client.Disconnect(context.TODO())

	// 选择数据库和集合
	collection := client.Database("testdb").Collection("users")

	// 使用 bson.D 构建查询
	filterD := bson.D{
		{Key: "name", Value: "John"},
		{Key: "age", Value: bson.D{
			{Key: "$gt", Value: 25},
		}},
	}

	// 使用 bson.M 构建查询
	filterM := bson.M{
		"name": "John",
		"age": bson.M{
			"$gt": 25,
		},
	}

	// 使用 bson.D 构建查询,包含 bson.E 和 bson.A
	filterA := bson.D{
		{Key: "name", Value: "John"},
		{Key: "tags", Value: bson.A{"developer", "golang"}},
	}

	// 查询数据
	var resultsD []bson.M
	var resultsM []bson.M
	var resultsA []bson.M

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

	// bsonD
	cursorD, err := collection.Find(ctx, filterD)
	if err != nil {
		log.Fatal(err)
	}
	defer cursorD.Close(ctx)
	// bsonM
	cursorM, err := collection.Find(ctx, filterM)
	if err != nil {
		log.Fatal(err)
	}
	defer cursorM.Close(ctx)
	// bsonE
	// bsonA
	cursorA, err := collection.Find(ctx, filterA)
	defer cursorA.Close(ctx)

	if err = cursorD.All(ctx, &resultsD); err != nil {
		log.Fatal(err)
	}

	if err = cursorM.All(ctx, &resultsM); err != nil {
		log.Fatal(err)
	}

	if err = cursorA.All(ctx, &resultsA); err != nil {
		log.Fatal(err)
	}

	// 打印结果
	fmt.Println("Results using bson.D:", resultsD)
	fmt.Println("Results using bson.M:", resultsM)
	fmt.Println("Results using bson.D with bson.A:", resultsA)
}

如何定义表结构schema

虽然MongoDB 是no-sql类型,但在使用的时候,表结构一般是固定的,且在代码中为了更清晰的展示表结构 以及 其字段。所以一般都是 定义声明其schema,以下是个示例,

package main

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

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

// User 表结构定义
type User struct {
	// 使用omitempty来表示某些字段是可选的
	ID    primitive.ObjectID `bson:"_id,omitempty"`
	Name  string             `bson:"name"`
	Age   int                `bson:"age"`
	Email string             `bson:"email,omitempty"`
}

// 获取MongoDB客户端的单例
var singlestonMongoClient *mongo.Client
var once sync.Once

func getSinglestonMongoClient() *mongo.Client {
	once.Do(func() {
		uri := "mongodb://localhost:27017"
		client, err := mongo.Connect(context.TODO(), options.Client().ApplyURI(uri))
		if err != nil {
			panic(err)
		}
		singlestonMongoClient = client
	})
	return singlestonMongoClient
}

func main() {
	client := getSinglestonMongoClient()
	if client == nil {
		panic("client is nil")
	}

	defer func() {
		if err := client.Disconnect(context.TODO()); err != nil {
			panic(err)
		}
	}()

	// 选择数据库和集合
	collection := client.Database("testdb").Collection("users")

	// 查询用户数据
	var users []User
	ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
	defer cancel()

	cursor, err := collection.Find(ctx, bson.M{})
	if err != nil {
		log.Fatal(err)
	}
	defer cursor.Close(ctx)

	// 遍历数据
	for cursor.Next(ctx) {
		var user User
		if err := cursor.Decode(&user); err != nil {
			log.Fatal(err)
		}
		users = append(users, user)
	}

	if err := cursor.Err(); err != nil {
		log.Fatal(err)
	}
	// 打印用户数据
	for _, user := range users {
		fmt.Printf("User: %+v\n", user)
	}
}

标签:mongo,err,nil,mongodb,ctx,Go,bson,log
From: https://blog.csdn.net/qq_38428433/article/details/140783693

相关文章

  • android u开机流程详细分析(中) - zygote
    5、zygoteZygote进程是Android中所有Java进程的父进程。Zygote进程在Init进程启动过程中被以service服务的形式启动。从android5.0开始,android开始支持64位的编译,zygote本身也就有了32位和64位的区别,所以在这里用ro.zygote属性来控制启动不同版本的zygote进程。init.rc位于......
  • Golang试用阿里通义千问大语言模型
    一、控制台配置通义千问密匙官方操作指南地址控制台地址注意:一个密匙申请之后,官方给了一个月期限共计100万条Token的额度 二、代码阶段1、DashScopRequest结构体 typeEngineRolestringconst(EngineRoleUserEngineRole="user"EngineRoleSystem......
  • Go-kratos框架商城微服务实战四
    Go-kratos框架商城微服务实战四接口测试,这里采用testify进行断言测试新建/test/目录新建/test/user_grpc_test.gopackagemainimport( "context" "log" "os" "testing" "time" v1"user/api/user/v1"//导入userclient &q......
  • Django-APP及项目入门
    1.APP定义:Django中功能的细分,每个APP有独立的数据库、表结构、HTML模版、CSS。创建APPpythonmanage.pystartappapp01重要文件介绍views.py:常用文件,urls中的函数常常在此处定义。models.py:常用文件,对数据库进行操作。2.项目入门确保app也注册(settings.py)......
  • Django安装、项目创建及默认文件介绍
    1.安装pipinstalldjango【注】:Django安装完后,存放于Lib下的site-packages中。2.创建项目终端创建"D:\Python\Python312\Scripts\django-admin.exe"startprojectmysite2django-admin.exestartprojectmysite2#Scripts已加入环境变量可以直接使用django-admin.exe进......
  • 02 Go语言开发REST API接口_20240728 课程笔记
    概述如果您没有Golang的基础,应该学习如下前置课程。Golang零基础入门Golang面向对象编程GoWeb基础基础不好的同学每节课的代码最好配合视频进行阅读和学习,如果基础比较扎实,则阅读本教程巩固一下相关知识点即可,遇到不会的知识点再看视频。视频课程最近发现越来越多的......
  • 【Golang 面试 - 进阶题】每日 3 题(三)
    ✍个人博客:Pandaconda-CSDN博客......
  • 【Golang 面试 - 进阶题】每日 3 题(四)
     ✍个人博客:Pandaconda-CSDN博客......
  • Django数据导入导出神器django-import-export使用
    前言Django以快速开发闻名,但是如果处理数据的导出导入还需要自己写脚本,那就有违“Python之禅”了……而且导数据通常需要不同的格式,Excel、csv、json等,每种格式的数据就要写一个脚本太麻烦了,这时直接祭出django-import-export这个神器,官方一句话介绍:django-import-exportisaD......
  • 用依赖倒置和控制反转,突破Golang循环调用限制之后的思考
    在软件开发中,随着项目规模的扩大和业务逻辑的复杂化,重构代码变得越来越重要。本文将介绍如何在既有代码基础上,通过依赖倒置(DIP)和控制反转(IoC),实现新增加的代码可以循环引用到服务层的代码。然后,我们将探讨接口隔离、设计小而清晰的接口和包,以及共同依赖原则等内容。包引用时的......