XContentBuilder如何拼接es查询语句（多条件模糊查询分页，时间查询）

朱雀 2022-12-27 11:12 340阅读 0赞

### 使用XContentBuilder拼接查询条件时，注意有开始就要有结尾 ###

### Object类型 ###

//object对象，对应的json中的object
    xContentBuilder.startObject();
    xContentBuilder.endObject();
    
    //例如{"name":{}}
    xContentBuilder.startObject();
    xContentBuilder.startObject("name");
    xContentBuilder.endObject();
    xContentBuilder.endObject();

### Array类型 ###

//这里表示的是{"must":[]} 这种形式
    xContentBuilder.startArray("must");
    xContentBuilder.endArray();

### 不会写查询条件的可以使用插件elasticsearch-head，在浏览器插件中下载即可，也可以csdn下载[https://download.csdn.net/download/qq\_39187822/13622496][https_download.csdn.net_download_qq_39187822_13622496] ###

### 完整的代码 ###

@GetMapping("/getEsTestList")
        public Result<Object> getBookList(@RequestParam(defaultValue = "1") Integer page,
                                        @RequestParam(defaultValue = "10") Integer rows,
                                        String endPoint,
                                        String userName,
                                        String logContent,
                                        String operate,
                                        String beginTime,
                                        String endTime,
                                        String operateType) {
            Request request = new Request("POST", endPoint);
            // 添加Json返回优化
            request.addParameter("pretty", "true");
            // 拼接查询Json
            IndexRequest indexRequest = new IndexRequest();
            XContentBuilder builder = null;
            Response response = null;
            String responseBody = null;
            try {
                XContentBuilder xContentBuilder = JsonXContent.contentBuilder();
                xContentBuilder.startObject();
                    xContentBuilder.startObject("query");
                        xContentBuilder.startObject("bool");
                                xContentBuilder.startArray("must");
                                if(StringUtils.isNotNull(userName) || StringUtils.isNotNull(logContent) || StringUtils.isNotNull(operate) || StringUtils.isNotNull(operateType)){
                                        if(StringUtils.isNotNull(userName)){
                                            xContentBuilder.startObject();
                                                xContentBuilder.startObject("wildcard");
                                                    xContentBuilder.field("user_name",userName+"*");
                                                xContentBuilder.endObject();
                                            xContentBuilder.endObject();
                                        }
                                        if(StringUtils.isNotNull(logContent)){
                                            xContentBuilder.startObject();
                                                xContentBuilder.startObject("match");
                                                    xContentBuilder.field("log_content",logContent+"*");
                                                xContentBuilder.endObject();
                                            xContentBuilder.endObject();
                                        }
                                        if(StringUtils.isNotNull(operate)){
                                            xContentBuilder.startObject();
                                                xContentBuilder.startObject("wildcard");
                                                    xContentBuilder.field("operate",operate+"*");
                                                xContentBuilder.endObject();
                                            xContentBuilder.endObject();
                                        }
                                        if(StringUtils.isNotNull(operateType)){
                                            xContentBuilder.startObject();
                                                xContentBuilder.startObject("term");
                                                    xContentBuilder.field("operate_type",operateType);
                                                xContentBuilder.endObject();
                                            xContentBuilder.endObject();
                                        }
                                }
                                if(StringUtils.isNotNull(beginTime) && StringUtils.isNotNull(endTime)){
                                    xContentBuilder.startObject();
                                        xContentBuilder.startObject("range");
                                            xContentBuilder.startObject("oper_time");
                                                xContentBuilder.field("gte",beginTime);
                                                xContentBuilder.field("lte",endTime);
                                            xContentBuilder.endObject();
                                        xContentBuilder.endObject();
                                    xContentBuilder.endObject();
                                }
                                xContentBuilder.endArray();
                        xContentBuilder.endObject();
                    xContentBuilder.endObject();
                xContentBuilder.startObject("sort");
                    xContentBuilder.startObject("oper_time");
                        xContentBuilder.field("order","desc");
                    xContentBuilder.endObject();
                xContentBuilder.endObject();
                xContentBuilder.field("from",page);
                xContentBuilder.field("size",rows);
                xContentBuilder.endObject();
                builder = xContentBuilder;
                indexRequest.source(builder);
                // 设置请求体并指定ContentType，如果不指定会乱码
                request.setEntity(new NStringEntity(indexRequest.source().utf8ToString(), ContentType.APPLICATION_JSON));
                // 执行HTTP请求
                response = restClient.performRequest(request);
                responseBody = EntityUtils.toString(response.getEntity());
            } catch (IOException e) {
                return new ResultUtil<>().setData(null);
            }
            return new ResultUtil<>().setData(JSONObject.parseObject(responseBody));
        }

[https_download.csdn.net_download_qq_39187822_13622496]: https://download.csdn.net/download/qq_39187822/13622496