Tapis pertanyaan mongodb Golang

Editor PHP Xigua hari ini akan memperkenalkan kepada anda pelaksanaan Golang bagi pertanyaan penapisan mongodb. Apabila menggunakan pangkalan data mongodb untuk pertanyaan data, kami selalunya perlu menapis hasil pertanyaan untuk memenuhi syarat tertentu. Sebagai bahasa pengaturcaraan yang berkuasa, Golang menyediakan perpustakaan pemacu mongodb yang kaya, yang boleh melaksanakan fungsi pertanyaan penapisan dengan mudah. Seterusnya, kami akan memperkenalkan secara terperinci cara menggunakan mongodb untuk menapis pertanyaan di Golang untuk membantu semua orang menggunakan dan memahami fungsi ini dengan lebih baik.

Kandungan soalan

Saya cuba mendapatkan senarai data yang sepadan dengan pertanyaan tertentu tetapi saya mendapat ralat ini

"(atlaserror) merchant is not allowed or the syntax is incorrect, see
the atlas documentation for more information"

func ...

var result []*model.Package

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

    tokenData, err := middleware.CtxValue(ctx)

    if err != nil {
        return nil, err
    }

    orQuery := []bson.M{}
    merchant := "abc"
    completedQuery := bson.M{"status": "completed"}
    cancelledQuery := bson.M{"status": "cancelled"}
    orQuery = append(
        orQuery,
        cancelledQuery,
        completedQuery)
    limit64 := int64(limit)
    page64 := int64(page)
    match := bson.M{"$match": bson.M{"$nor": orQuery}}
    var filterQuery primitive.M

    if tokenData.Role == "admin" && merchant != nil {
        filterQuery = bson.M{"merchant": bson.M{"id": merchant}}
    } else {
        filterQuery = bson.M{"user": bson.M{"id": tokenData.Id}}
    }
    paginatedData, err1 := paginate.New(r.Collection).Context(ctx).Limit(limit64).Page(page64).Aggregate(match, filterQuery)
    if err1 != nil {
        return nil, err1
    }


...

Penyelesaian

filterquery，似乎包含 { "merchant" : { "id" : "abc" } }，被单独传递给 .aggregate()。但是聚合框架期望接收代表一系列管道阶段的东西。 文档中概述了每个阶段，预计以 $ 字符开头，例如 $match peringkat.

Pangkalan data sedang cuba memproses merchant 作为管道的 options (lihat di sini dan di sini). Tetapi pilihan sedemikian tidak wujud, oleh itu mesej ralat.

Untuk menyelesaikan masalah ini anda harus filterquery 逻辑合并到您正在构建和传递的现有 match 变量/阶段中。或者，您可以将 filterquery 包装在不同的 $match 中，然后将它们（作为单个参数）传递给 .aggregate().

Contoh ini menunjukkan mereka membina berbilang peringkat dan kemudian menyerahkannya bersama-sama ke .aggregate() melalui mongo.pipeline{...}:mongo.pipeline{...}:

将它们一起提交给 .aggregate()

// create the stages
matchStage := bson.D{{"$match", bson.D{{"toppings", "milk foam"}}}}
unsetStage := bson.D{{"$unset", bson.A{"_id", "category"}}}
sortStage := bson.D{{"$sort", bson.D{
    {"price", 1},
    {"toppings", 1}},
}}
limitStage := bson.D{{"$limit", 2}}

// pass the stage into a pipeline
// pass the pipeline as the second paramter in the Aggregate() method
cursor, err := coll.Aggregate(context.TODO(), mongo.Pipeline{matchStage, unsetStage, sortStage, limitStage})

Atas ialah kandungan terperinci Tapis pertanyaan mongodb Golang. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!