ElasticSearch(9)--使用Java客户端进行分页查询
2018-02-07 13:50
417 查看
分页查询
package com.es.querydemo;
import java.net.InetAddress;
import java.util.Iterator;
import java.util.Map;
import org.elasticsearch.action.search.SearchRequestBuilder;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.transport.InetSocketTransportAddress;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.sort.SortOrder;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import com.fasterxml.jackson.databind.ObjectMapper;
/**
* 查询
*
* @author Beck
* @date 2018年2月6日
*/
public class TestESQuery3 {
private static final String HOST = "127.0.0.1";
private static final int PORT = 9300;
private static final String INDEX = "eshop";
private static final String TYPE = "product";
private static final ObjectMapper MAPPER = new ObjectMapper();
private TransportClient client = null;
// 分页查询
@Test
public void pageQuery(){
SearchRequestBuilder setQuery = this.client.prepareSearch(INDEX).setTypes(TYPE)
.setQuery(QueryBuilders.matchAllQuery())
.addSort("id", SortOrder.ASC);
// 从第几条开始,查询多少条
SearchResponse response = setQuery.setFrom(0).setSize(2).get();
SearchHits searchHits = response.getHits();
System.out.println("一共的记录数: " + searchHits.getTotalHits());
Iterator<SearchHit> iterator = searchHits.iterator();
while (iterator.hasNext()){
SearchHit searchHit = iterator.next();
System.out.println(searchHit.getSourceAsString());
}
}
// 获取客户端
@Before
public void getClient() throws Exception{
client = TransportClient.builder()
.build()
.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName(HOST), PORT));
}
// 关闭客户端
@After
public void closeClient(){
if (this.client != null){
this.client.close();
}
}
}
package com.es.querydemo;
import java.net.InetAddress;
import java.util.Iterator;
import java.util.Map;
import org.elasticsearch.action.search.SearchRequestBuilder;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.transport.InetSocketTransportAddress;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.sort.SortOrder;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import com.fasterxml.jackson.databind.ObjectMapper;
/**
* 查询
*
* @author Beck
* @date 2018年2月6日
*/
public class TestESQuery3 {
private static final String HOST = "127.0.0.1";
private static final int PORT = 9300;
private static final String INDEX = "eshop";
private static final String TYPE = "product";
private static final ObjectMapper MAPPER = new ObjectMapper();
private TransportClient client = null;
// 分页查询
@Test
public void pageQuery(){
SearchRequestBuilder setQuery = this.client.prepareSearch(INDEX).setTypes(TYPE)
.setQuery(QueryBuilders.matchAllQuery())
.addSort("id", SortOrder.ASC);
// 从第几条开始,查询多少条
SearchResponse response = setQuery.setFrom(0).setSize(2).get();
SearchHits searchHits = response.getHits();
System.out.println("一共的记录数: " + searchHits.getTotalHits());
Iterator<SearchHit> iterator = searchHits.iterator();
while (iterator.hasNext()){
SearchHit searchHit = iterator.next();
System.out.println(searchHit.getSourceAsString());
}
}
// 获取客户端
@Before
public void getClient() throws Exception{
client = TransportClient.builder()
.build()
.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName(HOST), PORT));
}
// 关闭客户端
@After
public void closeClient(){
if (this.client != null){
this.client.close();
}
}
}
相关文章推荐
- ElasticSearch(8)--使用Java客户端进行复杂查询
- Elasticsearch使用scroll进行分页查询
- ElasticSearch(7)--使用Java客户端进行基本搜索
- ElasticSearch(10)--使用Java客户端进行高亮显示
- java编程使用EasyUI进行分页查询前后端代码编写
- java操作elasticsearch使用QueryBuilders进行数据查询
- 【mongoDB】Java中使用条件操作符进行查询 推荐
- 在elasticsearch 的Java客户端使用IK分词器的问题解决
- java程序员菜鸟进阶(十一)Extjs4常用功能(三)——列表grid的使用(带综合查询,分页)
- 前端使用c# winform创建客户端来进行post发送文件,后台使用java来接收
- 使用Java调用ElasticSearch提供的相关API进行数据搜索完整实例演示
- 使用KeleyiSQLHelper类进行分页查询
- 使用Java的Lucene搜索工具对检索结果进行分组和分页
- Mybatis 使用Mapper接口的Sql动态代码方式进行CURD和分页查询
- Windows下使用Java调用ElasticSearch提供的相关API进行数据搜索完整实例演示
- 优化使用ROWNUM进行分页查询的SQL
- [原创]修正SubSonic v2.2.1的一处BUG,以及如何使用SubSonic进行多表查询、子查询以及数据库分页
- 使用ajax进行分页查询因连接池耗尽导致请求被挂起(备忘)
- 企业级搜索应用服务器Solr4.10.4部署开发详解(3)- Solr使用-使用java客户端solrj进行增删改查开发
- java中使用ehcache对jdbc查询数据进行缓存