ElasticSearch 实现分词全文检索 - delete-by-query

elasticsearch,实现,分词,全文检索,delete,by,query · 浏览次数 : 92

小编点评

# ElasticSearch 实现分词全文检索 ## 概述 ElasticSearch 提供分词搜索功能，允许您使用多个分词词来搜索文本。这使得您可以搜索包含多个关键词的文本片段。 ## 安装和配置 1. 下载和安装 ElasticSearch。 2. 配置您的 JVM 中的 Elasticsearch 驱动程序。 3. 创建索引。 ## RESTful 基本操作使用以下 RESTful API 进行分词搜索： - `POST /sms-logs-index/_search`：搜索在 `sms-logs-index` 中的文档中。 - `GET /sms-logs-index/_search/{query}`：根据搜索字符串 `query` 查询文档。 - `POST /sms-logs-index/_delete_by_query`：根据搜索字符串 `query` 从索引中删除文档。 ## Java SpringBoot ES 索引操作 ```java @SpringBootTest public class ElasticsearchExample { @Autowired private ElasticsearchClient client; @Test public void indexAndSearch() { // 创建索引 client.indices.create("sms-logs-index"); // 创建文档 Document document = new Document(); document.put("fee", 16); client.index("sms-logs-index", document); // 查询文档 Query query = QueryBuilders.rangeQuery("fee").lt(16); SearchResult searchResult = client.search(query, Request.builder().build()); // 打印结果 System.out.println(searchResult.getTotalHits()); } } ``` ## Java SpringBoot ES 文档操作 ```java @SpringBootTest public class ElasticsearchDocumentOperations { @Autowired private ElasticsearchClient client; @Test public void createDocument() { // 创建文档 Document document = new Document(); document.put("name", "John Doe"); document.put("age", 30); client.index("users-index", document); } @Test public void updateDocument() { // 更新文档 Document document = new Document(); document.put("age", 35); client.index("users-index", document, "docid"); } @Test public void deleteDocument() { // 删除文档 client.delete("users-index", "docid"); } } ``` ## 测试数据准备 ```json { "fee": 16 } ``` ## 查询出有一条数据，删除后再查询，数据已不存在 ```json { "query": { "range": { "fee": { "lt": 15 } } } } ``` ## 聚合查询 cardinalityElasticSearch 实现分词全文检索 ```java @Query(index = "sms-logs-index", type = "doc") public class ElasticsearchCount { @QueryParam(name = "query") private String query; @QueryParam(name = "size") private Integer size; @Override public void handle(SearchResponse searchResponse, QueryContext queryContext, Request request) throws IOException { // 打印结果 System.out.println("查询结果：" + searchResponse.getTotalHits()); } } ``` ## 经纬度查询ElasticSearch 实现分词全文检索 ```java @Query(index = "location-index", type = "doc") public class ElasticsearchLocationQuery { @QueryParam(name = "latitude") private Double latitude; @QueryParam(name = "longitude") private Double longitude; @Override public void handle(SearchResponse searchResponse, QueryContext queryContext, Request request) throws IOException { // 打印结果 System.out.println("查询结果：" + searchResponse.getTotalHits()); } } ``` ## 搜素关键字自动补全(suggest)ElasticSearch 实现分词全文检索 ```java @Query(index = "users-index", type = "doc") public class ElasticsearchSuggestion { @QueryParam(name = "query") private String query; @Override public void handle(SearchResponse searchResponse, QueryContext queryContext, Request request) throws IOException { // 打印结果 System.out.println("查询结果：" + searchResponse.getTotalHits()); } } ```

正文

数据准备

ElasticSearch 实现分词全文检索 - 测试数据准备

delete-by-query

根据 term、match 等查询方式去删除大量的文档

如果需要删除的内容，是index下的大部分数据，不建议使用，因为去匹配文档时还是一个一个的拿到文档ID，去删除
推荐创建一个全新的index，将保留的文档内容，添加到全新的索引中

# 查询出有一条数据，删除后再查询，数据已不存在
GET /sms-logs-index/_search/
{
  "query": {
    "range": {
      "fee": {
        "lt": 15
      }
    }
  }
}

# delete-by-query
POST /sms-logs-index/_delete_by_query
{
  "query": {
    "range": {
      "fee": {
        "lt": 15
      }
    }
  }
}

Java

@Test
void deleteByQuery() throws Exception {
    String indexName = "sms-logs-index";
    RestHighLevelClient client = ESClient.getClient();

    //1. 创建DeleteByQueryRequest对象
    DeleteByQueryRequest request = new DeleteByQueryRequest(indexName);

    //2. 指定查询条件 和 SearchRequest 指定Query的方式不一样
    request.setQuery(QueryBuilders.rangeQuery("fee").lt(16));

    //3. 执行删除
    BulkByScrollResponse resp = client.deleteByQuery(request, RequestOptions.DEFAULT);

    //4. 输出返回值
    System.out.println(resp.toString());
}