Elsticsearch学习笔记

RestHighLevelClient client = new RestHighLevelClient(RestClient.builder(new HttpHost("192.168.1.208", 9200, "http")));

/**
* 最简单的方式
*/
//1.创建请求
CreateIndexRequest request = new CreateIndexRequest("sentiment");
//2.获取响应
//此处client是上面创建的高级Rest客户端实例
CreateIndexResponse createIndexResponse = client.indices().create(request, RequestOptions.DEFAULT);
//3.关闭客户端
client.colse();

/**
*	创建索引自定义索引的相关信息
*/
//1.创建请求
CreateIndexRequest request = new CreateIndexRequest("sentiment");
//2.设置索引源信息
request.source("{\n" +
                "    \"settings\" : {\n" +
                "        \"number_of_shards\" : 1,\n" +
                "        \"number_of_replicas\" : 0\n" +
                "    },\n" +
                "    \"mappings\" : {\n" +
                "        \"properties\" : {\n" +
                "            \"title\" : { \"type\" : \"text\" },\n" +
                "            \"summary\" : { \"type\" : \"text\" },\n" +
                "            \"author\" : { \"type\" : \"text\" },\n" +
                "            \"publishTime\" : { \"type\" : \"date\" }\n" +
                "        }\n" +
                "    },\n" +
                "    \"aliases\" : {\n" +
                "        \"twitter_alias\" : {}\n" +
                "    }\n" +
                "}", XContentType.JSON);
//3.获取响应
//此处client是上面创建的高级Rest客户端实例
CreateIndexResponse createIndexResponse = client.indices().create(request, RequestOptions.DEFAULT);
client.colse();

//获取名为sentiment的索引信息
GetIndexRequest indexRequest = new GetIndexRequest("sentiment");
GetIndexResponse getIndexResponse = client.indices().get(indexRequest, RequestOptions.DEFAULT);

//查看索引是否存在
GetIndexRequest request = new GetIndexRequest("sentiment");
boolean exists = client.indices().exists(request, RequestOptions.DEFAULT);

//查看索引的mapping（映射）信息
GetMappingsRequest getMappingsRequest = new GetMappingsRequest();
getMappingsRequest.indices("sentiment");
GetMappingsResponse mapping = client.indices().getMapping(getMappingsRequest, RequestOptions.DEFAULT);

//查询索引定义的字段的mapping信息
GetFieldMappingsRequest fieldMappingsRequest = new GetFieldMappingsRequest();
fieldMappingsRequest.indices("sentiment");
fieldMappingsRequest.fields("title", "summary", "author");
GetFieldMappingsResponse fieldMapping = client.indices().getFieldMapping(fieldMappingsRequest, RequestOptions.DEFAULT);

//更新索引配置信息
UpdateSettingsRequest request = new UpdateSettingsRequest("sentiment");
//设置副分片的数量为0
Settings settings =
        Settings.builder()
        .put("index.number_of_replicas", 0)
        .build(); 
request.settings(settings);
AcknowledgedResponse updateSettingsResponse =
        client.indices().putSettings(request, RequestOptions.DEFAULT);
client.close();

//删除指定名称的索引  
DeleteIndexRequest request = new DeleteIndexRequest("sentiment");
AcknowledgedResponse delete = client.indices().delete(request, RequestOptions.DEFAULT);
client.close();

//创建文档对象(例如你的某个对象)，这里用舆情类进行展示
Sentiment sentiment = new Sentiment();
sentiment.setId("1");
sentiment.setTitle("北京有一直猪乸生了20只猪崽，真牛逼~");
sentiment.setSummary("这只猪乸好犀利");
sentiment.setAuthor("小甘同学");
sentiment.setOrientation(Orientation.NEGATIVE);
sentiment.setPublishTime(new Date());
sentiment.setSourceType(SourceType.COMMENT);
sentiment.setSite("正盟");
sentiment.setUrl("http://www.baidu.com");
sentiment.setContent(null);
sentiment.setKeyWord("猪乸");
//指定文档的索引
IndexRequest indexRequest = new IndexRequest("sentiment");
//文档ID
indexRequest.id(sentiment.getId());
indexRequest.source(sentiment);
//请求创建文档
IndexResponse index = client.index(indexRequest, RequestOptions.DEFAULT);
client.close()

