首页 > 解决方案 > 弹性搜索的弹簧

问题描述

我正在为基本的 CRUD 操作以及灵活的搜索功能开发一个 spring 应用程序。我使用弹性搜索作为后端数据存储。

以下是我正在处理的 JSON 文档:-

{
    "event-id":"7700908",
    "date":"date:time",
    "expiry": "some date",
    "created-by":"",
    "type":"x1|business|x3",
    ...
    "dress-code": {
        "mime-type": "image|audio|video|text",
        "placeholder-type": "key|index",
        "en_us": "Dress code guidelines...",
        "en_in": "",
        "placeholders": [
            {
                "key": "foo-bar",
                "type": "snippet|image|quote",
                "content": {
                    "mime-type": "image|audio|video|text",
                    "en_us": "some instruction placeholder",
                    "en_in": "some instruction placeholder",
                    "fr_FR": ""
                }
            }
        ]
    },
    "events": {
        "event-id": "4534534",
        "event-instruction": {
            "mime-type": "audio|video|text",
            "placeholder-type": "key|index",
            "en_us": "The actual instruction, with/without placeholder (like put of 3d glasses etc...)",
            "en_in": "",
            "placeholders": [
                {
                    "key": "foobar",
                    "type": "snippet|image|quote",
                    "content": {
                        "mime-type": "image|audio|video|text",
                        "en_us": "some instruction placeholder",
                        "en_in": "some instruction placeholder",
                        "fr_FR": ""
                    }
                }
            ]
        },
        "rules":""
        ...
    },
    "refs": [
        {
            "person-id":"445245524",
            ...
        }
    ]
}

然后以下数据模型将代表服务器上的 json :-

public class Event {

    @JsonProperty("event-id")
    private String eventId;

    @JsonProperty("date")
    private String date;

    @JsonProperty("expiry")
    private String expiry;

    @JsonProperty("created-by")
    private String createdBy;

    @JsonProperty("type")
    private String type;

    ...

    @JsonProperty("dress-code")
    private DressCode dressCode;

    ...
}

像往常一样,有ControllerRepository类。Controller 类定义了从 url 到服务器方法的映射,而 Respository 类实现了所有必要的数据库操作。

插入和获取记录是非常基本的。但是,我在编写基于用户提供的标准的搜索功能时遇到了几个问题。以下是我的初步方法:-

public List<Map<String, Object>> getAllEventsForCriteria(final Event event) 
{

        List<Map<String, Object>> resultAsList = new ArrayList<>();
        SearchRequest searchRequest = new SearchRequest(INDEX);
        SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
        searchSourceBuilder.query(buildQuery(event));
        searchRequest.source(searchSourceBuilder);
        try {
            SearchResponse searchResponse = restHighLevelClient.search(searchRequest);
            SearchHit[] searchHits = searchResponse.getHits().getHits();
            for (SearchHit hit : searchHits) {
                resultAsList.add(hit.getSourceAsMap());
            }
        } catch (java.io.IOException e) {
            e.getLocalizedMessage();
        }
        return resultAsList;
    }

    private QueryBuilder buildQuery(final Event event) {

        BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery();

        if (event.getEventId() != null) {
            QueryBuilder idTerm = QueryBuilders.termQuery("id", event.getQuizId());
            queryBuilder.must(idTerm);
        }
        if (event.getDate() != null) {
            QueryBuilder dateTerm = QueryBuilders.matchQuery("date", event.getDate());
            queryBuilder.must(dateTerm);
        }
        if (event.getExpiry() != null) {
            QueryBuilder expiryTerm = QueryBuilders.matchQuery("expiry", event.getExpiry());
            queryBuilder.must(expiryTerm);
        }
        if (event.getCreatedBy() != null) {
            QueryBuilder createdByTerm = QueryBuilders.matchQuery("created-by", event.getCreatedBy());
            queryBuilder.must(createdByTerm);
        }
        if (event.getType() != null) {
            QueryBuilder typeTerm = QueryBuilders.matchQuery("type", event.getType());
            queryBuilder.must(typeTerm);
        }
        if (event.getDressCode() != null) {
            if (event.getDressCode().getMimeType() != null) {
                QueryBuilder mimeTerm = QueryBuilders.termQuery("dressCode.mime-type", event.getDressCode().getMimeType());
                queryBuilder.must(mimeTerm);
            }
            if (event.getDressCode().getEnUs() != null) {
                QueryBuilder enUSTerm = QueryBuilders.matchQuery("dressCode.en_us", event.getDressCode().getEnUs());
                queryBuilder.must(enUSTerm);
            }
            if (event.getInstructions().getEnIn() != null) {
                QueryBuilder enInTerm = QueryBuilders.matchQuery("dressCode.en_in", event.getDressCode().getEnIn());
                queryBuilder.must(enInTerm);
            }
        }

        return queryBuilder;
    }

这种方法有两个主要问题:-

标签: javaspringelasticsearch

解决方案


推荐阅读