JarCastingelasticsearch-helper ES助手(https://github.com/snowThinker/elasticsearch-helper)
主要功能
- ElasticsearchTemplate深度分页支持：重写ElasticsearchTemplate支持 search after 深度分页
- 自动创建分区及自动分区指向：可按月分区索引，每月创建索引，自动别名指向功能
- Elasticsearch 读写分离：读写分离, 读操作所有索引分区，写只操作当月索引
如何使用
1、添加pom依赖
<dependency>
<groupId>io.github.snowthinker</groupId>
<artifactId>elasticsearch-helper</artifactId>
<version>0.0.2-RELEASE</version>
</dependency>
2、初始化CustomElasticsearchTemplate
@Bean
public CustomElasticsearchTemplate customElasticsearchTemplate(Client client) {
return new CustomElasticsearchTemplate(client, new CustomDefaultResultMapper());
}
3、JavaBean编写
@Data
public class Item implements Serializable {
@Id
private String id;
@Field
private String name;
@Field
private String sku;
}
4、深度分页
int pageSize = 10;
// 深度分页
Object[] searchAfters = new Object[]{"Iphone", "_id"};
// 排序必需和深度分页顺序相一致
SortBuilder[] orders = new SortBuilder[2];
orders[0] = SortBuilders.fieldSort("name.keyword").order(SortOrder.DESC);
orders[1] = SortBuilders.fieldSort("id.keyword").order(SortOrder.DESC);
// 条件查询
QueryBuilder queryBuilder = QueryBuilders.termQuery("name", "Iphone");
SearchQuery searchQuery = new NativeSearchQueryBuilder()
.withIndices("item")
.withQuery(queryBuilder)
.build();
Page<Item> pageResult = customElasticsearchTemplate.searchAfter(searchQuery, Arrays.asList(orders), searchAfters, pageSize, Item.class);
List<Item> dataList = pageResult.get().collect(Collectors.toList());
log.info("Total Record: {}, page list: {}", pageResult.getTotalElements(), dataList);
5、打印DSL日志
<logger name="org.springframework.data.elasticsearch.core.QUERY" level="DEBUG"/>