GET /sentiment/_search
{
  "query": {
    "term": {
      "author": "小甘同学"
    }
  },
  "track_scores":"true",
  "sort": {
    "id":{
      "order":"desc"
    }
  }
}

//java
SearchRequest searchRequest = new SearchRequest("sentiment");
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
searchSourceBuilder.query(QueryBuilders.matchQuery("author", "小甘同学"));
searchSourceBuilder.sort("id", SortOrder.DESC);
searchRequest.source(searchSourceBuilder);
SearchResponse search = client.search(searchRequest, RequestOptions.DEFAULT);

POST _search
{
  "query": {
    "bool" : {
      "must" : {
        "term" : { "authoer" : "小甘同学" }
      },
      "filter": {
        "term" : { "keyword" : "猪乸" }
      },
      "must_not" : {
        "range" : {
          "publishTime" : { "gte" : "2020-10-10" }
        }
      }
    }
  }
}

//java
SearchRequest searchRequest = new SearchRequest("sentiment");
BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
boolQueryBuilder.must(QueryBuilders.termsQuery("author"，"”小甘同学"));
boolQueryBuilder.filter(QueryBuilders.termsQuery("keyword"，"猪乸"));
boolQueryBuilder.must_not(QueryBuilders.rangeQuery("publishTime"，"2020-10-10"));
searchRequest.source(boolQueryBuilder);
SearchResponse search = client.search(searchRequest, RequestOptions.DEFAULT);

GET /_search
{
  "from": 5,
  "size": 20,
  "query": {
    "match": {
      "author": "小甘同学"
    }
  }
}

SearchRequest searchRequest = new SearchRequest("sentiment");
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
searchSourceBuilder.query(QueryBuilders.matchQuery("author", "小甘同学"));
searchSourceBuilder.from(5)
searchSourceBuilder.size(20)
searchRequest.source(searchSourceBuilder);
SearchResponse search = client.search(searchRequest, RequestOptions.DEFAULT);

//第一次请求
GET /sentiment/_search
{
     "size": 5,
     "query": {
          "match": {
               "author": "云浮"
          }
     },
     "sort": {
          "id": "asc",
          "publishTime": "desc"
     }
}

//第一次请求返回数据
{
  ...
  "hits":[
    ...
    {
      ....,
     "sortValues":["1f46c01879746f8c7e215a1ff064734d"]
    }    
  ]
}


//第二次请求
GET /sentiment/_search
{
     "size": 5,
     "query": {
          "match": {
               "author": "云浮"
          }
     },
     "sort": {
          "id": "asc",
          "publishTime": "desc"
     },
  	 "search_after":["1f46c01879746f8c7e215a1ff064734d"]
}

//java
//第一次请求
SearchRequest searchRequest1 = new SearchRequest("sentiment");
SearchSourceBuilder searchSourceBuilder1 = new SearchSourceBuilder();
searchSourceBuilder1.query(QueryBuilders.matchQuery("author", "云浮"));
searchSourceBuilder1.sort("id");
searchSourceBuilder1.size(10);
SearchResponse searchResponse1 = client.search(searchRequest1, RequestOptions.DEFAULT);
//第二次请求
SearchRequest searchRequest2 = new SearchRequest("sentiment");
SearchSourceBuilder searchSourceBuilder2 = new SearchSourceBuilder();
searchSourceBuilder2.query(QueryBuilders.matchQuery("author", "云浮"));
searchSourceBuilder2.sort("id");
//这里添加searchAfter参数
searchSourceBuilder2.searchAfter(searchResponse1.getHits().getHits()[9].getSortValues());
searchSourceBuilder2.size(10);
SearchResponse searchResponse2 = client.search(searchRequest2, RequestOptions.DEFAULT);