Advertisement

ES查询代码测试和训练(基于现有框架)

阅读量:
复制代码
    	@Autowired
    private RestHighLevelClient restHighLevelClient;
    @Autowired
    private CosCommonConfig cosCommonConfig;
    
    public Integer getReadCountById(XfaceNoticeMessageListInquiryResponseSubDTO subDTO) {
        // 构造查询器
        BoolQueryBuilder boolQueryBuilder = new BoolQueryBuilder();
        boolQueryBuilder.filter(QueryBuilders.termsQuery("push_id", subDTO.getNoticeId()));
    
        SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
        sourceBuilder.query(boolQueryBuilder);
        sourceBuilder.fetchSource(new String[]{"push_id", "read_num", "e

全部评论 (0)

还没有任何评论哟~