Elasticsearch? 的查詢很靈活，并且有Filter，有分組功能，還有ScriptFilter等等，所以很強大。下面上代碼：

一個簡單的查詢，返回一個List<對象> .。

/**

* 根據(jù)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;

}

/**

* 根據(jù)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;

}

/**

* 根據(jù)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;

}

/**

* 根據(jù)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;

}

}

總結(jié)

以上是生活随笔為你收集整理的elasticsearch 查询数据 | 分页查询的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。