Springdataelasticsearch怎么用

這篇文章主要介紹Springdataelasticsearch怎么用，文中介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們一定要看完！

一、準備

1.添加依賴

<dependency>      <groupId>org.springframework.boot</groupId>      <artifactId>spring-boot-starter-data-elasticsearch</artifactId>    </dependency>

2.application.yml

spring: application:  name: search-service data:  elasticsearch:   cluster-name: elasticsearch   cluster-nodes: 192.168.25.129:9300

3.實體類

@Data@Document(indexName = "goods", type = "_doc", shards = 1, replicas = 0)public class Goods {  @Idprivate Long id;  @Field(type = FieldType.text, analyzer = "ik_max_word")  private String all;  @Field(type = FieldType.keyword, index = false)  private String subTitle;private Long brandId;private Long cid1;private Long cid2;private Long cid3;private Date createTime;private List<Long> price;  @Field(type = FieldType.keyword, index = false)  private String skus;private Map<String, Object> specs;}

@Document 作用在類，標記實體類為文檔對象，一般有兩個屬性

indexName：對應索引庫名稱  type：對應在索引庫中的類型  shards：分片數量，默認5  replicas：副本數量，默認1  @Id 作用在成員變量，標記一個字段作為id主鍵  @Field 作用在成員變量，標記為文檔的字段，并指定字段映射屬性：  type：字段類型，取值是枚舉：FieldType  index：是否索引，布爾類型，默認是true  store：是否存儲，布爾類型，默認是false  analyzer：分詞器名稱

二.、索引操作

首先注入ElasticsearchTemplate

@Resourceprivate ElasticsearchTemplate elasticsearchTemplate;

● 創建索引

elasticsearchTemplate.createIndex(Goods.class);

● 配置映射

elasticsearchTemplate.putMapping(Goods.class);

● 刪除索引

//根據類elasticsearchTemplate.deleteIndex(Goods.class);//根據索引名elasticsearchTemplate.deleteIndex("goods");

三、文檔操作

1.定義接口。也是SpringData風格

public interface ItemRepository extends ElasticsearchRepository<Item,Long> {}

2.注入

@Autowiredprivate ItemRepository itemRepository;

● 新增文檔

Item item = new Item(1L, "小米手機7", " 手機",             "小米", 3499.00, "http://image.leyou.com/13123.jpg");itemRepository.save(item);

● 批量新增

List<Item> list = new ArrayList<>();  list.add(new Item(2L, "堅果手機R1", " 手機", "錘子", 3699.00, "http://image.leyou.com/123.jpg"));  list.add(new Item(3L, "華為META10", " 手機", "華為", 4499.00, "http://image.leyou.com/3.jpg"));  // 接收對象集合，實現批量新增  itemRepository.saveAll(list);

四、 基本搜索

● 基本查詢。

例：

// 查詢全部，并安裝價格降序排序  Iterable<Item> items = this.itemRepository.findAll(Sort.by(Sort.Direction.DESC, "price"));  items.forEach(item-> System.out.println(item));

● 自定義查詢

And      findByNameAndPrice      {"bool" : {"must" : [ {"field" : {"name" : "?"}}, {"field" : {"price" : "?"}} ]}}              Or      findByNameOrPrice      {"bool" : {"should" : [ {"field" : {"name" : "?"}}, {"field" : {"price" : "?"}} ]}}              Is      findByName      {"bool" : {"must" : {"field" : {"name" : "?"}}}}              Not      findByNameNot      {"bool" : {"must_not" : {"field" : {"name" : "?"}}}}              Between      findByPriceBetween      {"bool" : {"must" : {"range" : {"price" : {"from" : ?,"to" : ?,"include_lower" : true,"include_upper" : true}}}}}              LessThanEqual      findByPriceLessThan      {"bool" : {"must" : {"range" : {"price" : {"from" : null,"to" : ?,"include_lower" : true,"include_upper" : true}}}}}              GreaterThanEqual      findByPriceGreaterThan      {"bool" : {"must" : {"range" : {"price" : {"from" : ?,"to" : null,"include_lower" : true,"include_upper" : true}}}}}              Before      findByPriceBefore      {"bool" : {"must" : {"range" : {"price" : {"from" : null,"to" : ?,"include_lower" : true,"include_upper" : true}}}}}              After      findByPriceAfter      {"bool" : {"must" : {"range" : {"price" : {"from" : ?,"to" : null,"include_lower" : true,"include_upper" : true}}}}}              Like      findByNameLike      {"bool" : {"must" : {"field" : {"name" : {"query" : "?*","analyze_wildcard" : true}}}}}              StartingWith      findByNameStartingWith      {"bool" : {"must" : {"field" : {"name" : {"query" : "?*","analyze_wildcard" : true}}}}}              EndingWith      findByNameEndingWith      {"bool" : {"must" : {"field" : {"name" : {"query" : "*?","analyze_wildcard" : true}}}}}              Contains/Containing      findByNameContaining      {"bool" : {"must" : {"field" : {"name" : {"query" : "**?**","analyze_wildcard" : true}}}}}              In      findByNameIn(Collection<String>names)      {"bool" : {"must" : {"bool" : {"should" : [ {"field" : {"name" : "?"}}, {"field" : {"name" : "?"}} ]}}}}              NotIn      findByNameNotIn(Collection<String>names)      {"bool" : {"must_not" : {"bool" : {"should" : {"field" : {"name" : "?"}}}}}}              Near      findByStoreNear      Not Supported Yet !              True      findByAvailableTrue      {"bool" : {"must" : {"field" : {"available" : true}}}}              False      findByAvailableFalse      {"bool" : {"must" : {"field" : {"available" : false}}}}              OrderBy      findByAvailableTrueOrderByNameDesc      {"sort" : [{ "name" : {"order" : "desc"} }],"bool" : {"must" : {"field" : {"available" : true}}}}

