Elasticsearch:Sintaksis kueri

Konsep utama

Petakan pengetahuan SQL Anda ke terminologi Elasticsearch sebelum menulis kueri:

Plugin ini dibangun di atas Apache Calcite dan menerjemahkan pernyataan SQL ke kueri domain-specific language (DSL) Elasticsearch pada waktu proses.

Kueri dasar

Semua kueri dasar menggunakan titik akhir POST /_alisql.

POST /_alisql?pretty
{
  "query": "select * from monitor where host='100.80.xx.xx' limit 5"
}

POST /_alisql?pretty
{
  "query": "select * from monitor",
  "fetch_size": 3
}

POST /_alisql?pretty
{
  "query": "select * from monitor where host= ? ",
  "params": [{"type":"STRING","value":"100.80.xx.xx"}],
  "fetch_size": 1
}

{
  "columns": [
    {"name": "times", "type": "integer"},
    {"name": "value2", "type": "float"},
    {"name": "host", "type": "keyword"},
    {"name": "region", "type": "keyword"},
    {"name": "measurement", "type": "keyword"},
    {"name": "timestamp", "type": "date"}
  ],
  "rows": [
    [572575, 4649800.0, "100.80.xx.xx", "china-dd", "cpu", "2018-08-09T08:18:42.000Z"]
  ],
  "cursor": "u5HzAgJzY0BEWEYxWlhKNVFXNWtS****"
}

Kueri terpaginasi

Untuk set hasil yang besar, gunakan paginasi berbasis kursor.

Langkah 1 — Permintaan awal dengan `fetch_size`:

POST /_alisql?pretty
{
  "query": "select * from monitor",
  "fetch_size": 3
}

Respons mencakup token cursor jika masih tersedia data tambahan.

Langkah 2 — Lanjutkan dengan kursor:

Teruskan nilai cursor dari respons sebelumnya untuk mengambil halaman berikutnya:

POST /_alisql?pretty
{
  "cursor": "u5HzAgJzY0BEWEYxWlhKNVFXNWtS****"
}

Respons kueri kursor menghilangkan bidang columns untuk mengurangi latensi jaringan. Semua bidang lain mengikuti struktur yang sama seperti respons awal.

Langkah 3 — Kondisi akhir:

Lanjutkan mengirim permintaan kursor hingga respons tidak lagi berisi bidang cursor atau tidak ada rows. Pada titik tersebut, seluruh data telah diambil.

Kueri berformat JSON

Tambahkan format=org untuk mengembalikan hasil dalam format JSON yang sama seperti kueri DSL Elasticsearch asli. Pernyataan JOIN tidak didukung.

POST /_alisql?format=org
{
  "query": "select * from monitor where host= ? ",
  "params": [{"type":"STRING","value":"100.80.xx.xx"}],
  "fetch_size": 1
}

Respons menggunakan struktur hits standar Elasticsearch:

{
  "_scroll_id": "DXF1ZXJ5QW5kRmV0Y2gBAAAAAAAAAAsWYXNEdlVJZzJTSXFfOGluOVB4Q3Z****",
  "took": 18,
  "timed_out": false,
  "_shards": {"total": 1, "successful": 1, "skipped": 0, "failed": 0},
  "hits": {
    "total": 2,
    "max_score": 1.0,
    "hits": [
      {
        "_index": "monitor",
        "_type": "_doc",
        "_id": "2",
        "_score": 1.0,
        "_source": {
          "times": 572575,
          "value2": 4649800,
          "host": "100.80.xx.xx",
          "region": "china-dd",
          "measurement": "cpu",
          "timestamp": "2018-08-09T16:18:42+0800"
        }
      }
    ]
  }
}

Gunakan bidang _scroll_id untuk kueri terpaginasi saat bekerja dengan format ini. Semua parameter permintaan lainnya sama seperti pada kueri dasar.

Kueri terjemahan (translate)

API translate mengonversi pernyataan SQL menjadi kueri DSL Elasticsearch yang setara. Gunakan fitur ini untuk men-debug kueri atau memahami bagaimana plugin memetakan kondisi SQL ke filter DSL. Pernyataan JOIN tidak didukung.

POST _alisql/translate
{
  "query": "select * from monitor where host= '100.80.xx.xx' "
}

Respons berupa ekuivalen DSL dari kueri SQL tersebut:

{
  "size": 1000,
  "query": {
    "constant_score": {
      "filter": {
        "term": {
          "host": {
            "value": "100.80.xx.xx",
            "boost": 1.0
          }
        }
      },
      "boost": 1.0
    }
  },
  "_source": {
    "includes": ["times", "value2", "host", "region", "measurement", "timestamp"],
    "excludes": []
  }
}

Kueri khusus

Plugin aliyun-sql mendukung pengkuerian bidang dengan tipe data nested dan text, yang tidak dapat dikueri secara langsung di database SQL standar.

Langkah 1 — Buat indeks dengan bidang nested dan text:

PUT user_info/
{
  "mappings": {
    "_doc": {
      "properties": {
        "addr": {"type": "text"},
        "age": {"type": "integer"},
        "id": {"type": "integer"},
        "name": {
          "type": "nested",
          "properties": {
            "first_name": {"type": "keyword"},
            "second_name": {"type": "keyword"}
          }
        }
      }
    }
  }
}

Langkah 2 — Masukkan dokumen secara massal:

PUT user_info/_doc/_bulk?refresh
{"index":{"_id":"1"}}
{"addr":"467 Hutchinson Court","age":80,"id":"1","name":[{"first_name":"lesi","second_name":"Adams"},{"first_name":"chaochaosi","second_name":"Aams"}]}
{"index":{"_id":"2"}}
{"addr":"671 Bristol Street","age":21,"id":"2","name":{"first_name":"Hattie","second_name":"Bond"}}
{"index":{"_id":"3"}}
{"addr":"554 Bristol Street","age":23,"id":"3","name":{"first_name":"Hattie","second_name":"Bond"}}

Langkah 3 — Kueri bidang nested:

Gunakan notasi titik untuk mereferensikan bidang nested:

POST _alisql
{
  "query": "select * from user_info where name.second_name='Adams'"
}

Respons:

{
  "columns": [
    {"name": "id", "type": "integer"},
    {"name": "addr", "type": "text"},
    {"name": "name.first_name", "type": "keyword"},
    {"name": "age", "type": "integer"},
    {"name": "name.second_name", "type": "keyword"}
  ],
  "rows": [
    [1, "467 Hutchinson Court", "lesi", 80, "Adams"]
  ]
}

Langkah 4 — Mencari di bidang teks:

Filter pada bidang bertipe text menggunakan pencocokan kata kunci:

POST _alisql
{
  "query": "select * from user_info where addr='Bristol'"
}

Respons:

{
  "columns": [
    {"name": "id", "type": "integer"},
    {"name": "addr", "type": "text"},
    {"name": "name.first_name", "type": "keyword"},
    {"name": "age", "type": "integer"},
    {"name": "name.second_name", "type": "keyword"}
  ],
  "rows": [
    [2, "671 Bristol Street", "Hattie", 21, "Bond"],
    [3, "554 Bristol Street", "Hattie", 23, "Bond"]
  ]
}

Fungsi dan ekspresi bawaan