Elasticsearch教程(九) elasticsearch 查询数据 | 分页查询

soゝso 2016-08-23 00:23:13 64263

Elasticsearch  目录

Elasticsearch  的查询很灵活,并且有Filter,有分组功能,还有ScriptFilter等等,所以很强大。下面上代码:

一个简单的查询,返回一个List<对象> .。

/**
 * 根据Id 查询 SOBangg
 * @param key
 * @return
 */
public static List findSOBanggById(String id) {

	Client client = ESTools.client;
	SearchResponse response = client.prepareSearch(MappingManager.INDEX)
    .setTypes(MappingManager.B_TYPE)
    .setSearchType(SearchType.DFS_QUERY_THEN_FETCH)
    .setQuery(QueryBuilders.termQuery("id",id))                 // Query
//        .setPostFilter(QueryBuilders.rangeQuery("age").from(12).to(18))     // Filter
    .setFrom(0).setSize(60).setExplain(true)
    .execute()
    .actionGet();
	SearchHits hits = response.getHits();
	List list = new ArrayList();
	for (SearchHit searchHit : hits) {
		Map source = searchHit.getSource();
		SOBangg entity = (SOBangg) JSONObject.toBean(JSONObject.fromObject(source) , SOBangg.class);
		list.add(entity);
	}
	return list;
}

下面我把我整个类贴出来。

package com.sojson.core.elasticsearch.manager;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;

import net.sf.json.JSONObject;

import org.elasticsearch.action.get.GetRequest;
import org.elasticsearch.action.get.GetResponse;
import org.elasticsearch.action.search.SearchRequestBuilder;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.action.search.SearchType;
import org.elasticsearch.client.Client;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.index.query.QueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;

import com.sojson.common.model.SOBang;
import com.sojson.common.model.SOBangg;
import com.sojson.common.model.SOBanggKey;
import com.sojson.core.elasticsearch.utils.ESTools;
import com.sojson.core.mybatis.page.Pagination;

public class SelectManager {
	
	
	/**
	 * 分页查询 SOBang
	 * @param resultMap
	 * @param pageSize
	 * @param pageNo
	 * @return
	 */
	public static Pagination findByPage(Map resultMap, 
			Integer pageSize,
			Integer pageNo){
		Pagination page = new Pagination();
		pageNo = null==pageNo?1:pageNo;
		page.setPageNo(pageNo);
		page.setPageSize(pageSize);
		
		
		Client client = ESTools.client;
		SearchRequestBuilder srb = client.prepareSearch(MappingManager.INDEX);
		srb.setSearchType(SearchType.DFS_QUERY_THEN_FETCH);
		srb.setTypes(MappingManager.TYPE);
//		srb.setQuery(resultMap);
		srb.setFrom((pageNo - 1) * pageSize).setSize(pageSize)
		.setExplain(true);
		
		SearchResponse response = srb.execute().actionGet();
		SearchHits hits = response.getHits();
		
		page.setTotalCount((int)hits.getTotalHits());
		List list = new ArrayList();
		for (SearchHit searchHit : hits) {
			Map source = searchHit.getSource();
			SOBang entity = (SOBang)JSONObject.toBean(JSONObject.fromObject(source) 
						, SOBang.class);
			list.add(entity);
		}
		page.setList(list);
		return page;
		
	}
	/**
	 * 分页查询 SOBangg
	 * @param resultMap
	 * @param pageSize
	 * @param pageNo
	 * @return
	 */
	public static Pagination findSOBanggByPage(Map resultMap,
			Integer pageSize,
			Integer pageNo){
		Pagination page = new Pagination();
		pageNo = null==pageNo?1:pageNo;
		page.setPageNo(pageNo);
		page.setPageSize(pageSize);
		
		
		Client client = ESTools.client;
		SearchRequestBuilder srb = client.prepareSearch(MappingManager.INDEX);
		srb.setSearchType(SearchType.DFS_QUERY_THEN_FETCH);
		srb.setTypes(MappingManager.B_TYPE);
		
		srb.setQuery(QueryBuilders.termQuery("status",0));
		srb.setFrom((pageNo - 1) * pageSize).setSize(pageSize)
		.setExplain(true);
		
		SearchResponse response = srb.execute().actionGet();
		SearchHits hits = response.getHits();
		
		page.setTotalCount((int)hits.getTotalHits());
		List list = new ArrayList();
		for (SearchHit searchHit : hits) {
			Map source = searchHit.getSource();
			SOBangg entity = (SOBangg) JSONObject
				.toBean(JSONObject.fromObject(source) , SOBangg.class);
			list.add(entity);
		}
		page.setList(list);
		return page;
		
	}
	/**
	 * 根据ID查询SOBang
	 * @param id
	 * @return
	 */
	public static SOBang findSOBangById(String id){
		GetRequest rq = new GetRequest(MappingManager.INDEX, MappingManager.TYPE, id);
		//GetResponse response = client.prepareGet(MappingManager.INDEX, MappingManager.TYPE, id);
		GetResponse response = ESTools.client.get(rq).actionGet();
		SOBang entity = null;
		//判断非空
		if(!response.isSourceEmpty()){
			Map data = response.getSource();
			entity = (SOBang)JSONObject.toBean(JSONObject.fromObject(data)
						,SOBang.class);
		}
		return entity;
	}
	/**
	 * 根据Key 查询 SOBangg
	 * @param key
	 * @return
	 */
	public static SOBangg findSOBanggByKey(SOBanggKey key) {
		String prefix = "%sx_x%s";
		String id = String.format(prefix, key.getId(),key.getGid());
		GetRequest rq = new GetRequest(MappingManager.INDEX, MappingManager.B_TYPE, id);
		//GetResponse response = client.prepareGet(MappingManager.INDEX, MappingManager.TYPE, id);
		GetResponse response = ESTools.client.get(rq).actionGet();
		SOBangg entity = null;
		//判断非空
		if(!response.isSourceEmpty()){
			Map data = response.getSource();
			entity = (SOBangg)JSONObject.toBean(JSONObject.fromObject(data)
						,SOBangg.class);
		}
		return entity;
	}
	/**
	 * 根据Id 查询 SOBangg
	 * @param key
	 * @return
	 */
	public static List findSOBanggById(String id) {
	
		Client client = ESTools.client;
		SearchResponse response = client.prepareSearch(MappingManager.INDEX)
	    .setTypes(MappingManager.B_TYPE)
	    .setSearchType(SearchType.DFS_QUERY_THEN_FETCH)
	    .setQuery(QueryBuilders.termQuery("id",id))                 // Query
	//        .setPostFilter(QueryBuilders.rangeQuery("age").from(12).to(18))     // Filter
	    .setFrom(0).setSize(60).setExplain(true)
	    .execute()
	    .actionGet();
		SearchHits hits = response.getHits();
		List list = new ArrayList();
		for (SearchHit searchHit : hits) {
			Map source = searchHit.getSource();
			SOBangg entity = (SOBangg) JSONObject.toBean(JSONObject.fromObject(source) 
						, SOBangg.class);
			list.add(entity);
		}
		return list;
	}
	
	
	
