Elasticsearch：Sintaksis Query

Query Dasar

• Query umum

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

• Query dengan jumlah entri data yang telah ditentukan

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

• Query dengan parameter tertentu

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

  Tipe	Parameter	Diperlukan	Contoh	Deskripsi
  Parameter URL	pretty	Tidak	Tidak ada.	Memformat hasil query.
  Parameter body permintaan	query	Ya	select * from monitor where host='100.80.xx.xx' limit 5	Menentukan pernyataan SQL yang ingin Anda jalankan.
  	fetch_size	Tidak	3	Menentukan jumlah entri data yang akan dikembalikan. Nilai default adalah 1000. Nilai maksimum adalah 10000. Jika Anda menetapkan parameter ini ke nilai lebih dari 10000, sistem tetap menganggap nilainya sebagai 10000. null Kedua limit dan fetch_size dapat membatasi rentang query, namun memiliki perbedaan berikut: limit: mendukung full query atau range query. fetch_size: mirip dengan Scroll.
  	params	Tidak	[{"type":"STRING","value":"100.80.xx.xx"}]	Mengimplementasikan fitur antarmuka PreparedStatement.

• Hasil query
  Saat menjalankan pernyataan SQL untuk meminta sejumlah besar data untuk pertama kalinya, jumlah entri data yang dikembalikan ditentukan oleh parameter fetch_size. Hasil query juga mencakup kursor.

  {
    "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****"
  }

  Parameter	Deskripsi
  columns	namatipe dataNama dan tipe data dari bidang yang Anda kueri.
  rows	Hasil query.
  cursor	Kursor yang digunakan untuk query selanjutnya.

  null Secara default, jumlah maksimum entri data yang dikembalikan adalah 1.000. Jika jumlah entri data yang diminta melebihi 1.000, Anda dapat menggunakan kursor untuk meminta entri tambahan hingga tidak ada kursor atau entri data yang tersisa.

Query dengan kursor

• Permintaan query

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

  Tipe	Parameter	Diperlukan	Deskripsi
  Parameter URL	pretty	Tidak	Memformat hasil query.
  Parameter body permintaan	cursor	Ya	Kursor yang digunakan untuk meminta data tertentu.

• Hasil query

  {
    "rows": [
      [
        572547,
        3.327459E7,
        "100.80.xx.xx",
        "china-dd",
        "cpu",
        "2018-08-09T08:19:12.000Z"
      ]
    ],
    "cursor": "u5HzAgJzY0BEWEYxWlhKNVFXNWtS****"
  }

  Hasil query tidak mencakup bidang columns, sehingga mengurangi latensi transmisi jaringan. Bidang lain dalam hasil query serupa dengan bidang dalam hasil query dari query dasar.

Query berformat JSON

• Permintaan query (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
  }

  format=org menunjukkan bahwa hasil query berada dalam format JSON. Parameter lainnya sama dengan yang digunakan dalam query dasar. Untuk informasi lebih lanjut, lihat Query Dasar.

• Hasil query

  {
    "_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"
          }
        }
      ]
    }
  }

  Hasil query memiliki format yang sama dengan pernyataan bahasa domain-spesifik (DSL). Parameter _scroll_id dalam hasil query digunakan untuk query halaman.

Query Terjemahan

Anda dapat menggunakan query terjemahan untuk mengonversi pernyataan SQL menjadi pernyataan DSL yang didukung oleh Elasticsearch.

• Permintaan query (pernyataan JOIN tidak didukung)

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

• Hasil query

  {
    "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": []
    }
  }

Query Khusus

Plug-in aliyun-sql memungkinkan Anda meminta data berdasarkan bidang bertipe nested dan text.

1. Buat skema tabel.

   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"
                           }
                       }
                   }
               }
           }
       }
   }

2. Masukkan sejumlah besar data sekaligus.

   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"}}

3. Minta informasi pengguna berdasarkan bidang second_name bertipe nested.

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

   Hasil berikut dikembalikan:

   {
     "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"
       ]
     ]
   }

4. Minta informasi pengguna berdasarkan bidang addr bertipe text.

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

   Hasil berikut dikembalikan:

   {
     "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"
       ]
     ]
   }

UDF

UDF hanya dapat ditambahkan selama inisialisasi plug-in aliyun-sql. Berikut adalah langkah-langkah untuk menambahkan UDF date_format:

1. Definisikan kelas DateFormat.

   /**
    * DateFormat.
    */
   public class DateFormat extends UDF {
   
       public String eval(DateTime time, String toFormat) {
           if (time == null || toFormat == null) {
               return null;
           }
           Date date = time.toDate();
           SimpleDateFormat format =  new SimpleDateFormat(toFormat);
           return format.format(date);
       }
   
   }

2. Tambahkan kelas DateFormat ke metode inisialisasi plug-in.

   udfTable.add(KeplerSqlUserDefinedScalarFunction
                   .create("date_format"
                           , DateFormat.class
                           , (JavaTypeFactoryImpl) typeFactory));

3. Gunakan UDF date_format untuk meminta data.

   select date_format(date_f,'yyyy') from date_test

Fungsi dan Ekspresi Lainnya