修改部分

  1. @SpringBootTest
  2. public class MyTest{
  3. //注入RestHighLevelClient对象
  4. @Autowired
  5. private RestHighLevelClient restHighLevelClient;
  6. @Test
  7. public void test() throws IOException {
  8. //准备UpdateRequest请求对象
  9. UpdateRequest updateRequest = new UpdateRequest(索引库名, 文档id);
  10. //构建Map集合,放入需要修改的字段数据
  11. Map<String, Object> map = new HashMap<>();
  12. map.put(键, 值);
  13. //在UpdateRequest请求对象中放入Map集合
  14. updateRequest.doc(map);
  15. //发送请求
  16. restHighLevelClient.update(updateRequest, RequestOptions.DEFAULT);
  17. }
  18. }

修改全部

  1. @SpringBootTest
  2. public class MyTest{
  3. //注入RestHighLevelClient对象
  4. @Autowired
  5. private RestHighLevelClient restHighLevelClient;
  6. @Test
  7. public void test() throws IOException {
  8. //根据id查询数据库中的数据
  9. 类名 对象名 = XxxService.getById(id值);
  10. //转换为文档类型
  11. 文档类名 文档对象名 = new 文档类名(对象名);
  12. //序列化Json,这里需要引入fastjson的依赖
  13. String json = JSON.toJSONString(文档对象名);
  14. //准备IndexRequest请求对象,并指定索引库名和文档id
  15. IndexRequest indexRequest = new IndexRequest(索引库名).id(文档id);
  16. //在IndexRequest请求对象中放入Json,并指定参数类型为Json
  17. indexRequest.source(json, XContentType.JSON);
  18. //发送请求
  19. restHighLevelClient.index(indexRequest, RequestOptions.DEFAULT);
  20. }
  21. }