ESQUERY
更新时间：2025-10-16
描述
ESQUERY(<field>, <query_dsl>) 函数用于将无法用 SQL 表达的查询下推到 Elasticsearch 进行过滤。
第一个参数 <field> 用于关联索引，第二个参数 <query_dsl> 为 Elasticsearch 的基本 Query DSL 的 JSON 表达式，
JSON 需使用 {} 包裹，并且必须包含且仅包含一个根键，例如 match_phrase、geo_shape、bool 等。
语法
SQL
1ESQUERY(<field>, <query_dsl>)参数
| 参数 | 说明 |
|---|---|
<field> |
需要查询的字段，用于关联 Elasticsearch 索引。 |
<query_dsl> |
Elasticsearch Query DSL 的 JSON 表达式，需使用 {} 包裹，并且根键必须唯一（如 match_phrase、geo_shape、bool）。 |
返回值
返回一个布尔值，表示该文档是否匹配提供的 Elasticsearch 查询 DSL。
举例
SQL
1-- match_phrase 查询：
2SELECT * FROM es_table
3WHERE ESQUERY(k4, '{
4 "match_phrase": {
5 "k4": "doris on es"
6 }
7}');
SQL
1-- geo_shape 查询：
2SELECT * FROM es_table
3WHERE ESQUERY(k4, '{
4 "geo_shape": {
5 "location": {
6 "shape": {
7 "type": "envelope",
8 "coordinates": [
9 [13, 53],
10 [14, 52]
11 ]
12 },
13 "relation": "within"
14 }
15 }
16}');