SpringBoot之@elasticsearch完成CURD

Author: YuKongEr

README.md

@@ -19,6 +19,10 @@
 [【SpringBoot2.0系列09】SpringBoot之rabbitmq使用](https://www.jianshu.com/p/0d400d30936b)
 
 [【SpringBoot2.0系列10】SpringBoot之@Scheduled任务调度](https://www.jianshu.com/p/94cc87cf8f18)
+
+[【SpringBoot2.0系列11】SpringBoot之@Elasticsearch完成CURD](https://www.jianshu.com/p/3ec38433d9ad)
+
+
 [简书地址](https://www.jianshu.com/nb/26935871)
 
 [腾讯云+社区地址](https://cloud.tencent.com/developer/column/4803)

chapter10/src/main/java/com/yukong/chapter10/entity/Good.java

@@ -0,0 +1,33 @@
+package com.yukong.chapter10.entity;
+
+import lombok.*;
+import lombok.experimental.Accessors;
+import org.springframework.data.annotation.Id;
+import org.springframework.data.elasticsearch.annotations.Document;
+
+/**
+ * @author: yukong
+ * @date: 2018/9/4 14:48
+ * @description:
+ */
+@Data
+@ToString
+@Accessors(chain = true)
+@EqualsAndHashCode
+@Document(indexName = "goods", type = "computer")
+public class Good {
+
+ /**
+ * 主键,注意这个搜索是id类型是string，与我们常用的不同
+ * Id注解加上后，在Elasticsearch里相应于该列就是主键了，在查询时就可以直接用主键查询
+ */
+ @Id
+ private String id;
+
+ private String name;
+
+ private String desc;
+
+ private Integer number;
+
+}

chapter10/src/main/java/com/yukong/chapter10/repository/GoodRepository.java

@@ -0,0 +1,23 @@
+package com.yukong.chapter10.repository;
+
+import com.yukong.chapter10.entity.Good;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+/**
+ * @author: yukong
+ * @date: 2018/9/4 14:53
+ * @description:
+ */
+public interface GoodRepository extends ElasticsearchRepository<Good, String> {
+
+ /**
+ * 根据商品名称查询 分页
+ * @param name
+ * @param pageable
+ * @return
+ */
+ Page<Good> findByName(String name, Pageable pageable);
+
+}

chapter10/src/test/java/com/yukong/chapter10/repository/GoodRepositoryTest.java

@@ -0,0 +1,77 @@
+package com.yukong.chapter10.repository;
+
+import com.yukong.chapter10.Chapter10ApplicationTests;
+import com.yukong.chapter10.entity.Good;
+import org.junit.Assert;
+import org.junit.FixMethodOrder;
+import org.junit.Test;
+import org.junit.runners.MethodSorters;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.PageRequest;
+import org.springframework.data.domain.Pageable;
+import org.springframework.stereotype.Component;
+
+
+import static org.junit.Assert.*;
+
+
+
+/**
+ * @author: yukong
+ * @date: 2018/9/4 14:56
+ * @description:
+ */
+@Component
+@FixMethodOrder(MethodSorters.NAME_ASCENDING)
+public class GoodRepositoryTest extends Chapter10ApplicationTests {
+
+ @Autowired
+ private GoodRepository goodRepository;
+
+ @Test
+ public void save(){
+ Good good = new Good();
+ good.setId("100")
+ .setName("联想e541")
+ .setDesc("联想e系列")
+ .setNumber(10);
+ Good result = goodRepository.save(good);
+ Assert.assertNotNull(result);
+ }
+
+ @Test
+ public void select(){
+ // 需要注意find方法返回的死Optional对象 需要调用get方法返回具体的实体类对象
+ Good result = goodRepository.findById("100").get();
+ Assert.assertNotNull(result);
+
+ }
+
+ @Test
+ public void update(){
+ Good result = goodRepository.findById("100").get();
+ result.setNumber(300);
+ // 更新也是调用save方法
+ Good good = goodRepository.save(result);
+ Assert.assertNotNull(good);
+
+ }
+
+
+
+ @Test
+ public void delete(){
+ goodRepository.deleteById("100");
+ }
+
+ @Test
+ public void findByName() {
+ String name = "macbook";
+ Pageable pageable = new PageRequest(1,1);
+ Page<Good> goods = goodRepository.findByName(name, pageable);
+ System.out.println(goods.getContent());
+ Assert.assertEquals(1, goods.getSize());
+
+ }
+}