package com.walker.support.es.dao;
|
|
import com.walker.support.es.so.BaseSearchObject;
|
import org.elasticsearch.index.query.QueryBuilder;
|
import org.elasticsearch.search.aggregations.AggregationBuilder;
|
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* 索引访问对象
|
*
|
* @author 李志慧
|
* @date 2017年3月22日
|
*/
|
public interface SearchDao {
|
/**
|
* 插入索引记录
|
*
|
* @param so 索引对象
|
* @param <SO> BaseSearchObject 子类型
|
*/
|
<SO extends BaseSearchObject> void insert(SO so);
|
|
/**
|
* 插入一组索引记录
|
*
|
* @param soList 索引对象列表
|
* @param <SO> BaseSearchObject 子类型
|
*/
|
<SO extends BaseSearchObject> void insert(List<SO> soList);
|
|
/**
|
* 更新索引记录
|
*
|
* @param so 索引对象
|
* @param <SO> BaseSearchObject 子类型
|
*/
|
<SO extends BaseSearchObject> void update(SO so);
|
|
/**
|
* 更新一组索引记录
|
*
|
* @param soList 索引对象列表
|
* @param <SO> BaseSearchObject 子类型
|
*/
|
<SO extends BaseSearchObject> void update(List<SO> soList);
|
|
/**
|
* 删除索引记录
|
*
|
* @param so 索引对象
|
* @param <SO> BaseSearchObject 子类型
|
*/
|
<SO extends BaseSearchObject> void delete(SO so);
|
|
/**
|
* 删除一组索引记录
|
*
|
* @param soList 索引对象列表
|
* @param <SO> BaseSearchObject 子类型
|
*/
|
<SO extends BaseSearchObject> void delete(List<SO> soList);
|
|
/**
|
* 删除全部clazz指定的全部类型
|
*
|
* @param clazz 指定的类型
|
* @param <T> BaseSearchObject 子类型
|
*/
|
<T extends BaseSearchObject> void deleteAll(Class<T> clazz);
|
|
/**
|
* 获取单个索引数据
|
*
|
* @param clazz 索引对象类型
|
* @param id 唯一编号
|
* @param <T> BaseSearchObject 子类型
|
* @return id对应的索引数据
|
*/
|
<T extends BaseSearchObject> T get(Class<T> clazz, String id);
|
|
/**
|
* 获取 clazz 类型对应的全部索引，处于性能考虑最多返回前10000条
|
*
|
* @param clazz 索引对象类型
|
* @param <T> BaseSearchObject 子类型
|
* @return 搜索到的索引列表
|
*/
|
@Deprecated
|
<T extends BaseSearchObject> List<T> select(Class<T> clazz);
|
|
// /**
|
// * 分页获取 clazz 类型对应的索引
|
// *
|
// * @param splitPageInfo 分页对象
|
// * @param clazz 索引对象类型
|
// * @param <T> BaseSearchObject 子类型
|
// * @return 搜索到的索引列表
|
// */
|
// @Deprecated
|
// <T extends BaseSearchObject> List<T> select(SplitPageInfo splitPageInfo, Class<T> clazz);
|
|
/**
|
* 根据条件及参数查询索引
|
*
|
* @param <T> BaseSearchObject 子类型
|
* @param queryBuilder 查询json，参数占位符使用?aa/?bb/?xxx...
|
* @param searchParameter 查询配置，高亮、返回字段设置等
|
* @param clazz 索引对象类型
|
* @return 搜索到的索引列表
|
*/
|
<T extends BaseSearchObject> List<T> select(QueryBuilder queryBuilder, SearchParameter searchParameter, Class<T> clazz);
|
|
// /**
|
// * 根据条件及参数分页查询查询索引
|
// *
|
// * @param <T> BaseSearchObject 子类型
|
// * @param queryBuilder 查询
|
// * @param searchParameter 查询配置，高亮、返回字段设置等
|
// * @param splitPageInfo 分页对象
|
// * @param clazz 索引对象类型
|
// * @return 搜索到的索引列表
|
// */
|
// <T extends BaseSearchObject> List<T> select(QueryBuilder queryBuilder, SearchParameter searchParameter, SplitPageInfo splitPageInfo, Class<T> clazz);
|
|
/**
|
* 删除索引
|
*
|
* @param clazz 索引对象类型
|
* @param <T> BaseSearchObject 子类型
|
* @return 是否成功
|
*/
|
<T extends BaseSearchObject> boolean deleteIndex(Class<T> clazz);
|
|
/**
|
* 创建索引
|
*
|
* @param clazz 索引对象类型
|
* @param <T> BaseSearchObject 子类型
|
* @return 是否成功
|
*/
|
<T extends BaseSearchObject> boolean createIndex(Class<T> clazz);
|
|
/**
|
* 创建索引结构
|
*
|
* @param clazz 索引对象类型
|
* @param <T> BaseSearchObject 子类型
|
* @return 是否成功
|
*/
|
<T extends BaseSearchObject> boolean putMapping(Class<T> clazz);
|
|
/**
|
* 立即实现内存->文件系统缓存
|
*
|
* @param clazz 索引对象类型
|
* @param <T> BaseSearchObject 子类型
|
*/
|
<T extends BaseSearchObject> void refresh(Class<T> clazz);
|
|
/**
|
* 统计查询
|
* @param abstractRangeBuilder 聚合条件
|
* @param queryBuilder 查询条件
|
* @param clazz 索引对象类型
|
* @param <T>BaseSearchObject 子类型
|
* @return 统计查询结果
|
*/
|
<T extends BaseSearchObject> Map aggs(AggregationBuilder abstractRangeBuilder, QueryBuilder queryBuilder, Class<T> clazz);
|
}
|
