. . . . . . . . . . . . . . . . . . . . . .
\n. . . . . . . . . . . . . . . . . . . . . .
\n. . . . . . . . . . . . . . . . . . . . . .<\/p>\n
dependencies {\n implementation 'org.springframework.boot:spring-boot-starter-data-elasticsearch:2.5.6'\n}<\/code><\/pre>\n\uc124\uc815<\/h2>\n
\ucf54\ub9e8\ud2b8\ub97c \ud574\uc81c\ud558\uba74 \uac80\uc0c9\uc5d4\uc9c4\uc5d0 \uc804\uc1a1\ub418\ub294 \ucffc\ub9ac\ub97c \ub85c\uadf8\uc5d0 \ucd9c\ub825\ud574 \uc900\ub2e4.<\/p>\n
application.yml<\/p>\n
#logging:\n# level:\n# org:\n# springframework:\n# data:\n# elasticsearch:\n# client:\n# WIRE: trace\n\nelasticsearch:\n host: localhost\n port: 9200<\/code><\/pre>\n@Configuration\npublic class ElasticsearchClientConfig extends AbstractElasticsearchConfiguration {\n\n @Value("${elasticsearch.host}")\n private String host;\n\n @Value("${elasticsearch.port}")\n private int port;\n\n @Override\n @Bean\n public RestHighLevelClient elasticsearchClient() {\n SnakeCaseFieldNamingStrategy a;\n final ClientConfiguration clientConfiguration = ClientConfiguration.builder()\n .connectedTo(host + ":" + port)\n .usingSsl() \/\/ connect to https\n .build();\n\n return RestClients.create(clientConfiguration).rest();\n }\n\n @Bean\n public ElasticsearchOperations elasticsearchOperations() {\n return new ElasticsearchRestTemplate(elasticsearchClient());\n }\n}<\/code><\/pre>\n\uc5d4\ud130\ud2f0 \uc0dd\uc131<\/h2>\n
Entity \ub300\uc2e0 Document \uc5b4\ub178\ud14c\uc774\uc158\uc774 \ubd99\ub294\ub2e4.<\/p>\n
@Setter\n@Getter\n@NoArgsConstructor\n@Document(indexName = "auto_complete")\npublic class ESAutoComplete implements Persistable<Integer> {\n\n @Id\n @Field(type = FieldType.Long)\n Integer id;\n\n @NotNull\n @Field(type = FieldType.Text, name = "search_string")\n String searchString;\n\n @Override\n public Integer getId() {\n return id;\n }\n\n @Override\n public boolean isNew() {\n return false;\n }\n}<\/code><\/pre>\n\ub9ac\ud3ec\uc9c0\ud130\ub9ac \uc0dd\uc131<\/h2>\n@Repository\npublic interface ESAutoCompleteRepository extends ElasticsearchRepository<ESAutoComplete, Integer> {\n}<\/code><\/pre>\n\uc11c\ube44\uc2a4 \uc0dd\uc131<\/h2>\n@Service\npublic class ESAutoCompleteService extends ESCustomGenericService<ESAutoCompleteDto, ESAutoComplete, Integer, Integer> {\n\n private final ESAutoCompleteMapper mapper = Mappers.getMapper(ESAutoCompleteMapper.class);\n\n @Autowired\n private ElasticsearchOperations operations;\n\n public ESAutoCompleteService(ElasticsearchRepository<ESAutoComplete, Integer> repository) {\n super(repository, "\uc790\ub3d9\uc644\uc131");\n }\n\n @Override\n public SearchResponseDto search(Map<String, String> params) throws UnsupportedEncodingException {\n\n ESAutoCompleteSearchDto searchDto = new ESAutoCompleteSearchDto(params);\n Pageable pageable = PageRequest.of(searchDto.getPageNo(), searchDto.getPageSize());\n\n BoolQueryBuilder boolQueryBuilder = boolQuery();\n\n boolQueryBuilder\n .must(matchQuery("search_string.jaso",\n searchDto.getQueryString()).operator(Operator.AND).analyzer("suggest_search_analyzer").boost(5.0f))\n .should(matchPhraseQuery("search_string.ngram",\n searchDto.getQueryString()).analyzer("my_ngram_analyzer").boost(25.0f));\n\n NativeSearchQueryBuilder queryBuilder = new NativeSearchQueryBuilder();\n queryBuilder\n .withPageable(pageable)\n .withQuery(boolQueryBuilder);\n\n SearchHits<ESAutoComplete> articles = operations\n .search(queryBuilder.build(), ESAutoComplete.class, IndexCoordinates.of("auto_complete"));\n\n List<SearchHit<ESAutoComplete>> searchHitList = articles.getSearchHits();\n ArrayList<ESAutoComplete> list = new ArrayList<>();\n\n for (SearchHit<ESAutoComplete> item : searchHitList) {\n list.add(item.getContent());\n }\n List<Object> results = Arrays.asList(toDto(list).toArray());\n\n int totalCount = (int) articles.getTotalHits();\n\n return new SearchResponseDto(results, pageable, totalCount);\n }\n}<\/code><\/pre>\n```\n\n```java<\/code><\/pre>\n<\/code><\/pre>\n<\/code><\/pre>\n<\/code><\/pre>\n","protected":false},"excerpt":{"rendered":"