| | |
|---|
| | | */ |
|---|
| | | public boolean removeBatchByIndexNames(List<String> indexNames) { |
|---|
| | | for (String indexName : indexNames) { |
|---|
| | | // 索引存在才删除 |
|---|
| | | if (isIndexExists(indexName)) { |
|---|
| | | DeleteIndexRequest deleteIndexRequest = new DeleteIndexRequest(indexName); |
|---|
| | | try { |
|---|
| | | // 执行删除索引操作 |
|---|
| | |
|---|
| | | System.out.println("索引删除成功: " + acknowledged); |
|---|
| | | } catch (IOException e) { |
|---|
| | | e.printStackTrace(); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | return true; |
|---|
| | |
|---|
| | | */ |
|---|
| | | @Async |
|---|
| | | public void update(EsParam esParam, T item,List<String> columnList) { |
|---|
| | | if (elasticsearchSync) { |
|---|
| | | // 判断索引是否存在 |
|---|
| | | if (elasticsearchSync && isIndexExists(esParam.getIndexName())) { |
|---|
| | | // 创建更新请求 |
|---|
| | | UpdateByQueryRequest updateRequest = new UpdateByQueryRequest(esParam.getIndexName()); |
|---|
| | | |
|---|
| | |
|---|
| | | * 删除数据--根据条件 |
|---|
| | | */ |
|---|
| | | public boolean removeByQuery(EsParam esParam) { |
|---|
| | | if (elasticsearchSync) { |
|---|
| | | if (elasticsearchSync && isIndexExists(esParam.getIndexName())) { |
|---|
| | | DeleteByQueryRequest deleteByQueryRequest = new DeleteByQueryRequest(esParam.getIndexName()); |
|---|
| | | // 根据多个条件 生成 boolQueryBuilder |
|---|
| | | BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery(); |
|---|
