这段时间要写一个提供查询elasticsearch的接口，特在这里讲自己的一些问题情况记录一下。
首先是创建工程，spring boot+ES的这里就不过多的写了。
pom文件如下：
在application.properties中添加配置：
server.port=8083
spring.data.elasticsearch.cluster-name=这里是ES的名称
spring.data.elasticsearch.cluster-nodes=这里是ES的地址以及端口号
spring.data.elasticsearch.repositories.enabled=true
这里使用的是spring-data-elasticsearch，所以在Dao中只要继承ElasticsearchRepository就可以了。
例如：public interface Mf_cus_customerRepository extends ElasticsearchRepository<Mf_cus_customer,String> {}
这篇文章主要是记录查询的一些方法，所以只针对查询。
使用QueryBuilder来创建查询
1、单字段匹配（单条）
/**
* 单字段匹配查询
* @param searchContent
* @return
*/
public List<Mf_cus_customer> test_search(String searchContent){
QueryBuilder queryBuilder = QueryBuilders.termQuery("这里是你要查询的字段", searchContent);
SearchQuery searchQuery =new NativeSearchQueryBuilder().withQuery(queryBuilder).build();
System.out.println("查询的语句:" + searchQuery.getQuery().toString());
Page<Mf_cus_customer> searchPageResults =mfCusCustomerRepository.search(searchQuery);
return searchPageResults.getContent();
}
这里要注意的是QueryBuilders的termQuery方法以及matchQuery方法，这两个方法都可以进行单字段匹配的查询，但是这两个是有区别的。具体区别原理还没有学习，但是如果你的字段不是一个整体（类似cus_name）这样的就需要使用matchQuery或者是termQuery的第一个参数也就是你的字段后面加上.keyword。也就是说如果字段是一个整体那么这两个方法是一样的效果，例如：
matchQuery("name","张三")等价于termQuery("name","张三")。如果字段不是一个整体，那么这两个的效果如下：
matchQuery("cus_name","张三")等价于termQuery("cus_name.keyword","张三")。
2、单字段匹配（多条）
/**
* 一次匹配多个值
* @param searchContent
* @return
*/
public List<Mf_cus_customer> test_searchs(String searchContent){
List searchContents = Arrays.asList(searchContent.split(","));
QueryBuilder queryBuilder = QueryBuilders.termsQuery("cus_no.keyword", searchContents);//cus_no字段查询
SearchQuery searchQuery =new NativeSearchQueryBuilder().withQuery(queryBuilder).build();
System.out.println("查询的语句:" + searchQuery.getQuery().toString());
Page<Mf_cus_customer> searchPageResults =mfCusCustomerRepository.search(searchQuery);
return searchPageResults.getContent();
}
匹配多条使用的是termsQuery方法，问题同上。
3、分页
分页的话这里是用的是简单的方法，后期学到其他分页还会继续分享。
这里的分页使用的是Pageable，例如：
Pageable pageable =new PageRequest(pageNumber, pageSize);
然后在new NativeSearchQueryBuilder()后添加withPageable(pageable )即可。
/**
* 有分页的按照userID查询
* @param pageNumber
* @param pageSize
* @param searchContent
* @return
*/
public List<Mf_cus_customer> _searchByUserid(Integer pageNumber, Integer pageSize,String searchContent){
Pageable pageable =new PageRequest(pageNumber, pageSize);
QueryStringQueryBuilder builder =new QueryStringQueryBuilder(searchContent);
SearchQuery searchQuery =new NativeSearchQueryBuilder().withPageable(pageable).withQuery(builder).build();
System.out.println("查询的语句:" + searchQuery.getQuery().toString());
Page<Mf_cus_customer> searchPageResults =mfCusCustomerRepository.search(searchQuery);
return searchPageResults.getContent();
}
4、范围查询
使用QueryBuilders的rangeQuery方法，来进行范围查询，其中
大于：QueryBuilder qb1 = QueryBuilders.rangeQuery("字段").gt(值);
大于等于：QueryBuilder qb1 = QueryBuilders.rangeQuery("字段").gte(值);
小于：QueryBuilder qb1 = QueryBuilders.rangeQuery("字段").lt(值);
小于等于：QueryBuilder qb1 = QueryBuilders.rangeQuery("字段").lte(值);
5、多条件查询
使用QueryBuilders的boolQuery方法可以进行多条件查询，即sql语句中的and和or查询
这里and是must()，or是should()；
例如：
QueryBuilder qb1 = QueryBuilders.termsQuery("字段", 值);
QueryBuilder qb2 = QueryBuilders.rangeQuery("字段").gt(值);
QueryBuilder qb3 = QueryBuilders.boolQuery().must(qb1).must(qb2);//and链接两个查询条件，or的话使用should()。
这些是简单查询的部分功能，在项目中用到了，后续如果有其他的使用会继续记录。
网友评论