当前位置: 首页 > news >正文

029 elasticsearch文档管理(ElasticsearchRepository、ElasticsearchRestTemplate)

文章目录

    • BlogRepository.java
    • BlogRepositoryTest.java
    • BulkTest.java

文档的管理
ElasticSearchRepository接口
使用方法:
创建一个接口,继承于ElasticSearchRepository,指定使用的Entity类及对应主键数据类型
Springboot自动扫描接口并创建代理对象

  1. 新增、更新数据
    使用repository的save方法实现
  2. 删除数据
    deleteById
    deleteAll
  3. 查询数据
    可以使用repository自带的查询方法
    findById
    findAll
    可以自定义查询方法
    findBy{Title}And{content}(String title, String content);
    按照命名规则定义方法,就可以实现相应的查询

BlogRepository.java

package com.xd.cubemall.search.repository;import com.xd.cubemall.search.model.Blog;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;import java.util.List;public interface BlogRepository extends ElasticsearchRepository<Blog, Long> {List<Blog> findByTitle(String title);List<Blog> findByTitleAndContent(String title, String content);
}

BlogRepositoryTest.java

package com.xd.cubemall.sdes;import com.xd.cubemall.search.CubemallSearchApplication;
import com.xd.cubemall.search.model.Blog;
import com.xd.cubemall.search.repository.BlogRepository;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.domain.PageRequest;
import org.springframework.test.context.junit4.SpringRunner;import java.util.List;
import java.util.Optional;@RunWith(SpringRunner.class)
@SpringBootTest(classes = CubemallSearchApplication.class)
public class BlogRepositoryTest {@Autowiredprivate BlogRepository blogRepository;@Testpublic void addDocument() {Blog blog = new Blog();for (int i = 0; i < 50; i++) {blog.setId((long) (i+1));blog.setTitle("测试文档"+(i+1));blog.setContent("测试文档的内容"+(i+1));blog.setComment("注释内容");blog.setMobile("111111");blogRepository.save(blog);}}@Testpublic void updateDocument() {Optional<Blog> optional = blogRepository.findById(1l);if (optional.isPresent()) {Blog blog = optional.get();blog.setTitle("hello world");blogRepository.save(blog);}}@Testpublic void deleteDocument() {blogRepository.deleteById(1l);}@Testpublic void getById() {
//        Optional<Blog> optional = blogRepository.findById(1l);
//        Blog blog = optional.get();
//        System.out.println(blog);Iterable<Blog> all = blogRepository.findAll(PageRequest.of(1,10));all.forEach(b-> System.out.println(b));}@Testpublic void testFindByTitle() {List<Blog> list = blogRepository.findByTitle("测试");//termlist.stream().forEach(System.out::println);}@Testpublic void testFindByTitleAndContent() {List<Blog> list = blogRepository.findByTitleAndContent("37", "内容");list.forEach(e-> System.out.println(e));}}

BulkTest.java

package com.xd.cubemall.sdes;import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.xd.cubemall.search.CubemallSearchApplication;
import com.xd.cubemall.search.model.Blog;
import com.xd.cubemall.search.repository.BlogRepository;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate;
import org.springframework.data.elasticsearch.core.mapping.IndexCoordinates;
import org.springframework.data.elasticsearch.core.query.IndexQuery;
import org.springframework.test.context.junit4.SpringRunner;import java.util.List;
import java.util.stream.Collectors;@RunWith(SpringRunner.class)
@SpringBootTest(classes = CubemallSearchApplication.class)
public class BulkTest {@Autowiredprivate ElasticsearchRestTemplate template;@Autowiredprivate BlogRepository blogRepository;@Testpublic void bulkBlog() {JSONArray jsonArray = JSON.parseArray("");List<IndexQuery> list = jsonArray.stream().map(json -> {IndexQuery query = new IndexQuery();query.setId(((JSONObject) json).getString("id"));query.setSource(((JSONObject) json).toJSONString());return query;}).collect(Collectors.toList());template.bulkIndex(list, IndexCoordinates.of("blog_1"));}@Testpublic void saveAllBlog() {JSONArray jsonArray = JSON.parseArray("");List<Blog> list = jsonArray.stream().map(json -> {JSONObject jsonObject = ((JSONObject) json);Blog blog = jsonObject.toJavaObject(Blog.class);return blog;}).collect(Collectors.toList());blogRepository.saveAll(list);}}
http://www.lryc.cn/news/464982.html

相关文章:

  • 【Flutter】Dart:Isolate
  • ​微信小程序 页面间传递数据
  • 前端_005_Nodejs
  • SpringCache缓存介绍
  • python实战(一)——iris鸢尾花数据集分类
  • k8s-对命名空间资源配额
  • Failed to connect to github.com port 443
  • 【设计模式系列】简单工厂模式
  • 给定一个正整数n随机生成n个字节即生成2n个十六进制数将其组成字符串返回secrets.token_hex(n)
  • [Gtk] 工程
  • 基于Multisim的汽车尾灯控制电路设计与仿真
  • Leetcode 3326. Minimum Division Operations to Make Array Non Decreasing
  • redo文件误删除后通过逻辑备份进行恢复
  • 7805的输出电压如何调整?
  • git命令使用一览【自用】
  • MES系列-报表和分析
  • 如何在分布式环境中实现高可靠性分布式锁
  • Vue基础(4)
  • Redis高阶篇之Redis单线程与多线程
  • 【C++】STL——priority_queue优先级队列
  • 大数据新视界 --大数据大厂之大数据在智慧城市建设中的应用:打造智能生活的基石
  • 使用枚举来实现策略模式
  • 区块链技术原理
  • Spring Boot 接口数据加解密
  • 2018年计算机网络408真题解析
  • Javascript 脚本查找B站限时免费番剧
  • YoloV10改进策略:主干网络改进|DeBiFormer,可变形双级路由注意力|全网首发
  • C#学习笔记(一)
  • MATLAB边缘检测
  • Tortoise SVN 安装汉化教程(乌龟SVN)