SpringBoot整合Spring Data Elasticsearch的過程詳解
更新時間：2019年09月20日 09:06:02 作者：steakliu
這篇文章主要介紹了SpringBoot整合Spring Data Elasticsearch的過程詳解,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
Spring Data Elasticsearch提供了ElasticsearchTemplate工具類，實現(xiàn)了POJO與elasticsearch文檔之間的映射
elasticsearch本質也是存儲數(shù)據(jù)，它不支持事物，但是它的速度遠比數(shù)據(jù)庫快得多，
可以這樣來對比elasticsearch和數(shù)據(jù)庫
- 索引（indices）--------數(shù)據(jù)庫（databases)
- 類型（type)------------數(shù)據(jù)表（table)
- 文檔（Document）---------------- 行(row)
- 字段（Field）-------------------列(Columns )
整合：
1，在SprinBoot工程中引入jar包
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>
2，配置文件
spring.data.elasticsearch.cluster-name=elasticsearch //名字必須和elasticsearch.yml里面的cluster.name相同 spring.data.elasticsearch.cluster-nodes=127.0.0.1:9300 spring.data.elasticsearch.repositories.enabled=true
3，創(chuàng)建實體，并對類和屬性進行標注
@Document(indexName = "item",type = "docs", shards = 1, replicas = 0)//標記為文檔類型，ndexName：對應索引庫名稱type：對應在索引庫中的類型，shards：分片數(shù)量，默認5，replicas：副本數(shù)量，默認1
public class Item {
@Id //主鍵
private Long id;
@Field(type = FieldType.Text, analyzer = "ik_max_word") //標記為成員變量 FieldType，可以是text、long、short、date、integer等 text：存儲數(shù)據(jù)時候，會自動分詞，并生成索引 keyword：存儲數(shù)據(jù)時候，不會分詞建立索引 analyzer:分詞器名稱
private String title; //標題
@Field(type = FieldType.Keyword)
private String category;// 分類
@Field(type = FieldType.Keyword)
private String brand; // 品牌
@Field(type = FieldType.Double)
private Double price; // 價格
@Field(index = false, type = FieldType.Keyword)//index:是否索引
private String images; // 圖片地址
4.引入模板ElasticsearchTemplate
@Autowired private ElasticsearchTemplate elasticsearchTemplate;
5.創(chuàng)建一個索引
//添加索引
@Test
public void addIndex() {
elasticsearchTemplate.createIndex(Item.class);
}
6.刪除索引
//刪除索引
@Test
public void delete(){
elasticsearchTemplate.deleteIndex("item");
}
7.新增對象
繼承Repository提供的一些子接口，就能具備各種基本的CRUD功能，這里繼承ElasticsearchCrudRepository
首先定義一個對象的接口
public interface ItemRepository extends ElasticsearchCrudRepository<Item,Long> {
}
然后注入ItemRepository
@Autowired private ItemRepository itemRepository;
新增對象
//新增一個對象
@Test
public void insert(){
Item item = new Item(2L,"堅果R1","手機","錘子",2500.00,"http://image.baidu.com/13123.jpg");
//Order order = new Order(20180020,"菜單");
itemRepository.save(item);
}
批量新增
//批量新增
@Test
public void insertList(){
List<Item> list = new LinkedList<>();
list.add(new Item(9L,"華為p20","手機","華為",3500.00,"http://image.baidu.com/13123.jpg"));
list.add(new Item(10L,"華為p30","手機","華為",5450.00,"http://image.baidu.com/13123.jpg"));
list.add(new Item(11L,"華為p30 pro","手機","華為",6980.00,"http://image.baidu.com/13123.jpg"));
itemRepository.saveAll(list);
}
8.查詢
//根據(jù)字段查詢所有
@Test
public void queryAll(){
//升序,相應降序為dscending
Iterable<Item> items = this.itemRepository.findAll(Sort.by("price").ascending());
for (Item item : items){
System.out.println(item);
}
}
9.自定義查詢方法
Spring Data 的另一個強大功能，是根據(jù)方法名稱自動實現(xiàn)功能，你的方法名叫做：findByTitle，那么它就知道你是根據(jù)title查詢，然后自動幫你完成，無需寫實現(xiàn)類。當然，方法名稱要符合一定的約定：
上圖是截取csdn上博主我要取一個響亮的昵稱的圖
根據(jù)手機名查找手機
//自定義方法,根據(jù)Title查詢
@Test
public void findByTitle(){
Item item = this.itemRepository.findByTitle("堅果pro");
System.out.println(item);
}
區(qū)間查詢
//根據(jù)區(qū)間查詢
@Test
public void queryByPriceBetween(){
List<Item> list = this.itemRepository.findByPriceBetween(2000.00, 3500.00);
for (Item item : list) {
System.out.println("item = " + item);
}
}
模糊查詢
//模糊查詢
@Test
public void queryLikeTitle(){
List<Item> list = this.itemRepository.findByTitleLike("R2");
for (Item item : list){
System.out.println(item);
}
}
使用自定義方法需要在接口里面申明方法
public interface ItemRepository extends ElasticsearchCrudRepository<Item,Long> {
Item findByTitle(String title);
List<Item> findByPriceBetween(double price1, double price2);
List<Item> findByTitleLike(String title);
}
10.自定義查詢
//自定義查詢,查詢數(shù)目等
@Test
public void matchQuery(){
// 構建查詢條件
NativeSearchQueryBuilder queryBuilder = new NativeSearchQueryBuilder();
// 添加基本分詞查詢
queryBuilder.withQuery(QueryBuilders.matchQuery("title","堅果"));
//獲取結果
Page<Item> items = (Page<Item>) this.itemRepository.findAll();
//條數(shù)
long total = items.getTotalElements();
System.out.println("total = "+total);
for (Item item : items){
System.out.println(item);
}
}關鍵的是NativeSearchQueryBuilder這個類
分頁查詢
//分頁查詢
@Test
public void queryByPage(){
NativeSearchQueryBuilder nativeSearchQueryBuilder = new NativeSearchQueryBuilder();
nativeSearchQueryBuilder.withQuery(QueryBuilders.termQuery("category","手機"));
int page = 0;
int size = 2;
nativeSearchQueryBuilder.withPageable(PageRequest.of(page,size));
Page<Item> items = (Page<Item>) this.itemRepository.findAll();
long total = items.getTotalElements();
int totalPage = items.getTotalPages();
int nowPage = items.getNumber();
int pageSize = items.getSize();
System.out.println("總條數(shù) = "+total);
System.out.println("總頁數(shù) = "+totalPage);
System.out.println("當前頁 = "+nowPage);
System.out.println("每頁大小 = "+pageSize);
for (Item item : items){
System.out.println(item);
}
}
還有很多，就不意義列舉
在elasticsearch-head上查看數(shù)據(jù)
關于安裝elasticsearch-head，參考地址
Spring Data Elasticsearch文檔：https://docs.spring.io/spring-data/elasticsearch/docs/3.1.10.RELEASE/reference/html/
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。
您可能感興趣的文章:
相關文章
這篇文章主要介紹了抽象類使用Jackson序列化問題，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2023-01-01
這篇文章主要介紹了使用AOP的@Around后無返回值的解決，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2021-02-02
這篇文章主要介紹了Java中的static關鍵字深入理解，文字和代碼列舉了實際例子，有感興趣的同學可以研究下2021-03-03
這篇文章主要介紹了Java數(shù)據(jù)結構與算法入門實例詳解,本文給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2021-03-03
深入dom4j使用selectSingleNode方法報錯分析
本篇文章是對dom4j使用selectSingleNode方法報錯進行了詳細的分析介紹，需要的朋友參考下2013-05-05
Spring Boot集成Druid數(shù)據(jù)庫連接池
這篇文章主要介紹了Spring Boot集成Druid數(shù)據(jù)庫連接池,小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2017-04-04
MyBatis是一種持久化框架,可以與許多不同類型的關系型數(shù)據(jù)庫連接,下面這篇文章主要給大家介紹了關于MyBatis查詢數(shù)據(jù)庫語句的相關資料,文中通過實例代碼介紹的非常詳細,需要的朋友可以參考下2023-06-06
這篇文章主要介紹了JavaEE簡介，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2017-07-07
使用Java將字節(jié)數(shù)組轉成16進制形式的代碼實現(xiàn)
在很多場景下,需要進行分析字節(jié)數(shù)據(jù),但是我們存起來的字節(jié)數(shù)據(jù)一般都是二進制的,這時候就需要我們將其轉成16進制的方式方便分析,本文主要介紹如何使用Java將字節(jié)數(shù)組格式化成16進制的格式并輸出,需要的朋友可以參考下2024-05-05
這篇文章主要介紹了DataOutputStream亂碼問題的解決方案，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-09-09