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