Estoy creando un objeto de filtro dinámico para consultar datos de mongodb en nodejs. Sin embargo, mongo arroja el error "Error al analizar el objeto de filtro, el filtro debe ser de tipo BSON". Aquí está mi código de función de referencia y la captura de pantalla de los registros .
function GetDeviceByFilter(args, cb) { var query = args.qs; var andQry = []; var orQry = []; var type = parseInt(query.type); try { if(type === uType.s){ andQry.push({sel: parseInt(query.idx)}); if(query.isSold === "0"){ orQry.push({uid: {$exists: false}}) orQry.push({uid: 0}); orQry.push({uid: null}); } else if(query.isSold === "1"){ orQry.push({uid : {$gt: 0}}); } } else if(type === uType.a){ andQry.push({admn: parseInt(query.idx)}); if(query.isSold === "0"){ orQry.push({sel: {$exists: false}}) orQry.push({sel: 0}); orQry.push({sel: null}); } else if(query.isSold === "1"){ orQry.push({sid : {$gt: 0}}); } } logger.debug("And filter ", JSON.stringify(andQry)); logger.debug("or filter ", JSON.stringify(orQry)); } catch (e) { logger.error(e); } var filter = []; filter.push({$and: andQry});// = [$and : {andQry}, {$or: orQry}]; logger.debug("filter : ",filter); var projections = { uuid: 1, mac: 1, sim: 1, imei: 1, _id: 0 }; dbClient.FindDocFieldsByFilter(devCollection, filter, projections, 0, function(e, d) { if(e) logger.error(e) cb(d, retCode.ok); }); }Toneladas de gracias de antemano.
Su variable de filter es una matriz, no un objeto y una consulta find() acepta un objeto, no una matriz. Su objeto de filter final debe tener esta estructura, por ejemplo
var filter = { "$and": [ { sel: parseInt(query.idx) }, { admn: parseInt(query.idx)} ], "$or": [ { uid: {$exists: false} }, { uid: 0 }, { uid: null} ] }Así que tienes que cambiar la pieza.
var filter = []; filter.push({$and: andQry});// = [$and : {andQry}, {$or: orQry}]; logger.debug("filter : ",filter);para
var filter = {}; filter["$and"] = andQry; filter["$or"] = orQry; logger.debug("filter : ",filter);Encuentre los valores esperados en el rango de fechas particular para obtener una salida usando Find() Keyword, para obtener toda la matriz de salidas enumeradas use All()
db := GetDB() defer db.Session.Close() var tempMeet []models.Meetings gtQuery := bson.M{"$gt": start} ltQuery := bson.M{"$lt": end} pipe := bson.M{ "$and": []bson.M{ bson.M{"startTime": gtQuery}, bson.M{"endTime": ltQuery}, }, } shared.BsonToJSONPrint(pipe) err := db.C(models.COLLECTIONNAME).Find(pipe).All(&tempMeet) if err != nil { fmt.Println(err) return nil, errors.New(err.Error()) } return tempMeet, nil