参考

sql-rest-filtering
sql-rest-columnar
sql-rest-params

使用SQL+DSL 进行过滤

通过在过滤器参数中指定查询，可以使用标准Elasticsearch查询 DSL 过滤 SQL 将在其上运行的结果。

  1. POST /_sql?format=txt
  2. {
  3.   "query": "SELECT * FROM library ORDER BY page_count DESC",
  4.   "filter": {
  5.     "range": {
  6.       "page_count": {
  7.         "gte" : 500,
  8.         "lte" : 600
  9.       }
  10.     }
  11.   },
  12.   "fetch_size": 5
  13. }

返回

  1.      author     |     name      |  page_count   |      release_date      
  2. ----------------+---------------+---------------+------------------------
  3. James S.A. Corey|Leviathan Wakes|561            |2011-06-02T00:00:00.000Z

列式结果

通常，显示 SQL 查询结果结果的最广为人知的方式是每个单独的记录/文档表示一行/行。对于某些格式，弹性搜索 SQL 可以按列方式返回结果：一行表示当前结果页面中某个列的所有值。
可以按列方向返回以下格式：

  • json
  • yaml
  • cbor
  • smile
    1. POST /_sql?format=json
    2. {
    3. "query": "SELECT * FROM library ORDER BY page_count DESC",
    4. "fetch_size": 5,
    5. "columnar": true
    6. }
    返回
    1. {
    2. "columns": [
    3.   {
    4.     "name": "author",
    5.     "type": "text"
    6.   },
    7.   {
    8.     "name": "name",
    9.     "type": "text"
    10.   },
    11.   {
    12.     "name": "page_count",
    13.     "type": "long"
    14.   },
    15.   {
    16.     "name": "release_date",
    17.     "type": "datetime"
    18.   }
    19. ],
    20. "values": [
    21.   [
    22.     "Frank Herbert",
    23.     "James S.A. Corey",
    24.     "Dan Simmons"
    25.   ],
    26.   [
    27.     "Dune",
    28.     "Leviathan Wakes",
    29.     "Hyperion"
    30.   ],
    31.   [
    32.     604,
    33.     561,
    34.     482
    35.   ],
    36.   [
    37.     "1965-06-01T00:00:00.000Z",
    38.     "2011-06-02T00:00:00.000Z",
    39.     "1989-05-26T00:00:00.000Z"
    40.   ]
    41. ]
    42. }

    将参数传递给查询

    例如，通过在查询字符串本身中集成值，可以在查询条件或语句中使用值来“内联”完成：HAVING
    1. POST /_sql?format=json
    2. {
    3.   "query": "SELECT YEAR(release_date) AS year FROM library WHERE page_count > 100  GROUP BY year HAVING COUNT(*) > 0"
    4. }
    或者可以通过提取单独的参数列表中的值并在查询字符串中使用问号占位符（）来完成：?
    1. POST /_sql?format=txt
    2. {
    3.   "query": "SELECT YEAR(release_date) AS year FROM library WHERE page_count > ? AND author = ? GROUP BY year HAVING COUNT(*) > ?",
    4.   "params": [300, "Frank Herbert", 0]
    5. }
    ```json year

1965
``` 将值传递给查询的推荐方法是使用问号占位符，以避免任何黑客攻击或 SQL 注入的尝试。