	public static BangDetailsBo findById(String id) {
		BangDetailsBo result = new BangDetailsBo();
		GetRequest rq = new GetRequest(MappingManager.INDEX, MappingManager.TYPE, id);
		
		GetResponse response = ESTools.client.get(rq).actionGet();
		//判断非空
		if(!response.isSourceEmpty()){
			Map data = response.getSource();
			SOBang entity = (SOBang)JSONObject.toBean(JSONObject.fromObject(data)
						,SOBang.class);
			result.setEntity(entity);
		}
		
		return result;
	}
}


自己鼓捣鼓捣吧,有问题加群问我,Pagination对象我没公开,这个是系统里的,和这个查询没关系,你可以替换成你的Page对象即可。


版权所属:SO JSON在线解析

原文地址:https://www.sojson.com/blog/90.html

转载时必须以链接形式注明原始出处及本声明。

本文主题:

如果本文对你有帮助,那么请你赞助我,让我更有激情的写下去,帮助更多的人。

关于作者
一个低调而闷骚的男人。
相关文章
Elasticsearch教程Elasticsearch count 查询Elasticsearch 查询是否存在
Elasticsearch 教程Elasticsearch 日期查询详解,Elasticsearch Date 查询Java API
Elasticsearch 聚合(aggregation)查询返回所有
Elasticsearch教程(八) elasticsearch delete 删除数据(Java)
Elasticsearch教程(五) elasticsearch Mapping的创建
Elasticsearch教程(七) elasticsearch Insert 插入数据(Java)
Elasticsearch教程Elasticsearch配置文件 — elasticsearch.yml
Elasticsearch教程(六) elasticsearch Client创建
Elasticsearch教程Elasticsearch Java API创建Mapping,指定分词器
Elasticsearch 教程Elasticsearch部署阿里云集群,支持外网请求方式
最新文章
使用七牛云存储实现图片API,自动删除图片方案合集 1140
神速ICP备案经验分享,ICP备案居然一天就通过了 2238
百度加强推送URL链接,百度SEO强行推送链接JavaScript代码案例讲解。 2913
SOJSON 拓展服务器被DDos攻击了一晚上,是如何解决的? 3358
湖南地区备案“新增网站需提交组网方案或解释说明”,关于备案做简单叙述 3314
企查查你是个什么企业,骗子的帮凶,诈骗的集中营,通过企查查骚扰企业电话不断,为所欲为的企查查 9623
Java爬取百度云观测对网站的检测数据,获取子域名及域名的安全信息 2555
【2020年】百度搜索词获取,获取百度搜索的关键词【真实有效】 7037
Nodejs环境安装,Nodejs环境安装一篇就够了 1804
iOS版淘宝打开提示“您使用的程序是内测版本,将于2020-03-28到期,到期将无法使用,请尽快下载最新版本” 2505
最热文章
苹果电脑Mac怎么恢复出厂系统?苹果系统怎么重装系统? 432360
我为什么要选择RabbitMQ ,RabbitMQ简介,各种MQ选型对比 417837
免费天气API,全国天气 JSON API接口,可以获取五天的天气预报 350803
最新MyEclipse8.5注册码,有效期到2020年 (已经更新) 312147
免费天气API,天气JSON API,不限次数获取十五天的天气预报 288054
Elasticsearch教程(四) elasticsearch head 插件安装和使用 221370
Jackson 时间格式化,时间注解 @JsonFormat 用法、时差问题说明 177535
谈谈斐讯路由器劫持,你用斐讯路由器,你需要知道的事情 136407
Elasticsearch教程(一),全程直播(小白级别) 119609
Elasticsearch教程(五) elasticsearch Mapping的创建 98909

骚码加入我们 / 千人QQ群:259217951

入群需要5元为的是没有垃圾广告,如果没有QQ钱包,可以加群主拉进。

二维码生成 来自 >> 二维码生成器

支付扫码

所有赞助/开支都讲公开明细,用于网站维护:赞助名单查看

查看我的收藏

正在加载... ...