Elasticsearch 创建索引 Java 实现

1.创建索引，支持实体转map

public boolean createIndex(T entity) {String index = indexName(entity);try {CreateIndexRequest request = new CreateIndexRequest(index);request.mapping(toMapping(entity));client.indices().create(request, RequestOptions.DEFAULT);} catch (IOException e) {log.error("索引创建失败,Exception:", e);}return false;}/*** 文档类型创建** @param entity* @return*/public Map toMapping(T entity) {Field[] fields = entity.getClass().getDeclaredFields();Map<String, Object> mapping = Maps.newHashMap();Map<String, Object> fieldMap = Maps.newHashMap();mapping.put("properties", fieldMap);Stream.of(fields).forEach(field -> {if (field.isAnnotationPresent(com.zhongfu.adm.es.annotations.Field.class)) {com.zhongfu.adm.es.annotations.Field annotation =field.getAnnotation(com.zhongfu.adm.es.annotations.Field.class);Map<String, Object> fieldType = new FieldMap();String name = StringUtils.hasLength(annotation.name()) ? annotation.name() : field.getName();fieldMap.put(name, fieldType);fieldType.put("type", annotation.type().name());fieldType.put("analyzer", annotation.analyzer());fieldType.put("search_analyzer", annotation.searchAnalyzer());fieldType.put("index", annotation.index());} else {fieldMap.put(field.getName(), FieldType.AUTO);}});return mapping;}

2.判断索引是否存在

public boolean isExistsIndex(String... indices) {try {GetIndexRequest request = new GetIndexRequest(indices);return client.indices().exists(request, RequestOptions.DEFAULT);} catch (IOException e) {log.error("请求失败,Exception:", e);}return false;}

3.删除索引

public boolean deleteIndex(String... indices) {try {DeleteIndexRequest request = new DeleteIndexRequest(indices);AcknowledgedResponse response = client.indices().delete(request, RequestOptions.DEFAULT);return response.isAcknowledged();} catch (IOException e) {log.error("索引删除失败,Exception:", e);}return false;}

Elasticsearch 创建索引 Java 实现相关推荐

Java Elasticsearch创建索引
1,新建一个es的项目. 2,导入依赖Elasticsearch <dependencies><dependency><groupId> ...
怎样合理创建es索引_如何通过Elasticsearch创建索引库？
今天是刘小爱自学Java的第158天. 感谢你的观看,谢谢你. 学习计划安排如下:Elasticsearch作为一门全文检索技术,那它是如何使用的呢? 先学习Elasticsearch的一些语法,后续 ...
Elasticsearch创建索引和映射结构详解
前言这篇文章详细介绍了如何创建索引和某个类型的映射. 下文中[address]指代elasticsearch服务器访问地址(http://localhost:9200). 1 创建索引 ...
elasticsearch创建索引映射
1.我们这里通过google自带的工具postman来创建索引,这里我们创建一个:vclogdb,看到返回"acknowledged": true,表示创建成功: 2.通过elas ...
在Elasticsearch中索引Java Bean的简单方法
在数据存储方面,Java程序员习惯于使用魔术般持久的Java Bean. 诸如Hibernate和用于关系数据存储的JPA规范或Morphia和Spring Data MongoDB之类的解决方案是受 ...
Elasticsearch2.3.2创建索引java代码及异常处理
首先本文代码参考和引用了本博客的代码: http://www.cnblogs.com/coderdxj/p/6856145.html package com.test.entity; public c ...
ElasticSearch创建索引：[hotel/6g9tufKRuWDdWfgE_F30Q] ElasticsearchStatusException[Elasticsearch exception
报错: [hotel/hxWlZTdjTuKaC8m2uzj_JQ] ElasticsearchStatusException[Elasticsearch exception [type=resour ...
Elasticsearch 删除索引
章节 Elasticsearch 基本概念 Elasticsearch 安装 Elasticsearch 使用集群 Elasticsearch 健康检查 Elasticsearch 列出索引 Elas ...
ElasticSearch Java Api(一) －创建索引
ElasticSearch Java API官网文档:https://www.elastic.co/guide/en/elasticsearch/client/java-api/current/jav ...
Elasticsearch Java Client创建索引
1 配置 pom.xml org.springframework.boot spring-boot-starter-test org.elasticsearch.client elasticsearc ...

Elasticsearch 创建索引 Java 实现

Elasticsearch 创建索引 Java 实现相关推荐

最新文章

热门文章