如何使用Cloudant Java客户端搜索Cloudant空间索引文档？

针对你使用Cloudant Java客户端2.12.0版本查询空间索引的需求，我给你整理了具体的实现步骤和代码示例：

1. 确认空间索引的正确性 #

首先确保你的空间索引函数完整且符合要求，正确的空间索引函数应该输出标准GeoJSON格式的几何数据，比如：

function (doc) {
  // 确保文档包含合法的GeoJSON geometry字段
  if (doc.geometry && doc.geometry.type && doc.geometry.coordinates) {
    st_index(doc.geometry);
  }
}

你的索引位于_design/eventgeo设计文档下，索引名为st_index，这个结构是正确的。

2. Java客户端查询实现 #

Cloudant Java客户端通过SearchQuery来执行空间索引查询，以下是两种常见场景的代码示例：

初始化Cloudant客户端 #

首先创建数据库连接：

import com.cloudant.client.api.CloudantClient;
import com.cloudant.client.api.ClientBuilder;
import com.cloudant.client.api.Database;
import com.cloudant.client.api.query.SearchQuery;
import com.cloudant.client.api.query.GeoFilter;
import com.cloudant.client.api.query.SearchResult;

// 初始化客户端
CloudantClient client = ClientBuilder.account("你的Cloudant账号名")
    .username("你的用户名")
    .password("你的密码")
    .build();
// 获取目标数据库（第二个参数false表示不存在则不创建）
Database db = client.database("你的数据库名", false);

场景1：查询指定点附近的文档 #

比如查询距离旧金山市区（经纬度：-122.4194, 37.7749）10公里范围内的文档：

// 构建圆形区域的空间查询
SearchQuery query = new SearchQuery("_design/eventgeo", "st_index")
    .geo(new GeoFilter.Circle(-122.4194, 37.7749, 10.0, GeoFilter.Units.KILOMETERS));

// 执行查询并映射到自定义实体类（替换成你的文档实体类型）
SearchResult<YourDocument> result = db.search(query, YourDocument.class);

// 遍历处理结果
for (SearchResult.Row<YourDocument> row : result.getRows()) {
    YourDocument doc = row.getDoc();
    System.out.println("文档ID：" + doc.get_id());
    // 处理文档的其他逻辑
}

场景2：查询边界框内的文档 #

如果需要查询某个矩形区域内的文档，可使用边界框过滤：

// 定义边界框：参数依次为西南角经度、西南角纬度、东北角经度、东北角纬度
GeoFilter.BoundingBox bbox = new GeoFilter.BoundingBox(-122.51, 37.70, -122.39, 37.81);
SearchQuery query = new SearchQuery("_design/eventgeo", "st_index")
    .geo(bbox);

// 执行查询，若不需要实体映射可使用Object类型
SearchResult<Object> result = db.search(query, Object.class);
// 处理结果...

3. 自定义实体类示例 #

如果需要将查询结果映射到Java对象，你的实体类需要匹配文档结构，比如包含geometry字段：

public class YourDocument {
    private String _id;
    private String _rev;
    private Geometry geometry;
    // 文档的其他字段

    // Getter和Setter方法
    public String get_id() { return _id; }
    public void set_id(String _id) { this._id = _id; }

    // 内部类映射GeoJSON geometry结构
    public static class Geometry {
        private String type; // 比如"Point"、"Polygon"
        private double[] coordinates; // 经纬度数组，Point类型为[lon, lat]

        // Getter和Setter方法
        public String getType() { return type; }
        public void setType(String type) { this.type = type; }
        public double[] getCoordinates() { return coordinates; }
        public void setCoordinates(double[] coordinates) { this.coordinates = coordinates; }
    }
}

注意事项 #

• 确保Cloudant账号拥有目标数据库的查询权限；
• 如果查询结果较多，可通过query.limit()和query.skip()进行分页；
• 若需要更复杂的空间查询，可结合query.filter()添加额外的条件过滤。

内容的提问来源于stack exchange，提问作者Taketo Matsunaga