ElasticSearch-TransportClient客户端操作Es(五)
引入maven依赖
<dependency><groupId>org.elasticsearch</groupId><artifactId>elasticsearch</artifactId><version>6.8.0</version>
</dependency>
<dependency><groupId>org.elasticsearch.client</groupId><artifactId>transport</artifactId><version>6.8.0</version>
</dependency>
<dependency><groupId>org.elasticsearch.plugin</groupId><artifactId>transport-netty4-client</artifactId><version>6.8.0</version>
</dependency>
java操作es
创建索引和类型
- 创建客户端操作对象
//创建ES客户端操作对象
@Test
public void init() throws UnknownHostException {PreBuiltTransportClient preBuiltTransportClient = new PreBuiltTransportClient(Settings.EMPTY);preBuiltTransportClient.addTransportAddress(new TransportAddress(InetAddress.getByName("192.168.202.200"),9300));
}
- 创建索引
//创建索引
@Test
public void createIndex() throws UnknownHostException, ExecutionException, InterruptedException {PreBuiltTransportClient preBuiltTransportClient = new PreBuiltTransportClient(Settings.EMPTY);preBuiltTransportClient.addTransportAddress(new TransportAddress(InetAddress.getByName("192.168.202.200"),9300));//定义索引请求CreateIndexRequest ems = new CreateIndexRequest("ems");//执行索引创建CreateIndexResponse createIndexResponse = preBuiltTransportClient.admin().indices().create(ems).get();System.out.println(createIndexResponse.isAcknowledged());
}
- 删除索引
//删除索引
@Test
public void deleteIndex() throws UnknownHostException, ExecutionException, InterruptedException {PreBuiltTransportClient preBuiltTransportClient = new PreBuiltTransportClient(Settings.EMPTY);preBuiltTransportClient.addTransportAddress(new TransportAddress(InetAddress.getByName("192.168.202.200"),9300));//定义索引请求DeleteIndexRequest ems = new DeleteIndexRequest("ems");//执行索引删除AcknowledgedResponse acknowledgedResponse = preBuiltTransportClient.admin().indices().delete(ems).get();System.out.println(acknowledgedResponse.isAcknowledged());
}
- 创建索引和类型
//创建索引类型和映射
@Test
public void init() throws UnknownHostException, ExecutionException, InterruptedException {PreBuiltTransportClient preBuiltTransportClient = new PreBuiltTransportClient(Settings.EMPTY);preBuiltTransportClient.addTransportAddress(new TransportAddress(InetAddress.getByName("192.168.202.200"),9300));//创建索引CreateIndexRequest ems = new CreateIndexRequest("ems");//定义json格式映射String json = "{\"properties\":{\"name\":{\"type\":\"text\",\"analyzer\":\"ik_max_word\"},\"age\":{\"type\":\"integer\"},\"sex\":{\"type\":\"keyword\"},\"content\":{\"type\":\"text\",\"analyzer\":\"ik_max_word\"}}}";//设置类型和mappingems.mapping("emp",json, XContentType.JSON);//执行创建CreateIndexResponse createIndexResponse = preBuiltTransportClient.admin().indices().create(ems).get();System.out.println(createIndexResponse.isAcknowledged());
}
索引一条记录
- 指定id索引记录
//索引一条文档 指定id
@Test
public void createIndexOptionId() throws JsonProcessingException {Emp emp = new Emp("小陈", 23, "男", "这是一个单纯的少年,单纯的我!");String s = JSONObject.toJSONString(emp);IndexResponse indexResponse = transportClient.prepareIndex("ems", "emp", "1").setSource(s, XContentType.JSON).get();System.out.println(indexResponse.status());
}
各种普通查询
高亮查询
过滤查询
一次完整的搜索
ElasticSearch-TransportClient客户端操作Es(五)相关推荐
- Elasticsearch 之java操作es
https://blog.csdn.net/ty4315/article/details/52434296 Java操作es集群步骤1:配置集群对象信息:2:创建客户端:3:查看集群信息 1:集群名称 ...
- ElasticSearch之——Java操作ES实例(基于ES-2.3.0)
转载请注明出处:http://blog.csdn.net/l1028386804/article/details/78758691 今天,我们就来看看如何利用Java API来操作ES的数据,这里不讲 ...
- 【ELK】7. elasticsearch linux上操作es命令详解
========== 1.检查ES节点是否正常启动 curl http://192.168.6.16:9200 正常状态: 非正常状态: 1>确保服务是不是正常启动了,端口用的是哪个 2> ...
- Python操作ElasticSearch(Python操作ES)
目录 ElasticSearch官方文档 Python的ElasticSearch包安装 常见方法 基本查询 filter_path 条件查询 切片查询 match,模糊查询 match_phrase ...
- Elasticsearch笔记五之java操作es
Java操作es集群步骤1:配置集群对象信息:2:创建客户端:3:查看集群信息 1:集群名称 默认集群名为elasticsearch,如果集群名称和指定的不一致则在使用节点资源时会报错. 2:嗅探功能 ...
- 【ElasticSearch】(四)—— RestClient操作ES
目录 编辑 一.RestClient操作索引 环境搭建 1.导入数据 2.导入项目 3.mapping映射分析 4.初始化RestClient 1)创建索引库 1.代码解读 2.完整示例 2)删除索 ...
- Elasticsearch(一)——Es安装(三个必安工具、安装各种类型分词器)、Es 十大核心概念、通过 Kibana 操作 Es(中文分词、Es各种索引命令操作)
Elasticsearch(一)--Es安装(三个必安工具.安装各种类型分词器).Es 十大核心概念.通过 Kibana 操作 Es(中文分词.Es各种索引命令操作) 一.Elasticsearch ...
- Elasticsearch 7.X SpringBoot 使用 ElasticsearchRestTemplate 操作 ES
一.ElasticsearchRestTemplate 前面学习了es rest接口对es进行操作的方式,并且还学习了es的分片及扩容,有讲解了几种常见的分词器,喜欢的小伙伴可以看下本专栏的其他文章, ...
- Elasticsearch的介绍 以及使用python操作es详细步骤
一. 什么是 Elasticsearch 想查数据就免不了搜索,搜索就离不开搜索引擎,百度.谷歌都是一个非常庞大复杂的搜索引擎,他们几乎索引了互联网上开放的所有网页和数据.然而对于我们自己的业务数据来 ...
最新文章
- 论对一个程序的满意程度 | 每日趣闻
- 【问链-Eos公开课】第二课 EOS环境搭建(Ubuntu系统下)
- React中判断已完成的个数
- 出租车燃油附加费之阴谋[10-22]
- 计蒜课挑战难题:罗马数字转换成整数
- 报表 labview_【LabVIEW懒人系列教程小白入门】1.3LabVIEW数据类型
- 新漏洞可导致攻击者劫持Kindle
- Windows下用C语言连接Mysql注意问题
- linux popen阻塞_linux popen()与system()的区别
- c#生成随机彩色验证码例子
- 新云人才招聘系统抖音小程序申请配置教程
- 计蒜客--农场看守(简单的欧拉回路)
- 写在2019年来临前的倒数0.5小时
- Python编程——数字
- 在EXCEL中通过VBA实现批量读取文件夹内的文件名称
- 进制详解:二进制、八进制和十六进制
- ideaIU-2020.1下载
- 水果酒技术-山楂酒怎么做,山楂酒有几种制作方法
- 【Java自学】搬砖中年人代码自学之路Lesson 5
- 项目开发(质检督查)
热门文章
- 茅坡村计算机技术学院,名牌大学的恶搞自嘲外号
- B/S C/S架构分析与区别
- 协议 + socket import 和 form xx import *的区别 028
- Eclipse 从SVN检出项目之《文件夹 “” 已不存在 》
- SDHK_Tool.Static.SS_EulerAngleRotation 欧拉角旋转
- 阿里云产品头条(2018年2月刊)
- Bootstrap 的网格系统(Grid System)
- DEPRECATION: Python 2.7 reached the end of its life on January 1st, 2020. Please upgrade your Pytho
- (精)为何使用manven,什么是manven
- 用户体验--怎样绘制用户体验的地图