esearch 增删改查

update 5.5版本

 

增加

POST exams/exams/

{

  "name":"aaa",

  "grade" : 20

}

 

根据id Get

get test/type1/1

 

根据条件 查询，（不是模糊查询）

Post /download_log/_search?q=channel=c1

 

根据id 删除 

DELETE /twitter/tweet/AV-VOjX0A1qiMdMJQXZ_

 

条件删除

POST twitter,blog/tweet,post/_delete_by_query
{
  "query": {
    "match_all": {}
  } 

} 

 

 更新

POST test/type1/1/_update

{

    "script" : {

        "inline": "ctx._source.counter += params.count",

        "lang": "painless",

        "params" : {

            "count" : 1

        }

    }

}

 

模糊查询

GET /_search

{

  "query":{

      "wildcard": { "user": "*a*" }

  }

}

 

排序，分页

GET _search

{

   "from" : 0, "size" : 10,

    "sort" : [ 

        "_score"

    ],

    "query" : {

        "term" : { "user" : "a" }

      

    }

}

 

			RestClient restClient = builder.build();
			
			//新增一个文档
//			Map<String, String> params = Collections.emptyMap();
//			String jsonString = "{" +
//			            "\"user\":\"test\"," +
//			            "\"postDate\":\"2017-11-07\"," +
//			            "\"message\":\"trying out Elasticsearch 222\"" +
//			        "}";
//			HttpEntity entity = new NStringEntity(jsonString, ContentType.APPLICATION_JSON);
//			Response response = restClient.performRequest("PUT", "/posts/doc/5", params, entity);
			
//			//查询
			Map<String, String> params = Collections.emptyMap();
			HttpAsyncResponseConsumerFactory.HeapBufferedResponseConsumerFactory consumerFactory =
			        new HttpAsyncResponseConsumerFactory.HeapBufferedResponseConsumerFactory(30 * 1024 * 1024);
			Response response = restClient.performRequest("GET", "/twitter/_search", params, null, consumerFactory); 
			
			
			//删除
//			Map<String, String> params = Collections.emptyMap();
//			HttpAsyncResponseConsumerFactory.HeapBufferedResponseConsumerFactory consumerFactory =
//			        new HttpAsyncResponseConsumerFactory.HeapBufferedResponseConsumerFactory(30 * 1024 * 1024);
//			Response response = restClient.performRequest("POST", "/posts/_delete_by_query?conflicts=proceed", params, null, consumerFactory); 
			
			
			RequestLine requestLine = response.getRequestLine(); 
			HttpHost host = response.getHost(); 
			int statusCode = response.getStatusLine().getStatusCode(); 
			Header[] headers = response.getHeaders(); 
			String responseBody = EntityUtils.toString(response.getEntity()); 
			
			System.out.println(responseBody);