**/
@Repository
public interface DogRepository extends ElasticsearchRepository
}
然后是service和 impl，
新建DogService.java ：
import com.example.elastucsearchdemo.pojo.Dog;
import java.util.List;
public interface DogService {
boolean deleteDog(String id) ;
Dog saveDog(Dog dog) ;
Boolean saveDogAll(List dogsList) ;
List findAllDog() ;
Dog findoneDog(String id) ;
}
新建DogServiceImpl.impl：
import com.example.elastucsearchdemo.pojo.Dog;
import com.example.elastucsearchdemo.repository.DogRepository;
import com.example.elastucsearchdemo.service.DogService;
import org.elasticsearch.index.query.QueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.List;
import java.util.Optional;
@Service
public class DogServiceImpl implements DogService {
@Autowired
private DogRepository repository;
public boolean deleteDog(String id) {
try {
repository.deleteById(id);
} catch (Exception ex) {
ex.printStackTrace();
return false;
}
return true;
}
public Dog saveDog(Dog dog) {
try {
Dog save = repository.save(dog);
System.out.println(“结果：”+save.toString());
return save;
} catch (Exception ex) {
ex.printStackTrace();
return null;
}
}
public Boolean saveDogAll(List dogsList) {
try {
repository.saveAll(dogsList);
} catch (Exception ex) {
ex.printStackTrace();
return false;
}
return true;
}
public List findAllDog() {
List list = new ArrayList<>();
try {
Iterable aIterable = repository.findAll();
for (Dog Dog : aIterable) {
list.add(Dog);
}
} catch (Exception ex) {
ex.printStackTrace();
return null;
}
return list;
}
public Dog findoneDog(String id) {
Optional resu = repository.findById(id);
return repository.findById(id).get();
}
}
接着我们来写个简单的接口验证一下这些常规crud.
新建DogController.java：
import com.example.elastucsearchdemo.pojo.Dog;
import com.example.elastucsearchdemo.repository.DogRepository;
import com.example.elastucsearchdemo.service.DogService;
import org.elasticsearch.index.query.QueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.ArrayList;
import java.util.List;
import java.util.Random;
@RestController
public class DogController {
@Autowired
DogService dogService;
public static String getNonceStr(int length) {
//生成随机字符串
String str = “zxcvbnmlkjhgfdsaqwertyuiopQWERTYUIOPASDFGHJKLZXCVBNM1234567890”;
Random random = new Random();
StringBuffer randomStr = new StringBuffer();
// 设置生成字符串的长度，用于循环
for (int i = 0; i < length; ++i) {
//从62个的数字或字母中选择
int number = random.nextInt(62);
//将产生的数字通过length次承载到sb中
randomStr.append(str.charAt(number));
}
//将承载的字符转换成字符串
return randomStr.toString();
}
}
单条数据插入：@PostMapping(“addDogTest”)
public void addTest() {
//插入一只小狗
Dog dog = new Dog();
dog.setId(“100111”);
dog.setName(“TestDog”);
dog.setAge(3);
dog.setColor(“black”);
dogService.saveDog(dog);
}
调用该接口，可以看到数据成插入：
批量数据插入：@PostMapping(“addListTest”)
public void addTest() {
//插入所有小狗
List dogsList = new ArrayList<>();
for (int i = 0; i < 5; i++) {
Dog dogPes = new Dog();
dogPes.setId(UUID.randomUUID().toString().replace("-", “”));
dogPes.setName(“Alaska-”+getNonceStr(4));
dogPes.setAge(new Random().nextInt(100));
dogPes.setColor(“red”);
dogsList.add(dogPes);
}
dogService.saveDogAll(dogsList);
}
调用该接口，可以看到数据成插入：
删除：我们就把这个id为62668f83be6440b493d761dfc2703683的进行删除，
@GetMapping(“deleteOne”)
public void deleteOne() {
dogService.deleteDog(“62668f83be6440b493d761dfc2703683”);
}
调用下这个接口，可以看到数据已经删掉：
查找单条数据：@GetMapping(“findTest”)
public void find() {
//根据ID 查找一只小狗
Dog oneDog = dogService.findoneDog(“91713fd657ee4a059811bfb7df7456d0”);
System.out.println(oneDog.toString());
}
调用下该接口，可以看到数据成功获取：
查找所有数据：@GetMapping(“findAll”)
public void find() {
//查找所有小狗
List allDog = dogService.findAllDog();
System.out.println(allDog.toString());
}
调用下该接口，可以看到数据成功获取：
修改 ：可以看到service里面其实没有修改方法，如果用过JPA的小伙伴应该不能理解，因为这里的修改其实可以通过插入（保存）实现，也就是根据id去修改。
可以看到我们最早插入的数据，id为 100111：
我们把里面的age，和name 都修改下，通过插入去修改：
@PostMapping(“updateDogTest”)
public void updateDogTest() {
//插入一只小狗
Dog dog = new Dog();
dog.setId(“100111”);
dog.setName(“update”);
dog.setAge(2);
dog.setColor(“black”);
dogService.saveDog(dog);
}
调用下该接口，可以看到数据修改成功：
接下来是着重讲下查询，
精确查询：查找 name（字符串）作为字段，值为Alaska-km6u 的数据。
@Autowired
DogRepository repository; //为了方便讲解，就直接先这样使用
@GetMapping(“queryTest”)
public void queryTest() {
QueryBuilder qb0 = QueryBuilders.termQuery(“name”+".keyword", “Alaska-km6u”);
QueryBuilder qb = QueryBuilders.boolQuery().must(qb0);
List list=new ArrayList<>();
Iterable aIterable = repository.search(qb);
for (Dog Dog : aIterable) {
list.add(Dog);
}
System.out.println(list.toString());
}
调用下该接口：
注意，如果你是要精确查找一条数据，那么就是termQuery 。
但是如果你的数据里面不止一只小狗满足条件名字叫Alaska-km6u ，那就需要使用 termsQuery 。
范围查询：rangeQuery
假如我们要查询 age在 12-20岁之间的小狗，
那么就是：
// 闭区间
QueryBuilder qb1 = QueryBuilders.rangeQuery(“age”).from(“12”).to(“20”);
QueryBuilder qb = QueryBuilders.boolQuery().must(qb1);
List
【一线大厂Java面试题解析+后端开发学习笔记+最新架构讲解视频+实战项目源码讲义】
开源分享完整内容戳这里
list=new ArrayList<>();
Iterable aIterable = repository.search(qb);
for (Dog Dog : aIterable) {
list.add(Dog);
}
System.out.println(list.toString());
开区间：
//开区间
QueryBuilder qb1 = QueryBuilders.rangeQuery(“age”).from(“12”, false).to(“20”, false);
假如需要查询 age小于5岁的小狗，
那么就是：
//小于
QueryBuilder qb1 = QueryBuilders.rangeQuery(“age”).lt(“5”);
如果是要小于等于5：
//小于等于
QueryBuilder qb1 = QueryBuilders.rangeQuery(“age”).lte(“5”);
假如需要查询age大于10岁的小狗，
那么就是：
//大于
QueryBuilder qb1 = QueryBuilders.rangeQuery(“age”).gt(“10”);
如果是要大于等于10：
//大于
QueryBuilder qb1 = QueryBuilders.rangeQuery(“age”).gte(“10”);
范围查询暂时就介绍这些， 上面都是基于单条件进行的查询，其实多条件同时查询也是很常见。
