0. ES版本

6.x版本

1. 創建索引

PUT /location
{"settings": {"number_of_shards": 1,"number_of_replicas": 0},"mappings": {"location": {"properties": {"id": {"type": "keyword"},"name": {"type": "text","analyzer": "ik_max_word","search_analyzer": "ik_max_word"},"coordinate": {"type": "geo_point"}}}}
}

2. 批量插入數據

注意：這里的coordinate用的是字符串插入，所以要用緯經度。試了下用數組的形式（“coordinate”:[116.64002551005981,40.17836693398477]）會報錯，應該是6.x的版本不支持吧

PUT /location/location/_bulk
{"index":{"_id":"1"}}
{"name":"資料名稱1","coordinate":"40.17836693398477,116.64002551005981"}
{"index":{"_id":"2"}}
{"name":"資料名稱2","coordinate":"40.19103839805197,116.5624013764374"}
{"index":{"_id":"3"}}
{"name":"資料名稱3","coordinate":"40.13933715136454,116.63441990026217"}
{"index":{"_id":"4"}}
{"name":"資料名稱4","coordinate":"40.14901664712196,116.53067995860928"}
{"index":{"_id":"5"}}
{"name":"資料名稱5","coordinate":"40.125057718315716,116.62963567059545"}
{"index":{"_id":"6"}}
{"name":"資料名稱6","coordinate":"40.19216257806647,116.64025980109571"}
{"index":{"_id":"7"}}
{"name":"資料名稱7","coordinate":"40.16371689899584,116.63095084701624"}
{"index":{"_id":"8"}}
{"name":"資料名稱8","coordinate":"40.146045218040605,116.5696251832195"}
{"index":{"_id":"9"}}
{"name":"資料名稱9","coordinate":"40.144735806234166,116.60712460957835"}

3. geo_bounding_box查詢

3.1 解釋

geo_bounding_box是查詢一個矩形內的所有數據，提供左上角和右上角的經緯度坐標

3.2 經緯度屬性查詢

GET /location/location/_search
{"query": {"geo_bounding_box": {"coordinate": {"top_left": {"lat": 40.187328,"lon": 116.498353},"bottom_right": {"lat": 40.084509,"lon": 116.610461}}}}
}

3.3 經緯度數組查詢

GET /location/location/_search
{"query": {"geo_bounding_box": {"coordinate": {"top_left": [116.498353, 40.187328],"bottom_right": [116.610461, 40.084509]}}}
}

3.4 經緯度字符串查詢

GET /location/location/_search
{"query": {"geo_bounding_box": {"coordinate": {"top_left": "40.187328, 116.498353","bottom_right": "40.084509, 116.610461"}}}
}

3.5 經緯度邊界框WKT查詢

GET /location/location/_search
{"query": {"geo_bounding_box": {"coordinate": {"wkt": "BBOX(116.498353,116.610461,40.187328,40.084509)"}}}
}

3.6 經緯度頂點屬性查詢

GET /location/location/_search
{"query": {"geo_bounding_box": {"coordinate": {"top": 40.187328,"left": 116.498353,"bottom": 40.084509,"right": 116.610461}}}
}

4. geo_polygon查詢

4.1 解釋

geo_polygon查詢一個多邊形區域內的所有數據，需要按順序形成一個閉合的區域，不管從哪個坐標開始，只要能形成一個閉合區域就行

4.2 查詢

GET /location/location/_search
{"query": {"geo_polygon": {"coordinate": {"points": ["40.178012,116.577188","40.169329,116.586315","40.178288,116.591813"]}}}
}

GET /location/location/_search
{"query": {"geo_polygon": {"coordinate": {"points": ["40.178012,116.577188","40.169329,116.586315","40.178288,116.591813","40.171975,116.587105"]}}}
}

5. Springboot中使用geo_bounding_box查詢

5.1 實體類

@Data
@AllArgsConstructor
@NoArgsConstructor
@Document(indexName = "location", type = "location")
public class AddressEsEntity {@Idprivate String id;@Field(type = FieldType.Text, analyzer = "ik_max_word")private String name;@Field(type = FieldType.Keyword)private String coordinate;
}

5.2 geoBoundingBoxQuery

這里的setCorners里面直接傳topLeft和bottomRight會報錯，具體原因還沒研究

String topLeft = "40.187328,116.498353";
String bottomRight = "40.084509,116.610461";
try {SearchRequest searchRequest = new SearchRequest("location");SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();searchSourceBuilder.query(QueryBuilders.geoBoundingBoxQuery("coordinate").setCorners(new GeoPoint("40.187328,116.498353"), new GeoPoint("40.084509,116.610461")));searchRequest.types("location").source(searchSourceBuilder);SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);SearchHit[] hits = searchResponse.getHits().getHits();System.out.println(searchResponse);
} catch (IOException e) {e.printStackTrace();
}

5.3 geoPolygonQuery

List<GeoPoint> points = new ArrayList<>();
points.add(new GeoPoint("40.178012,116.577188"));
points.add(new GeoPoint("40.169329,116.586315"));
points.add(new GeoPoint("40.178288,116.591813"));
try {SearchRequest searchRequest = new SearchRequest("address");SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();searchSourceBuilder.query(QueryBuilders.geoPolygonQuery("coordinate", points));searchRequest.types("address").source(searchSourceBuilder);SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);SearchHit[] hits = searchResponse.getHits().getHits();System.out.println(searchResponse);
} catch (IOException e) {e.printStackTrace();
}