springboot集成es 插入和查询的简单使用

阿里云国内75折回扣微信号：monov8

阿里云国际，腾讯云国际，低至75折。AWS 93折免费开户实名账号代冲值优惠多多微信号：monov8 飞机：@monov6

第一步引入依赖

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
            <version>2.2.5.RELEASE</version>
        </dependency>

第二步配置yml文件在spring下面加上这个

  elasticsearch:
    rest:
      # ip是服务器ip地址
      uris: http://127.0.0.1:9200

然后启动项目看到出现这个就是成功了

第三步创建一个常量类用于存储我们一会儿要用到的名称

public class OrderEs {
    public static final String INDEX_NAME = "order_index";

    public static final String ID = "id";

    public static final String ORDER_NO = "order_no";

    public static final String ORDER_BUYER = "order_buyer";

    public static final String ORDER_PHONE = "order_phone";

    public static final String REAL_PAY = "real_pay";

    public static final String ACCOUNT = "account";
}

第四步创建Es实体类注意要加上@Document注解

@Document(indexName = OrderEs.INDEX_NAME)
@Data
public class OrderEsPO {

    @Id
    @Field(type = FieldType.Keyword,name = OrderEs.ID)
    private String id;

    @Field(type = FieldType.Keyword,name = OrderEs.ORDER_NO)
    private String orderNo;

    @Field(type = FieldType.Keyword,name = OrderEs.ORDER_BUYER)
    private String orderBuyer;

    @Field(type = FieldType.Keyword,name = OrderEs.ORDER_PHONE)
    private String orderPhone;

    @Field(type = FieldType.Keyword,name = OrderEs.REAL_PAY)
    private String realPay;

    @Field(type = FieldType.Keyword,name = OrderEs.ACCOUNT)
    private String account;

}

第五步写测试接口这里展示了插入和查询两个方法

@RestController
@RequestMapping("/order")
@CrossOrigin
public class OrderController 

    @Resource
    private ElasticsearchRestTemplate elasticsearchRestTemplate;

    /**
     * es插入
     *
     * @return {@link String}
     */

    @GetMapping("/esinsert")
    @Transactional
    public String esInsert(){
        OrderEsPO orderEsPO = new OrderEsPO();
        orderEsPO.setOrderNo("1234455");
        orderEsPO.setOrderBuyer("张三");
        orderEsPO.setOrderPhone("13191892075");
        orderEsPO.setRealPay("100000");
        orderEsPO.setAccount("1008611");
        elasticsearchRestTemplate.save(orderEsPO);
        return "success";
    }

    /**
     * es搜索
     *
     * @param orderEsPO 订单es参数
     * @return {@link String}
     */
    @GetMapping("/essearch")
    @Transactional
    public String esSearch(OrderEsPO orderEsPO){
        /**构造查询对象**/
        BoolQueryBuilder booleanQueryBuilder = QueryBuilders.boolQuery();
        /**编写查询条件**/
        booleanQueryBuilder.should(QueryBuilders.termQuery(OrderEs.ORDER_NO,orderEsPO.getOrderNo()));
        /**构造query对象**/
        NativeSearchQuery nativeSearchQuery = new NativeSearchQuery(booleanQueryBuilder);
        /**搜索**/
        SearchHits<OrderEsPO> search = elasticsearchRestTemplate.search(nativeSearchQuery, OrderEsPO.class, IndexCoordinates.of(OrderEs.INDEX_NAME));
        List<OrderEsPO> collect = search.getSearchHits().stream().map(SearchHit::getContent).collect(Collectors.toList());
        return collect.toString();
    }
}

然后我们启动项目先调用插入接口由于这个索引一开始是不存在的第一次调用后会默认创建索引然后打开我们的可视化界面就能看到这里的索引