java查询所有数据_elasticsearch查询所有数据restful api以及java代码实现
原文:http://blog.java1234.com/blog/articles/366.html
restful api实现如下:
返回所有数据;
Java代码实现:
运行:
ERROR StatusLogger Log4j2 could not find a logging implementation. Please add log4j-core to the classpath. Using SimpleLogger to log to the console...
{"title":"前任3:再见前任","publishDate":"2017-12-29","content":"一对好基友孟云(韩庚 饰)和余飞(郑恺 饰)跟女友都因为一点小事宣告分手,并且“拒绝挽回,死不认错”。两人在夜店、派对与交友软件上放飞人生第二春,大肆庆祝“黄金单身期”,从而引发了一系列好笑的故事。孟云与女友同甘共苦却难逃“五年之痒”,余飞与女友则棋逢敌手相爱相杀无绝期。然而现实的“打脸”却来得猝不及防:一对推拉纠结零往来,一对纠缠互怼全交代。两对恋人都将面对最终的选择:是再次相见?还是再也不见?","director":"田羽生","price":"35"}
{"title":"机器之血","publishDate":"2017-12-29","content":"2007年,Dr.James在半岛军火商的支持下研究生化人。研究过程中,生化人安德烈发生基因突变大开杀戒,将半岛军火商杀害,并控制其组织,接管生化人的研究。Dr.James侥幸逃生,只好寻求警方的保护。特工林东(成龙 饰)不得以离开生命垂危的小女儿西西,接受证人保护任务...十三年后,一本科幻小说《机器之血》的出版引出了黑衣生化人组织,神秘骇客李森(罗志祥 饰)(被杀害的半岛军火商的儿子),以及隐姓埋名的林东,三股力量都开始接近一个“普通”女孩Nancy(欧阳娜娜 饰)的生活,想要得到她身上的秘密。而黑衣人幕后受伤隐藏多年的安德烈也再次出手,在多次缠斗之后终于抓走Nancy。林东和李森,不得不以身犯险一同前去解救,关键时刻却发现李森竟然是被杀害的半岛军火商的儿子,生化人的实验记录也落入了李森之手......","director":"张立嘉","price":"45"}
{"title":"星球大战8:最后的绝地武士","publishDate":"2018-01-05","content":"《星球大战:最后的绝地武士》承接前作《星球大战:原力觉醒》的剧情,讲述第一军团全面侵袭之下,蕾伊(黛西·雷德利 Daisy Ridley 饰)、芬恩(约翰·博耶加 John Boyega 饰)、波·达默龙(奥斯卡·伊萨克 Oscar Isaac 饰)三位年轻主角各自的抉 择和冒险故事。前作中觉醒强大原力的蕾伊独自寻访隐居的绝地大师卢克·天行者(马克·哈米尔 Mark Hamill 饰),在后者的指导下接受原力训练。芬恩接受了一项几乎不可能完成的任务,为此他不得不勇闯敌营,面对自己的过去。波·达默龙则要适应从战士向领袖的角色转换,这一过程中他也将接受一些血的教训。","director":"莱恩·约翰逊","price":"55"}
{"title":"战狼2","publishDate":"2017-07-27","content":"故事发生在非洲附近的大海上,主人公冷锋(吴京 饰)遭遇人生滑铁卢,被“开除军籍”,本想漂泊一生的他,正当他打算这么做的时候,一场突如其来的意外打破了他的计划,突然被卷入了一场非洲国家叛乱,本可以安全撤离,却因无法忘记曾经为军人的使命,孤身犯险冲回沦陷区,带领身陷屠杀中的同胞和难民,展开生死逃亡。随着斗争的持续,体内的狼性逐渐复苏,最终孤身闯入战乱区域,为同胞而战斗。","director":"吴京","price":"38"}
{"title":"羞羞的铁拳","publishDate":"2017-12-29","content":"靠打假拳混日子的艾迪生(艾伦 饰),本来和正义感十足的体育记者马小(马丽 饰)是一对冤家,没想到因为一场意外的电击,男女身体互换。性别错乱后,两人互坑互害,引发了拳坛的大地震,也揭开了假拳界的秘密,惹来一堆麻烦,最终两人在“卷莲门”副掌门张茱萸(沈腾 饰)的指点下,向恶势力挥起了羞羞的铁拳。","director":"宋阳 / 张吃鱼","price":"35"}
/**
* 创建索引 添加文档
*
* @throws Exception
*/
@Test
public void testIndex1() throws Exception {
JsonArray jsonArray = new JsonArray();
JsonObject jsonObject = new JsonObject();
jsonObject.addProperty("title", "前任3:再见前任");
jsonObject.addProperty("publishDate", "2017-12-29");
jsonObject.addProperty("content",
"一对好基友孟云(韩庚 饰)和余飞(郑恺 饰)跟女友都因为一点小事宣告分手,并且“拒绝挽回,死不认错”。两人在夜店、派对与交友软件上放飞人生第二春,大肆庆祝“黄金单身期”,从而引发了一系列好笑的故事。孟云与女友同甘共苦却难逃“五年之痒”,余飞与女友则棋逢敌手相爱相杀无绝期。然而现实的“打脸”却来得猝不及防:一对推拉纠结零往来,一对纠缠互怼全交代。两对恋人都将面对最终的选择:是再次相见?还是再也不见?");
jsonObject.addProperty("director", "田羽生");
jsonObject.addProperty("price", "35");
jsonArray.add(jsonObject);
JsonObject jsonObject2 = new JsonObject();
jsonObject2.addProperty("title", "机器之血");
jsonObject2.addProperty("publishDate", "2017-12-29");
jsonObject2.addProperty("content",
"2007年,Dr.James在半岛军火商的支持下研究生化人。研究过程中,生化人安德烈发生基因突变大开杀戒,将半岛军火商杀害,并控制其组织,接管生化人的研究。Dr.James侥幸逃生,只好寻求警方的保护。特工林东(成龙 饰)不得以离开生命垂危的小女儿西西,接受证人保护任务...十三年后,一本科幻小说《机器之血》的出版引出了黑衣生化人组织,神秘骇客李森(罗志祥 饰)(被杀害的半岛军火商的儿子),以及隐姓埋名的林东,三股力量都开始接近一个“普通”女孩Nancy(欧阳娜娜 饰)的生活,想要得到她身上的秘密。而黑衣人幕后受伤隐藏多年的安德烈也再次出手,在多次缠斗之后终于抓走Nancy。林东和李森,不得不以身犯险一同前去解救,关键时刻却发现李森竟然是被杀害的半岛军火商的儿子,生化人的实验记录也落入了李森之手......");
jsonObject2.addProperty("director", "张立嘉");
jsonObject2.addProperty("price", "45");
jsonArray.add(jsonObject2);
JsonObject jsonObject3 = new JsonObject();
jsonObject3.addProperty("title", "星球大战8:最后的绝地武士");
jsonObject3.addProperty("publishDate", "2018-01-05");
jsonObject3.addProperty("content",
"《星球大战:最后的绝地武士》承接前作《星球大战:原力觉醒》的剧情,讲述第一军团全面侵袭之下,蕾伊(黛西·雷德利 Daisy Ridley 饰)、芬恩(约翰·博耶加 John Boyega 饰)、波·达默龙(奥斯卡·伊萨克 Oscar Isaac 饰)三位年轻主角各自的抉 择和冒险故事。前作中觉醒强大原力的蕾伊独自寻访隐居的绝地大师卢克·天行者(马克·哈米尔 Mark Hamill 饰),在后者的指导下接受原力训练。芬恩接受了一项几乎不可能完成的任务,为此他不得不勇闯敌营,面对自己的过去。波·达默龙则要适应从战士向领袖的角色转换,这一过程中他也将接受一些血的教训。");
jsonObject3.addProperty("director", "莱恩·约翰逊");
jsonObject3.addProperty("price", "55");
jsonArray.add(jsonObject3);
JsonObject jsonObject4 = new JsonObject();
jsonObject4.addProperty("title", "羞羞的铁拳");
jsonObject4.addProperty("publishDate", "2017-12-29");
jsonObject4.addProperty("content",
"靠打假拳混日子的艾迪生(艾伦 饰),本来和正义感十足的体育记者马小(马丽 饰)是一对冤家,没想到因为一场意外的电击,男女身体互换。性别错乱后,两人互坑互害,引发了拳坛的大地震,也揭开了假拳界的秘密,惹来一堆麻烦,最终两人在“卷莲门”副掌门张茱萸(沈腾 饰)的指点下,向恶势力挥起了羞羞的铁拳。");
jsonObject4.addProperty("director", "宋阳 / 张吃鱼");
jsonObject4.addProperty("price", "35");
jsonArray.add(jsonObject4);
JsonObject jsonObject5 = new JsonObject();
jsonObject5.addProperty("title", "战狼2");
jsonObject5.addProperty("publishDate", "2017-07-27");
jsonObject5.addProperty("content",
"故事发生在非洲附近的大海上,主人公冷锋(吴京 饰)遭遇人生滑铁卢,被“开除军籍”,本想漂泊一生的他,正当他打算这么做的时候,一场突如其来的意外打破了他的计划,突然被卷入了一场非洲国家叛乱,本可以安全撤离,却因无法忘记曾经为军人的使命,孤身犯险冲回沦陷区,带领身陷屠杀中的同胞和难民,展开生死逃亡。随着斗争的持续,体内的狼性逐渐复苏,最终孤身闯入战乱区域,为同胞而战斗。");
jsonObject5.addProperty("director", "吴京");
jsonObject5.addProperty("price", "38");
jsonArray.add(jsonObject5);
for (int i = 0; i < jsonArray.size(); i++) {
JsonObject jo = jsonArray.get(i).getAsJsonObject();
IndexResponse response = client.prepareIndex("film", "dongzuo").setSource(jo.toString(), XContentType.JSON)
.get();
System.out.println("索引名称:" + response.getIndex());
System.out.println("类型:" + response.getType());
System.out.println("文档ID:" + response.getId());
System.out.println("当前实例状态:" + response.status());
}
}
package com.somp.ES;
import java.net.InetAddress;
import org.elasticsearch.action.search.SearchRequestBuilder;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.transport.TransportAddress;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;
import org.elasticsearch.search.sort.SortOrder;
import org.elasticsearch.transport.client.PreBuiltTransportClient;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
public class Elaticserach {
/**
* 查询所有
*/
private static String host = "192.168.50.155"; // 服务器地址
private static int port = 9300; // 端口
private TransportClient client = null;
/**
* 获取连接
*
* @return
*/
@SuppressWarnings({ "unchecked", "resource" })
@Before
public void getCient() throws Exception {
client = new PreBuiltTransportClient(Settings.EMPTY)
.addTransportAddress(new TransportAddress(InetAddress.getByName(Elaticserach.host), Elaticserach.port));
}
/**
* 关闭连接
*
* @param client
*/
@After
public void close() {
if (client != null) {
client.close();
}
}
/**
* 查询所有
*/
@Test
public void testIndex() throws Exception {
SearchRequestBuilder seb = client.prepareSearch("film").setTypes("dongzuo");
SearchResponse actionGet = seb.setQuery(QueryBuilders.matchAllQuery()).execute().actionGet();
SearchHits hits = actionGet.getHits();
for (SearchHit searchHit : hits) {
System.out.println(searchHit.getSourceAsString());
}
}
/**
* 分页查询
*/
@Test
public void testIndexPage() throws Exception {
SearchRequestBuilder seb = client.prepareSearch("film").setTypes("dongzuo");
SearchResponse actionGet = seb.setQuery(QueryBuilders.matchAllQuery()).setFrom(0).setSize(3).execute()
.actionGet();
SearchHits hits = actionGet.getHits();
for (SearchHit searchHit : hits) {
System.out.println(searchHit.getSourceAsString());
}
}
/**
* 排序
*/
@Test
public void testSort() throws Exception {
SearchRequestBuilder seb = client.prepareSearch("film").setTypes("dongzuo");
SearchResponse actionGet = seb.setQuery(QueryBuilders.matchAllQuery()).addSort("publishDate", SortOrder.DESC)
.execute().actionGet();
SearchHits hits = actionGet.getHits();
for (SearchHit searchHit : hits) {
System.out.println(searchHit.getSourceAsString());
}
}
/**
* 数据列过滤
*/
@Test
public void testInclude() throws Exception {
SearchRequestBuilder seb = client.prepareSearch("film").setTypes("dongzuo");
SearchResponse actionGet = seb.setQuery(QueryBuilders.matchAllQuery()).setFetchSource("publishDate", null)
.execute().actionGet();
SearchHits hits = actionGet.getHits();
for (SearchHit searchHit : hits) {
System.out.println(searchHit.getSourceAsString());
}
}
/**
* 按照提交查询
*/
@Test
public void testSearch() throws Exception {
SearchRequestBuilder seb = client.prepareSearch("film").setTypes("dongzuo");
SearchResponse actionGet = seb.setQuery(QueryBuilders.matchQuery("title", "战"))
.setFetchSource(new String[] { "publishDate", "title" }, null).execute().actionGet();
SearchHits hits = actionGet.getHits();
for (SearchHit searchHit : hits) {
System.out.println(searchHit.getSourceAsString());
}
}
/**
* 查询条件高亮显示
*/
@Test
public void testHigh() throws Exception {
SearchRequestBuilder seb = client.prepareSearch("film").setTypes("dongzuo");
HighlightBuilder highlightBuilder=new HighlightBuilder();
highlightBuilder.preTags("
");
highlightBuilder.postTags("");
highlightBuilder.field("title");
SearchResponse actionGet = seb.setQuery(QueryBuilders.matchQuery("title", "战")).highlighter(highlightBuilder)
.setFetchSource(new String[] { "publishDate", "title" }, null)
.execute()
.actionGet();
SearchHits hits = actionGet.getHits();
for (SearchHit searchHit : hits) {
System.out.println(searchHit.getSourceAsString());
System.out.println(searchHit.getHighlightFields());
}
}
}
java查询所有数据_elasticsearch查询所有数据restful api以及java代码实现相关推荐
- java查询elasticsearch_elasticsearch查询所有数据restful api以及java代码实现
elasticsearch查询所有数据restful api以及java代码实现 restful api实现如下: 返回所有数据: Java代码实现:/** * 查询所有 * @throws Exce ...
- ElasticSearch查询所有数据restful api以及java代码实现
elasticsearch查询所有数据restful api以及java代码实现 restful api实现如下: get http://192.168.1.111:9200/film/dongzuo ...
- java分页显示12345_elasticsearch分页查询数据restful api以及java代码实现
elasticsearch分页查询数据restful api以及java代码实现 restful api实现如下: { "from": 0, "size": 2 ...
- java多条件组合查询6_elasticsearch组合多条件查询实现restful api以及java代码实现
elasticsearch组合多条件查询实现restful api以及java代码实现 实际开发中,基本都是组合多条件查询. elasticsearch提供bool来实现这种需求: 主要参数: mus ...
- es查询所欲_ElasticSearch 查询所有数据
1,分页查询所有,但最多能查10000 条记录,超过就会报错 public List getAll(String index, String type, QueryBuilder queryBuild ...
- java中怎么判断返回200_java – 从Spring REST API返回HTTP代码200
我想使用此代码接收带有值的http链接: @PostMapping(value = "/v1/notification") public String handleNotifica ...
- java 实现微博推送_编写调用新浪微博API的Java程序来发送微博
首先,需要下载新浪微博的sdk,这里附上地址:http://vdisk.weibo.com/s/z7ifc2gccwc1b 下载完了之后解压,然后打开myeclipse,新建项目,再把刚才解压出来的i ...
- java加密与解密-核心包中的部分API(2)
主要是介绍java安全框架的核心包中的部分API作用 java.Security包 java.security包主要用于为安全框架提供类和接口 Provider类 Provider类实现了java ...
- Java RESTful API集成测试
这篇文章将重点介绍为RESTful API(带有JSON有效负载)编写Java集成测试的基本原理和机制. 目的是对技术进行介绍,并为基本正确性编写一些测试. 这些示例将使用最新版本的GitHub RE ...
最新文章
- 在plsql里面怎么去掉空行_盐渍樱花怎么做?详细做法告诉您,一年都不会坏,学会再也不用买...
- 《预训练周刊》第17期:深度迁移学习与数据增强改善2型糖尿病预测、钢琴补谱应用...
- SNS 好像遇到了拐点?
- python批量改名_Python写个批量改名工具
- ng-repeat 设定select 选择项
- html 清除float,css中如何清除float
- 链家java_链家2018春招Java工程师编程题题解
- CSS实现段落首行缩进、1.5倍行距、左右对齐
- 高频变压器_变压器图案
- SharePoint2013 备份还原
- -Block和JSON
- $@ $# $2 $0 $* Linux 参数使用
- 资深Linux 系统管理员常用的15个很好用的Cron工作示例
- pear php有什么用?,php – PEAR和PEAR2有什么区别?
- 基于 Retinex 的几种图像增强算法总结
- 锁存器,触发器,寄存器关系及区别
- 计算机网络教程第六章应用层课后习题答案
- 2022年怎么申请企业邮箱?企业云邮箱申请?
- 【榜单公布】新星计划第二季落幕,快看你有没有上榜?
- EXCEL VBA 中关于斗牛的算法