使用firebase进行动态查询

Dynamic querying using firebase

本文关键字:动态 查询 firebase 使用      更新时间:2023-09-26

我有这个用例,我必须根据用户以对象形式发送的参数进行查询。用户可以发送多个参数进行查询。它类似于SQL中的"SELECT * FROM users WHERE FIRST_NAME = 'something' AND LAST_NAME = 'something'"。

示例对象可以是:

var object= {
    email: "some...@google.com",
    location: "San Jose, CA"
};

我有这些字段(email &我们把它命名为/users

所以用户端点看起来像:

{
  "randomID1":{
    email: "some...@google.com",
    location: "San Jose, CA"
  },
  "randomID2":{
    email: "anothe...@fb.com",
    location: "Menlo Park, CA"
  }
}

我必须使用上面提到的对象并动态地为firebase生成一个查询,下面是我所拥有的:

return $q(function(resolve, reject) {
            ref.orderByChild("email");
            for(var key in filterObject){
                if(filterObject.hasOwnProperty(key)){
                    console.log("Key: ",key);
                    console.log("Value: ",filterObject[key]);
                    ref.equalTo(""+filterObject[key],""+key);
                }
            }
            return ref.on("value", function (snapshot) {
                resolve(snapshot.val());
            }, function (errorObject) {
                reject(errorObject);
            });
        });

这总是返回给我所有的数据,并没有真正过滤任何东西。有人能给点建议吗?我是firebase的新手,如果这是一个幼稚的问题,很抱歉。

谢谢

经过一番尝试,我找到了答案。基本上,Firebase不允许查询多个属性,所以我在第一个属性上查询Firebase,如果还有更多的属性要查询,我使用下划线js来过滤那些剩余的属性。

代码如下:

return $q(function(resolve, reject) {
            var query = ref ;
            for(var key in filterObject){
                if(filterObject.hasOwnProperty(key)){
                    query = query.orderByChild(key);
                    query = query.equalTo(filterObject[key]);
                    delete(filterObject[key]);
                    break; //break out after querying the first property in firebase
                }
            }
            return query.on("value", function (snapshot) {
                var objects = snapshot.val();
                var result = _.filter(objects, function(obj){
                    return _.isMatch(obj, filterObject); //for all other objects I use underscorejs to filter
                });
                resolve(result);
            }, function (errorObject) {
                reject(errorObject);
            });
        });