public interface EsQueryService
| 限定符和类型 | 方法和说明 |
|---|---|
long |
count(QueryParam queryParam)
按条件查询符合条件的数据量
|
<T> List<T> |
findByIds(String index,
Collection<String> ids,
Class<T> clazz)
通过id列表查询
|
<T> List<T> |
findByIds(String index,
Collection<String> ids,
Class<T> clazz,
List<String> fields)
通过id列表查询
|
<T> PageData<T> |
findPage(List<String> indices,
Map<String,Object> queryMap,
Class<T> clazz,
int pageNo,
int pageSize)
分页查询
|
<T> PageData<T> |
findPage(List<String> indices,
Map<String,Object> queryMap,
Class<T> clazz,
List<String> fields,
int pageNo,
int pageSize,
String sortField,
org.springframework.data.domain.Sort.Direction direction)
分页查询
|
<T> PageData<T> |
findPage(List<String> indices,
Object queryObj,
Class<T> clazz,
int pageNo,
int pageSize)
分页查询
|
<T> PageData<T> |
findPage(List<String> indices,
Object queryObj,
Class<T> clazz,
List<String> fields,
int pageNo,
int pageSize,
String sortField,
org.springframework.data.domain.Sort.Direction direction)
分页查询
|
<T> PageData<T> |
findPage(List<String> indices,
org.elasticsearch.index.query.QueryBuilder queryBuilder,
Class<T> clazz,
int pageNo,
int pageSize)
分页查询
|
<T> PageData<T> |
findPage(List<String> indices,
org.elasticsearch.index.query.QueryBuilder queryBuilder,
Class<T> clazz,
List<String> fields,
int pageNo,
int pageSize,
String sortField,
org.springframework.data.domain.Sort.Direction direction)
分页查询
|
<T> T |
get(String index,
String id,
Class<T> clazz)
查询单条记录
|
<T> T |
get(String index,
String id,
Class<T> clazz,
List<String> fields)
查询单条记录
|
<T> List<T> |
query(QueryParam queryParam,
Class<T> clazz)
按条件查询符合条件的数据，只适合查询10000条范围之内的，
注意，查询数据量有可能超过100M限制，此时在查询条件中限制返回字段是一个比较好的解决方法，
更深入的解决办法，参考：
http://note.youdao.com/noteshare?
|
<T> List<T> |
scrollSearch(QueryParam queryParam,
Class<T> clazz)
滚动查询符合条件的数据
注意，查询数据量有可能超过100M限制，
此时在查询条件中限制返回字段是一个比较好的解决方法，
另外一个方法是缩小每次滚动的量度，即设置合适的length值，否则滚动量度默认为10000数据量
更深入的解决办法，参考：
http://note.youdao.com/noteshare?
|
<T> T get(String index, String id, Class<T> clazz)
index - 索引名称id - 主键clazz - 数据实体类<T> T get(String index, String id, Class<T> clazz, List<String> fields)
index - 索引名称id - 主键clazz - 数据实体类fields - 需要返回的指定字段<T> List<T> findByIds(String index, Collection<String> ids, Class<T> clazz)
index - 索引名称ids - id列表clazz - 数据实体类<T> List<T> findByIds(String index, Collection<String> ids, Class<T> clazz, List<String> fields)
index - 索引名称ids - id列表clazz - 数据实体类fields - 需要返回的指定字段<T> PageData<T> findPage(List<String> indices, org.elasticsearch.index.query.QueryBuilder queryBuilder, Class<T> clazz, int pageNo, int pageSize)
indices - 索引名称queryBuilder - 查询条件clazz - 数据实体类pageNo - 当前页pageSize - 当前页数据条数<T> PageData<T> findPage(List<String> indices, Object queryObj, Class<T> clazz, int pageNo, int pageSize)
indices - 索引名称queryObj - 查询条件clazz - 数据实体类pageNo - 当前页pageSize - 当前页数据条数<T> PageData<T> findPage(List<String> indices, Map<String,Object> queryMap, Class<T> clazz, int pageNo, int pageSize)
indices - 索引名称queryMap - 查询条件clazz - 数据实体类pageNo - 当前页pageSize - 当前页数据条数<T> PageData<T> findPage(List<String> indices, Object queryObj, Class<T> clazz, List<String> fields, int pageNo, int pageSize, String sortField, org.springframework.data.domain.Sort.Direction direction)
indices - 索引名称queryObj - 查询条件clazz - 数据实体类fields - 需要返回的指定字段pageNo - 当前页pageSize - 当前页数据条数sortField - 排序字段direction - Direction.Desc/ASC 排序方式<T> PageData<T> findPage(List<String> indices, Map<String,Object> queryMap, Class<T> clazz, List<String> fields, int pageNo, int pageSize, String sortField, org.springframework.data.domain.Sort.Direction direction)
indices - 索引名称queryMap - 查询条件clazz - 数据实体类fields - 需要返回的指定字段pageNo - 当前页pageSize - 当前页数据条数sortField - 排序字段direction - Direction.Desc/ASC 排序方式<T> PageData<T> findPage(List<String> indices, org.elasticsearch.index.query.QueryBuilder queryBuilder, Class<T> clazz, List<String> fields, int pageNo, int pageSize, String sortField, org.springframework.data.domain.Sort.Direction direction)
indices - 索引名称queryBuilder - 查询条件clazz - 数据实体类fields - 需要返回的指定字段pageNo - 当前页pageSize - 当前页数据条数sortField - 排序字段direction - Direction.Desc/ASC 排序方式long count(QueryParam queryParam) throws IllegalQueryParamException
queryParam - 查询对象IllegalQueryParamException<T> List<T> query(QueryParam queryParam, Class<T> clazz) throws IllegalQueryParamException
T - queryParam - clazz - IllegalQueryParamException<T> List<T> scrollSearch(QueryParam queryParam, Class<T> clazz) throws IllegalQueryParamException
T - queryParam - clazz - IllegalQueryParamException