目录
1、更新索引
/**
* 更新索引
* 根据数据id来进行更新索引
*/
@Test
public void updateIndex(){
Person guansheng = new Person(5, "宋江", 88, 0, "水泊梁山", "17666666666", "[email protected]","及时雨宋江");
client.prepareUpdate().setIndex("indexsearch").setType("mysearch").setId("5")
.setDoc(JSONObject.toJSONString(guansheng),XContentType.JSON)
.get();
client.close();
}
2、删除索引(3种)
(1)按照id进行删除
/**
* 按照id进行删除数据
*/
@Test
public void deleteById(){
DeleteResponse deleteResponse = client.prepareDelete("indexsearch", "mysearch", "14").get();
client.close();
}
(2)按照查询条件来进行删除
/*
按照条件进行删除
*/
@Test
public void deleteByQuery(){
BulkByScrollResponse bulkByScrollResponse = DeleteByQueryAction.INSTANCE.newRequestBuilder(client)
.filter(QueryBuilders.rangeQuery("id").gt(2).lt(4))
.source("indexsearch")
.get();
long deleted = bulkByScrollResponse.getDeleted();
System.out.println(deleted);
}
(3)删除整个索引库
@Test
public void deleteIndex(){
DeleteIndexResponse indexsearch = client.admin().indices().prepareDelete("indexsearch").execute().actionGet();
client.close();
}