Elasticsearch入门Demo（二）

1.向索引库添加json字符串

/**
* 添加索引:传入json字符串
*/
@Test
public void addIndex2()
{
String jsonStr = "{" + "\"userName\":\"张三\"," + "\"sendDate\":\"2017-11-30\"," + "\"msg\":\"你好李四\"" + "}";
IndexResponse response = client.prepareIndex("weixin", "tweet").setSource(jsonStr, XContentType.JSON).get();
logger.info("json索引名称:" + response.getIndex() + "\njson类型:" + response.getType() + "\njson文档ID:"
+ response.getId() + "\n当前实例json状态:" + response.status());

}

2.向索引库添加一个Map集合

/**
* 创建索引-传入Map对象
*/
@Test
public void addIndex3()
{
Map<String, Object> map = new HashMap<String, Object>();
map.put("userName", "张三");
map.put("sendDate", new Date());
map.put("msg", "你好李四");

IndexResponse response = client.prepareIndex("momo", "tweet").setSource(map).get();

logger.info("map索引名称:" + response.getIndex() + "\n map类型:" + response.getType() + "\n map文档ID:"
+ response.getId() + "\n当前实例map状态:" + response.status());

}

3.向索引库添加JsonObject

/**
* 传递json对象
*/
@Test
public void addIndex4()
{
JsonObject jsonObject = new JsonObject();
jsonObject.addProperty("userName", "张三");
jsonObject.addProperty("sendDate", "2017-11-23");
jsonObject.addProperty("msg", "你好李四");

IndexResponse response = client.prepareIndex("qq", "tweet").setSource(jsonObject, XContentType.JSON).get();

logger.info("jsonObject索引名称:" + response.getIndex() + "\n jsonObject类型:" + response.getType()
+ "\n jsonObject文档ID:" + response.getId() + "\n当前实例jsonObject状态:" + response.status());

}

4.从索引库获取数据

/**
* 从索引库获取数据
*/
@Test
public void getData1()
{
GetResponse getResponse = client.prepareGet("msg", "tweet", "1").get();
logger.info("索引库的数据:" + getResponse.getSourceAsString());

}

5.更新索引库数据

/**
* 更新索引库数据
*/
@Test
public void updateData()
{
JsonObject jsonObject = new JsonObject();

jsonObject.addProperty("userName", "王五");
jsonObject.addProperty("sendDate", "2008-08-08");
jsonObject.addProperty("msg", "你好,张三，好久不见");

UpdateResponse updateResponse = client.prepareUpdate("msg", "tweet", "1")
.setDoc(jsonObject.toString(), XContentType.JSON).get();

logger.info("updateResponse索引名称:" + updateResponse.getIndex() + "\n updateResponse类型:"
+ updateResponse.getType() + "\n updateResponse文档ID:" + updateResponse.getId()
+ "\n当前实例updateResponse状态:" + updateResponse.status());

}

6.删除索引库数据

/**
* 根据索引名称，类别，文档ID 删除索引库的数据
*/
@Test
public void deleteData()
{
DeleteResponse deleteResponse = client.prepareDelete("msg", "tweet", "1").get();

logger.info("deleteResponse索引名称:" + deleteResponse.getIndex() + "\n deleteResponse类型:"
+ deleteResponse.getType() + "\n deleteResponse文档ID:" + deleteResponse.getId()
+ "\n当前实例deleteResponse状态:" + deleteResponse.status());

}

Elasticsearch入门Demo（二）相关推荐

python elasticsearch 入门教程(二) ---全文搜索
python elasticsearch 入门教程(二) ---全文搜索截止目前的搜索相对都很简单:单个姓名,通过年龄过滤.现在尝试下稍微高级点儿的全文搜索--一项传统数据库确实很难搞定的任务. ...
Elasticsearch入门（二） API
Elasticsearch入门(二) API VSCode部署 RESTful API 索引库管理列举索引创建job_idx索引库查看索引删除索引数据管理数据插入数据更新删除数据 Bu ...
Elasticsearch入门Demo（一）
1.创建一个Maven工程,在pom.xml中添加如下代码: <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns ...
Elasticsearch入门（包含整合SpringBoot和简单实战demo）
ElasticSearch 前言:本文的ElasticSearch版本是7.6.x 一.ElasticSearch概述 1.Lucene 在学习ElasticSearch之前,先简单了解一下Lucen ...
ElasticSearch插件demo
环境: 操作系统:win7 elasticsearch版本:5.4.4 java:1.8 参考文章: 1.Elasticsearch权威指南(中文版) 2.Elasticsearch笔记五之java操 ...
【ELK】ElasticSearch插件demo
环境: 操作系统:win7 elasticsearch版本:5.4.4 java:1.8 参考文章: 1.Elasticsearch权威指南(中文版) 2.Elasticsearch笔记五之java操 ...
大白话ElasticSearch入门概念，看不懂找我!
点击上方蓝色"胖滚猪学编程",选择"设为星标" 跟着胖滚猪学编程!好玩!有趣! 这是胖滚猪ES系列博文第三篇,大白话ElasticSearch入门概念. 阅读本 ...
SpringBoot入门（二）——起步依赖
本文来自网易云社区在前一篇我们通过简单几步操作就生成了一个可以直接运行的Web程序,这是因为SpringBoot代替我们做了许多工作,概括来讲可以分为起步依赖和自动配置.这一篇先来看看起步依赖. 项 ...
ElasticSearch入门第一篇：Windows下安装ElasticSearch
这是ElasticSearch 2.4 版本系列的第一篇: ElasticSearch入门第一篇:Windows下安装ElasticSearch ElasticSearch入门第二篇:集群配置 E ...

Elasticsearch入门Demo（二）

Elasticsearch入门Demo（二）相关推荐

最新文章

热门文章