분산 검색 Elasticsearch - QueryBuilders.matchPhrasePrefixQuery

주: 이 프로젝트의 기초는 분포식 검색 Elasticsearch-프로젝트 프로세스(一)와 분포식 검색 Elasticsearch-프로젝트 프로세스(二)로 프로젝트 골격은 여기서 다운로드할 수 있습니다.
matchPhrasePrefixQuery에 대한 ES 소스 코드의 설명은 다음과 같습니다.

    /**
     * Creates a match query with type "PHRASE_PREFIX" for the provided field name and text.
     *
     * @param name The field name.
     * @param text The query text (to be analyzed).
     */
    public static MatchQueryBuilder matchPhrasePrefixQuery(String name, Object text) {
        return new MatchQueryBuilder(name, text).type(MatchQueryBuilder.Type.PHRASE_PREFIX);
    }

하면, 만약, 만약...
matchPhrasePrefixQuery를 호출할 때text는 중국어입니다. 그러면 아마도 하나의 상황일 것입니다. matchPhraseQuery와 matchPhrasePrefixQuery는 아무런 차이가 없습니다.텍스트가 영어일 때 차이가 나타난다. matchPhraseQuery의 텍스트는 영어 단어이고 matchPhrasePrefixQuery의 텍스트는 이런 제약이 없다. 한 영어 단어에서 연결된 알파벳 몇 개를 뽑아서 조회할 수 있다.
예제 코드는 다음과 같습니다.

/**
 * @author Geloin
 */
package com.gsoft.gsearch.util;

import java.util.UUID;

import junit.framework.Assert;

import org.elasticsearch.action.bulk.BulkRequestBuilder;
import org.elasticsearch.action.bulk.BulkResponse;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.index.query.QueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.junit.Test;

import com.gsoft.gsearch.BaseTest;
import com.gsoft.gsearch.entity.Person;

/**
 *  ， ， 
 * 
 * @author Geloin
 * 
 */
public class MatchPhrasePrefixQueryTest extends BaseTest {
	
	@Test
	public void matchPhrasePrefixQuery() {
		try {
			
			//  
			BulkRequestBuilder builder = client.prepareBulk();

			for (int i = 0; i < 2; i++) {
				Person p = new Person();
				p.setId(UUID.randomUUID().toString());
				p.setAge(20);
				p.setIsStudent(false);
				p.setSex(" ");
				p.setName("Zhangsan wang");

				String source = ElasticSearchUtil.BeanToJson(p);

				IndexRequest request = client.prepareIndex().setIndex(index)
						.setType(type).setId(p.getId()).setSource(source)
						.request();

				builder.add(request);
			}

			BulkResponse bResponse = builder.execute().actionGet();
			if (bResponse.hasFailures()) {
				Assert.fail(" ！");
			}

			//  
			QueryBuilder qb = QueryBuilders.matchPhraseQuery("name", "wa");
			
			SearchResponse searchResponse = client.prepareSearch(index)
					.setTypes(type).setQuery(qb).setFrom(0).setSize(12)
					.execute().actionGet();

			SearchHits hits = searchResponse.getHits();
			if (null == hits || hits.totalHits() == 0) {
				log.error(" matchPhraseQuery(\"name\", \"wa\") ！");
			} else {
				for (SearchHit hit : hits) {
					String json = hit.getSourceAsString();

					Person newPerson = mapper.readValue(json, Person.class);
					System.out.println("name\t\t" + newPerson.getName());
					System.out.println("sex\t\t" + newPerson.getSex());
					System.out.println("age\t\t" + newPerson.getAge());
					System.out.println("isStudent\t\t"
							+ newPerson.getIsStudent());
				}
			}
			
			System.out.println("===================================================");

			//  
			QueryBuilder qb1 = QueryBuilders.matchPhrasePrefixQuery("name", "wa");
			
			SearchResponse searchResponse1 = client.prepareSearch(index)
					.setTypes(type).setQuery(qb1).setFrom(0).setSize(20)
					.execute().actionGet();

			SearchHits hits1 = searchResponse1.getHits();
			
			
			if (null == hits1 || hits1.totalHits() == 0) {
				log.error(" matchPhrasePrefixQuery(\"name\", \"wa\") ！");
				return;
			} else {
				for (SearchHit hit : hits1) {
					String json = hit.getSourceAsString();

					Person newPerson = mapper.readValue(json, Person.class);
					System.out.println("name\t\t" + newPerson.getName());
					System.out.println("sex\t\t" + newPerson.getSex());
					System.out.println("age\t\t" + newPerson.getAge());
					System.out.println("isStudent\t\t"
							+ newPerson.getIsStudent());
				}
			}

		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			if (null != client) {
				client.close();
			}
			if (null != node) {
				node.close();
			}
		}
	}
}

matchP 사용
hraseQuery는 결과를 조회하지 않았고, matchPhrasePrefixQuery는 우리가 필요로 하는 결과를 조회했다.