例：

public interface ItemRepository extends ElasticsearchRepository<Item,Long> {  /**   * 根據價格區間查詢   * @param price1   * @param price2   * @return   */  List<Item> findByPriceBetween(double price1, double price2);}

五、高級查詢

● 詞條查詢

MatchQueryBuilder queryBuilder = QueryBuilders.matchQuery("all", "小米");    // 執行查詢    Iterable<Goods> goods = this.goodsRepository.search(queryBuilder);

● 自定義查詢

// 構建查詢條件    NativeSearchQueryBuilder queryBuilder = new NativeSearchQueryBuilder();    // 添加基本的分詞查詢    queryBuilder.withQuery(QueryBuilders.matchQuery("all", "小米"));    // 執行搜索，獲取結果    Page<Goods> goods = this.goodsRepository.search(queryBuilder.build());    // 打印總條數    System.out.println(goods.getTotalElements());    // 打印總頁數    System.out.println(goods.getTotalPages());

● 分頁查詢

// 構建查詢條件    NativeSearchQueryBuilder queryBuilder = new NativeSearchQueryBuilder();    // 添加基本的分詞查詢    queryBuilder.withQuery(QueryBuilders.termQuery("all", "手機"));    // 初始化分頁參數    int page = 0;    int size = 3;    // 設置分頁參數    queryBuilder.withPageable(PageRequest.of(page, size));    // 執行搜索，獲取結果    Page<Goods> goods = this.goodsRepository.search(queryBuilder.build());    // 打印總條數    System.out.println(goods.getTotalElements());    // 打印總頁數    System.out.println(goods.getTotalPages());    // 每頁大小    System.out.println(goods.getSize());    // 當前頁    System.out.println(goods.getNumber());

● 排序

// 構建查詢條件    NativeSearchQueryBuilder queryBuilder = new NativeSearchQueryBuilder();    // 添加基本的分詞查詢    queryBuilder.withQuery(QueryBuilders.termQuery("all", "手機"));    // 排序    queryBuilder.withSort(SortBuilders.fieldSort("price").order(SortOrder.DESC));    // 執行搜索，獲取結果    Page<Goods> goods = this.goodsRepository.search(queryBuilder.build());    // 打印總條數    System.out.println(goods.getTotalElements());

● 聚合為桶

NativeSearchQueryBuilder queryBuilder = new NativeSearchQueryBuilder();    // 不查詢任何結果    queryBuilder.withSourceFilter(new FetchSourceFilter(new String[]{""}, null));    // 1、添加一個新的聚合，聚合類型為terms，聚合名稱為brands，聚合字段為brand    queryBuilder.addAggregation(AggregationBuilders.terms("brands").field("brandId"));    // 2、查詢,需要把結果強轉為AggregatedPage類型    AggregatedPage<Goods> aggPage = (AggregatedPage<Goods>) this.goodsRepository.search(queryBuilder.build());    // 3、解析    // 3.1、從結果中取出名為brands的那個聚合，    // 因為是利用String類型字段來進行的term聚合，所以結果要強轉為StringTerm類型    LongTerms agg = (LongTerms) aggPage.getAggregation("brands");    // 3.2、獲取桶    List<LongTerms.Bucket> buckets = agg.getBuckets();    // 3.3、遍歷    for (LongTerms.Bucket bucket : buckets) {      // 3.4、獲取桶中的key，即品牌名稱      System.out.println(bucket.getKeyAsString());      // 3.5、獲取桶中的文檔數量      System.out.println(bucket.getDocCount());    }

● 嵌套聚合，求平均值

NativeSearchQueryBuilder queryBuilder = new NativeSearchQueryBuilder();    // 不查詢任何結果    queryBuilder.withSourceFilter(new FetchSourceFilter(new String[]{""}, null));    // 1、添加一個新的聚合，聚合類型為terms，聚合名稱為brands，聚合字段為brand    queryBuilder.addAggregation(AggregationBuilders.terms("brands").field("brandId")            .subAggregation(AggregationBuilders.avg("priceAvg").field("price"))); // 在品牌聚合桶內進行嵌套聚合，求平均值    // 2、查詢,需要把結果強轉為AggregatedPage類型    AggregatedPage<Goods> aggPage = (AggregatedPage<Goods>) this.goodsRepository.search(queryBuilder.build());    // 3、解析    // 3.1、從結果中取出名為brands的那個聚合，    // 因為是利用String類型字段來進行的term聚合，所以結果要強轉為StringTerm類型    LongTerms agg = (LongTerms) aggPage.getAggregation("brands");    // 3.2、獲取桶    List<LongTerms.Bucket> buckets = agg.getBuckets();    // 3.3、遍歷    for (LongTerms.Bucket bucket : buckets) {      // 3.4、獲取桶中的key，即品牌名稱 3.5、獲取桶中的文檔數量      System.out.println(bucket.getKeyAsString() + "，共" + bucket.getDocCount() + "臺");      // 3.6.獲取子聚合結果：      InternalAvg avg = (InternalAvg) bucket.getAggregations().asMap().get("priceAvg");      System.out.println("平均售價：" + avg.getValue());    }

附：配置搜索結果不顯示為null字段：

spring: jackson:  default-property-inclusion: non_null # 配置json處理時忽略空值

以上是“Springdataelasticsearch怎么用”這篇文章的所有內容，感謝各位的閱讀！希望分享的內容對大家有幫助，更多相關知識，歡迎關注億速云行業資訊頻道！