如何使用go mongo驱动程序在MongoDB中将[]字节存储为二进制

Question

我正在使用using go.mongodb.org/mongo-driver/mongo，并尝试在MongoDB中编写字节切片故事。但是，驱动程序将其作为整数数组进行封送处理。

在我的例子中，我有以下类型：

type Hash [20]byte

我尝试将ValueMarshaler接口实现为愚弄：

func (h Hash) MarshalBSONValue() (bsontype.Type, []byte, error) {
    return bsontype.Binary, h[:20], nil
}

但很明显，h[:20]不会返回mongo的有效字节。它会死机并返回以下内容：

panic: runtime error: slice bounds out of range [:-658764325]

goroutine 39 [running]:
go.mongodb.org/mongo-driver/x/bsonx/bsoncore.ReadElement(0xc0004bca1c, 0x1d, 0xe4, 0x55b6910, 0xffffffffffffff01, 0xc000178d00, 0xc00129aa18, 0x406d52d, 0x4819ea0, 0xc000bba240)
       /go/pkg/mod/go.mongodb.org/mongo-driver@v1.0.1/x/bsonx/bsoncore/bsoncore.go:122 +0x271
go.mongodb.org/mongo-driver/x/bsonx/bsoncore.Document.Validate(0xc0004bca18, 0x21, 0xe8, 0x4799100, 0x26)
       /go/pkg/mod/go.mongodb.org/mongo-driver@v1.0.1/x/bsonx/bsoncore/document.go:377 +0xe4
go.mongodb.org/mongo-driver/x/bsonx.(*Doc).UnmarshalBSON(0xc00129aba0, 0xc0004bca18, 0x21, 0xe8, 0x5, 0xc00129abc8)
       /go/pkg/mod/go.mongodb.org/mongo-driver@v1.0.1/x/bsonx/document.go:225 +0x6e
go.mongodb.org/mongo-driver/x/bsonx.ReadDoc(0xc0004bca18, 0x21, 0xe8, 0xc0004bca18, 0x21, 0xe8, 0xc0004bca39, 0x0)
       /go/pkg/mod/go.mongodb.org/mongo-driver@v1.0.1/x/bsonx/document.go:54 +0x77
go.mongodb.org/mongo-driver/x/bsonx.(*Val).UnmarshalBSONValue(0xc00129b2c0, 0x3, 0xc0004bca18, 0x21, 0xe8, 0x21, 0xe8)
       /go/pkg/mod/go.mongodb.org/mongo-driver@v1.0.1/x/bsonx/value.go:249 +0x90f
go.mongodb.org/mongo-driver/x/bsonx.(*Doc).UnmarshalBSON(0xc00129b370, 0xc0004bca0a, 0x30, 0xf6, 0x44747df, 0xc0000b21e0)
       /go/pkg/mod/go.mongodb.org/mongo-driver@v1.0.1/x/bsonx/document.go:236 +0x173
go.mongodb.org/mongo-driver/x/bsonx.ReadDoc(0xc0004bca0a, 0x30, 0xf6, 0xc0004bca0a, 0x30, 0xf6, 0xc0004bca3a, 0x0)
       /go/pkg/mod/go.mongodb.org/mongo-driver@v1.0.1/x/bsonx/document.go:54 +0x77
go.mongodb.org/mongo-driver/x/bsonx.(*Val).UnmarshalBSONValue(0xc00129ba90, 0x3, 0xc0004bca0a, 0x30, 0xf6, 0x30, 0xf6)
       /go/pkg/mod/go.mongodb.org/mongo-driver@v1.0.1/x/bsonx/value.go:249 +0x90f
go.mongodb.org/mongo-driver/x/bsonx.(*Doc).UnmarshalBSON(0xc00129bb40, 0xc0004bca00, 0x3b, 0x100, 0xc0000b21e0, 0x100)
       /go/pkg/mod/go.mongodb.org/mongo-driver@v1.0.1/x/bsonx/document.go:236 +0x173
go.mongodb.org/mongo-driver/x/bsonx.ReadDoc(0xc0004bca00, 0x3b, 0x100, 0x0, 0x100, 0x4833880, 0xc000bba090, 0xc0004bca00)
       /go/pkg/mod/go.mongodb.org/mongo-driver@v1.0.1/x/bsonx/document.go:54 +0x77
go.mongodb.org/mongo-driver/mongo.transformDocument(0xc00014a070, 0x4833880, 0xc000bba090, 0xc000bba120, 0x1, 0x1, 0x0, 0x0)
       /go/pkg/mod/go.mongodb.org/mongo-driver@v1.0.1/mongo/mongo.go:155 +0x1f5
go.mongodb.org/mongo-driver/mongo.(*Collection).UpdateOne(0xc00010e1e0, 0x4cca0a0, 0xc00010e3c0, 0x4833880, 0xc000bba060, 0x4833880, 0xc000bba090, 0x0, 0x0, 0x0, ...)
       /go/pkg/mod/go.mongodb.org/mongo-driver@v1.0.1/mongo/collection.go:530 +0xf0


Process finished with exit code 2

Answer 1

BSON是一个二进制JSON。JSON本身没有字节数组类型，但它确实有数组。

该库无需任何额外的封送处理程序即可处理类型。

下面是一个最小的工作示例。

package main

import (
    "context"
    "fmt"
    "time"

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

type Hash [4]byte

type Model struct {
    Key Hash `bson:"key"`
}

func main() {
    client, err := mongo.NewClient(options.Client().ApplyURI("mongodb://localhost:27017"))
    if err != nil {
        panic(err)
    }
    ctx, cancel := context.WithTimeout(context.Background(), 20*time.Second)
    defer cancel()

    err = client.Connect(ctx)
    if err != nil {
        panic(err)
    }

    db := client.Database("database")
    collection := db.Collection("collection")

    // insert as plain []byte slice
    _, err = collection.InsertOne(ctx, bson.M{"key": [4]byte{1, 2, 3, 4}})
    if err != nil {
        panic(err)
    }

    // insert h as a Hash type
    h := Hash([4]byte{1, 2, 3, 4})
    _, err = collection.InsertOne(ctx, bson.M{"key": h})
    if err != nil {
        panic(err)
    }

    cursor, err := collection.Find(ctx, bson.M{})
    if err != nil {
        panic(err)
    }

    var all []Model
    if err := cursor.All(ctx, &all); err != nil {
        panic(err)
    }

    fmt.Println(all)
}