在 Go 中通过检查 MongoDB 中的多个属性值来检索项目列表
在 MongoDB 中,可以使用以下方式实现基于多个属性值检索项目聚合管道。这是使用 mgo.v2 包的 Go 实现:
<code class="go">import ( "context" "fmt" "gopkg.in/mgo.v2" "gopkg.in/mgo.v2/bson" ) func RetrieveItemListByMultipleAttributeValues(databaseName, collectionName string, venueIDs []string) (map[string]int, error) { ctx := context.Background() // Create a new MongoDB connection. session, err := mgo.Dial("mongodb://host:port") if err != nil { return nil, fmt.Errorf("Error dialing MongoDB: %w", err) } defer session.Close() // Select the database and collection. collection := session.DB(databaseName).C(collectionName) // Define the aggregation pipeline. pipeline := []bson.M{ {"$match": bson.M{"venueList.id": bson.M{"$in": venueIDs}}}, {"$unwind": "$venueList"}, {"$match": bson.M{"venueList.id": bson.M{"$in": venueIDs}}}, {"$unwind": "$venueList.sum"}, {"$group": bson.M{ "_id": "$venueList.sum.name", "count": bson.M{"$sum": "$venueList.sum.value"}, }}, {"$group": bson.M{ "_id": nil, "counts": bson.M{ "$push": bson.M{ "name": "$_id", "count": "$count", }, }, }}, } // Run the aggregation pipeline. resultIterator, err := collection.Pipe(pipeline).Iter() if err != nil { return nil, fmt.Errorf("Error running aggregation pipeline: %w", err) } // Create a map to store the aggregated results. result := make(map[string]int) // Decode each result and add it to the map. for resultIterator.Next(&result) { for _, count := range result["counts"].([]interface{}) { result[count.(map[string]interface{})["name"].(string)] = count.(map[string]interface{})["count"].(int) } } // Close the result iterator. resultIterator.Close() // Return the result map. return result, nil }</code>
以上是如何使用 Go 在 MongoDB 中基于多个属性值检索项目?的详细内容。更多信息请关注PHP中文网其他相关文章!