MongoDb 近/geonear 可变距离查询

我想执行一个查询，其中距离是集合中的动态字段。

集合中的条目示例：

{
  name:'myName',
  location: {lat:10, lng:20},
  maximumDistance: 10
}
{
  name:'myName2',
  location: {lat:20, lng:20},
  maximumDistance: 100
}

我的目标是从该集合中检索所有元素location接近给定位置，假设 (10,10) 但计算出的距离小于此最大距离 field.

我可以在近查询中将 maxDistance 设置为一个常量值（足够高以检索我想要的所有元素），然后在我的 java 代码中执行过滤器，但我更喜欢在查询上执行此操作，它可能太面向 SQL。

您将无法使用普通查询来执行此操作，因为您无法动态设置每个文档的距离。从 MongoDB 2.4 开始，您可以使用聚合框架来执行此操作，因为他们已将 geoNear 运算符添加到管道的开头。

第一个阶段是 geoNear，它与 geonear 命令非常相似。我们还将获得从指定点 (10,10) 到文档的距离作为结果。

第二阶段，我们需要使用项目运算符来添加 maxDistance 字段和计算的 geoNear 距离之间的差异。

最后，我们匹配那些具有正增量（（最大 - 距离）> 0）的文档。

这是使用的管道异步Java驱动程序 http://www.allanbank.com/mongodb-async-driver/的辅助类。

package example;

import static com.allanbank.mongodb.builder.AggregationProjectFields.include;
import static com.allanbank.mongodb.builder.QueryBuilder.where;
import static com.allanbank.mongodb.builder.expression.Expressions.field;
import static com.allanbank.mongodb.builder.expression.Expressions.set;
import static com.allanbank.mongodb.builder.expression.Expressions.subtract;

import com.allanbank.mongodb.bson.element.ArrayElement;
import com.allanbank.mongodb.builder.Aggregate;
import com.allanbank.mongodb.builder.AggregationGeoNear;
import com.allanbank.mongodb.builder.GeoJson;

public class AggregateGeoNear {
    public static void main(String[] args) {
        Aggregate aggregate = Aggregate
                .builder()
                .geoNear(
                        AggregationGeoNear.builder()
                                .location(GeoJson.p(10, 10))
                                .distanceField("distance"))
                .project(
                        include("name", "location", "maximumDistance"),
                        set("delta",
                                subtract(field("maximumDistance"),
                                        field("distance"))))
                .match(where("delta").greaterThanOrEqualTo(0)).build();

        System.out
                .println(new ArrayElement("pipeline", aggregate.getPipeline()));
    }
}

这是创建的管道：

pipeline : [
  {
    '$geoNear' : {
      near : [
        10, 
        10
      ],
      distanceField : 'distance',
      spherical : false,
      uniqueDocs : true
    }
  }, 
  {
    '$project' : {
      name : 1,
      location : 1,
      maximumDistance : 1,
      delta : {
        '$subtract' : [
          '$maximumDistance', 
          '$distance'
        ]
      }
    }
  }, 
  {
    '$match' : {
      delta : { '$gte' : 0 }
    }
  }
]

HTH - 罗布。

附：上述构建器使用的是驱动程序 1.2.0 版本的预发行版。当我输入代码时，代码将通过构建矩阵，并应在 2013 年 3 月 22 日星期五之前发布。