過濾查詢 mongodb Golang

php小編西瓜今天要為大家介紹的是關於過濾查詢mongodb的Golang實作。在使用mongodb資料庫進行資料查詢時，我們經常需要對查詢結果進行過濾，以滿足特定的條件。 Golang作為一種強大的程式語言，提供了豐富的mongodb驅動程式庫，可以輕鬆實現過濾查詢功能。接下來，我們將詳細介紹如何在Golang中使用mongodb進行過濾查詢，幫助大家更好地應用並理解這項功能。

問題內容

我正在嘗試取得與特定查詢相符的資料列表，但收到此錯誤

"(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
    }


...

解決方法

filterquery，似乎包含{ "merchant" : { "id" : "abc" } }#，被單獨傳遞給.aggregate()。但是聚合框架期望接收代表一系列管道階段的東西。 文件中概述了每個階段，預計以 $ 字元開頭，例如 $match 階段。

目前資料庫正在嘗試將 merchant 作為管道的 options 進行處理（請參閱 這裡和此處）。但這樣的選項不存在，因此出現錯誤訊息。

要解決此問題，您應該將 filterquery 邏輯合併到您正在建置和傳遞的現有 match 變數/階段中。或者，您可以將 filterquery 包裝在不同的 $match 中，然後將它們（作為單一參數）傳遞給 .aggregate()。

此範例文档中的a>顯示他們建立了多個階段並且然後透過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})

以上是過濾查詢 mongodb Golang的詳細內容。更多資訊請關注PHP中文網其他相關文章！