ElasticSearch DSL 簡單梳理

聲明:
本文為方便日后部分DSL結(jié)構(gòu)速查,由于索引設(shè)計(jì)不同,語法會有差異,本文默認(rèn)String 保存為keyword類型,詳細(xì)了解移步Elastic Stack 官網(wǎng)

https://www.elastic.co/guide/cn/elasticsearch/guide/current/index.html
https://www.elastic.co/guide/en/elasticsearch/reference/current/index.html

習(xí)慣用SQL的同學(xué),也可以直接用es的translate接口轉(zhuǎn)換為DSL作為參考,如下:

GET /_sql/translate
{
  "query":"select OrderId,etl_route_name from erp_order where etl_deleted = 0 "
}

1.EXP (=)

SELECT * FROM ERP_ORDER WHERE ETL_DELETE = 0

1.DSL

GET /erp_order/_search
{
  "query": {
    "bool": {
      "filter": [
        {
          "term": {
            "etl_deleted": 0
          }
        }  
      ]
    }
  }
}

2.EXP(!=)

SELECT * FROM ERP_ORDER WHERE ETL_DELETE = 0 AND ETL_DELETE != 1

2.DSL

GET /erp_order/_search
{
  "query": {
    "bool": {
      "filter": [
        {
          "term": {
            "etl_deleted": 0
          }
        }  
      ],
       "must_not":
        {
          "term": {
            "etl_deleted": 1
          }
        }
    }
  }
}

3.EXP(in)

SELECT * FROM ERP_ORDER WHERE ETL_ORDER_TYPE  IN (1,2,3,4,5)

3.DSL

GET /erp_order/_search
{
  "query": {
    "bool": {
      "filter": [
        {
          "terms": {
            "etl_order_type": [ 1, 2,3, 4,5 ]
          }
        }
      ]
    }
  }
}

4.EXP(>,<,>=,<=)

SELECT  * FROM ERP_ORDER WHERE etl_create_time_date  >= "2010-04-01T00:00:00+08:00" AND etl_create_time_date < "2021-05-01T00:00:00+08:00"

4.DSL

GET /erp_order/_search
{
  "query": {
    "bool": {
      "filter": [
        {
          "range": {
            "etl_create_time_date": {
              "gte": "2010-04-01T00:00:00+08:00",
              "lt": "2021-05-01T00:00:00+08:00"
            }
          }
        }
      ]
    }
  }
}

5.EXP(limit)

SELECT * FROM ERP_ORDER WHERE ETL_DELETE = 0 limit 10,20

5.DSL

GET /erp_order/_search
{ "from": 10,
"size": 20,
  "query": {
    "bool": {
      "filter": [
        {
          "term": {
            "etl_deleted": 0
          }
        }  
      ]
    }
  }
}

6.EXP(count(1))

SELECT COUNT(1) FROM ERP_ORDER WHERE ETL_IS_TEST = false AND ETL_DELETED = 0

6.DSL

GET /order_oms_order/_search?size=0&filter_path=hits
{
  "query": {
    "bool": {
      "filter": [
        {
          "term": {
            "etl_is_test": false
          }
        },
        {
          "term": {
            "etl_deleted": 0
          }
        }
      ]
    }
  }
}

7.EXP(COUNT-DISTINCT)

SELECT COUNT(DISTINCT ORDERID) FROM erp_order where etl_deleted = 0 

7.DSL

GET /erp_order/_search?size=0&filter_path=aggregations
{
  "query": {
    "bool": {
      "filter": [
        {
          "term": {
            "etl_deleted": 0
          }
        }
      ]
    }
  },
  "aggs": {
    "count": {
      "cardinality": {
        "field": "OrderId"
      }
    }
  }
}

8.EXP(COUNT-GROUP)

SELECT COUNT(ORDERID) FROM erp_order where etl_deleted = 0 group by etl_order_type 

8.DSL

GET /erp_order/_search?size=0&filter_path=aggregations
{
  "query": {
    "bool": {
      "filter": [
        {
          "term": {
            "etl_deleted": 0
          }
        }
      ]
    }
  },
  "aggs": {
    "type": {
      "terms": {
        "field": "etl_order_type"
      }
    }
  }
}

9.EXP(SUM-GROUP)

SELECT SUM(TotalPrice),etl_order_type FROM erp_order where etl_deleted = 0 group by etl_order_type 

9.DSL

GET /erp_order/_search?size=0&filter_path=aggregations
{
  "query": {
    "bool": {
      "filter": [
        {
          "term": {
            "etl_deleted": 0
          }
        }
      ]
    }
  },
  "aggs": {
    "typeNode": {
      "terms": {
        "field": "etl_order_type"
      },
      "aggs": {
        "totalPrice": {
          "sum": {
            "field": "TotalPrice",
            "format": "0.00"
          }
        }
      }
    }
  }
}

10.EXP(SUM-GROUP-ORDER-LIMIT)

SELECT SUM(TotalPrice) AS totalAmonut, SUM(OrderTotalCount) etl_route_name as totalCount  FROM erp_order where etl_is_test = false group by etl_order_type order by totalCount desc limit 10

10.DSL

GET /erp_order/_search?size=0&filter_path=aggregations
{
  "query": {
    "bool": {
     
      "filter": [
        {
          "term": {
            "etl_is_test": false
          }
        }
      ]
    }
  },
  "aggs": {
    "province": {
      "terms": {
        "field": "etl_route_name"
         ,"size": 10
      },
      "aggs": {
        "totalCount": {
          "sum": {
            "field": "OrderTotalCount",
            "format": "0"
          }
        },
        "totalAmonut": {
          "sum": {
            "field": "TotalPrice",
            "format": "0.00"
          }
        },
        "province_bucket_sort": {
          "bucket_sort": {
            "sort": {
              "totalCount": {
                "order": "desc"
              }
            }
          }
        }
      }
    }
  }
}

11.EXP(GROUP BY TIME)

SELECT count(1) ,DATE_FORMAT(etl_create_date,“yyyy-MM-dd”) as key_as_string  group by key_as_string  

11.1.DSL

GET /erp_order/_search?size=0&filter_path=aggregations
{
  "aggs": {
    "timeNodes": {
      "date_histogram": {
        "field": "etl_create_date",
        "calendar_interval": "day",
        "format": "yyyy-MM-dd"
      }
    }
  }
}

11.2.DSL(填充時間段內(nèi)缺失的時間數(shù)據(jù))

GET /erp_order/_search?size=0&filter_path=aggregations
{
    "query": {
    "bool": {
      "filter": [
        {
          "range": {
            "etl_create_time_date": {
              "gte": "2010-04-01T00:00:00+08:00",
              "lte": "2021-05-01T00:00:00+08:00"
            }
          }
        }
      ]
    }
  },

   "aggs": {
    "timeNodes": {
      "date_histogram": {
        "field": "etl_create_date",
        "calendar_interval": "day",
        "format": "yyyy-MM-dd",
         "min_doc_count" : 0,
         "extended_bounds" : {
                "min" : "2021-04-01",
                "max" : "2021-05-01"
         }
      }
    }
  }
}

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡書系信息發(fā)布平臺,僅提供信息存儲服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容