ES测试保存

详情可参考ES官网添加链接描述
在GulimallESConfiguration中加入如下配置

 
    public static final RequestOptions COMMON_OPTIONS;
    static {
        RequestOptions.Builder builder = RequestOptions.DEFAULT.toBuilder();
        // builder.addHeader("Authorization", "Bearer " + TOKEN);
        // builder.setHttpAsyncResponseConsumerFactory(
        //         new HttpAsyncResponseConsumerFactory
        //                 .HeapBufferedResponseConsumerFactory(30 * 1024 * 1024 * 1024));
        COMMON_OPTIONS = builder.build();
    }

详情可参考ES官网添加链接描述

   @Data
    class User {
        private String userName;
        private String gender;
        private Integer age;
    }

    
    @Test
    public void testESSave() throws IOException {
        IndexRequest indexRequest = new IndexRequest("users");
        //数据的id
        indexRequest.id("1");

        // indexRequest.source("userName","zhangsan","age",18,"gender","男");

        User user = new User();
        user.setUserName("java小生不才");
        user.setAge(18);
        user.setGender("男");
        String jsonString = JSON.toJSONString(user);
        //要保存的内容
        indexRequest.source(jsonString, XContentType.JSON);

        //执行操作
        IndexResponse index = restHighLevelClient.index(indexRequest, GulimallESConfiguration.COMMON_OPTIONS);

        //提取有用的响应数据
        System.out.println(index);
    }

测试方法执行之前

测试方法执行之后