Gør det meste (og den sværeste del) af det, du ønsker, kan nemt gøres i MongoDB. Det sidste trin, når du returnerer "basic", "premium" eller "standard" kan højst sandsynligt også gøres, men jeg tror ikke, det er besværet værd, da det er trivielt i Go.
I MongoDB skal du bruge Aggregation framework
for det. Dette er tilgængeligt i mgo
pakken via Collection.Pipe()
metode. Du skal sende et udsnit til det, hvert element svarer til et aggregeringstrin. Læs dette svar for flere detaljer:Sådan får du et aggregat fra en MongoDB-samling
Tilbage til dit eksempel. Din GetEventLevel()
metode kunne implementeres på denne måde:
func (dao *campaignDAO) GetEventLevel(eventID string) (string, error) {
c := sess.DB("").C("eventboosts") // sess represents a MongoDB Session
now := time.Now()
pipe := c.Pipe([]bson.M{
{
"$match": bson.M{
"_event_id": eventID, // Boost for the specific event
"is_published": true, // Boost is active
"start_date": bson.M{"$lt": now}, // now is between start and end
"end_date": bson.M{"$gt": now}, // now is between start and end
},
},
{
"$lookup": bson.M{
"from": "campaigns",
"localField": "_campaign_id",
"foreignField": "_id",
"as": "campaign",
},
},
{"$unwind": "$campaign"},
{
"$match": bson.M{
"campaign.is_published": true, // Attached campaign is active
},
},
})
var result []*EventBoost
if err := pipe.All(&result); err != nil {
return "", err
}
if len(result) == 0 {
return "standard", nil
}
return result[0].Level, nil
}
Hvis du kun har brug for højst én EventBoost
(eller der er måske ikke flere på samme tid), brug $limit
trin for at begrænse resultaterne til et enkelt, og brug $project
kun at hente level
felt og intet mere.
Brug denne pipeline til ovennævnte forenkling/optimering:
pipe := c.Pipe([]bson.M{
{
"$match": bson.M{
"_event_id": eventID, // Boost for the specific event
"is_published": true, // Boost is active
"start_date": bson.M{"$lt": now}, // now is between start and end
"end_date": bson.M{"$gt": now}, // now is between start and end
},
},
{
"$lookup": bson.M{
"from": "campaigns",
"localField": "_campaign_id",
"foreignField": "_id",
"as": "campaign",
},
},
{"$unwind": "$campaign"},
{
"$match": bson.M{
"campaign.is_published": true, // Attached campaign is active
},
},
{"$limit": 1}, // Fetch at most 1 result
{
"$project": bson.M{
"_id": 0, // We don't even need the EventBoost's ID
"level": "$level", // We do need the level and nothing more
},
},
})