분산 검색 Elasticsearch - QueryBuilders.termQuery

2667 단어 Elasticsearch
주: 이 프로젝트의 기초는 분포식 검색 Elasticsearch-프로젝트 프로세스(一)와 분포식 검색 Elasticsearch-프로젝트 프로세스(二)로 프로젝트 골격은 여기서 다운로드할 수 있습니다.
ES 소스 코드에서 termQuery에 대한 설명은 다음과 같습니다.
    /**
     * A Query that matches documents containing a term.
     *
     * @param name  The name of the field
     * @param value The value of the term
     */
    public static TermQueryBuilder termQuery(String name, String value) {
        return new TermQueryBuilder(name, value);
    }

termQuery는 제가 많은 시간을 들여서 알게 된 Query입니다. (이전에 Lucene에 대한 연구가 적었기 때문에) 총괄적으로 보면termQuery는
의 value는 다음과 같습니다.
        1. 만약value가 한자라면 대부분의 경우 하나의 한자만 사용할 수 있다.
        2. 만약value가 영어라면 하나의 단어이다.
termQuery 코드는 다음과 같습니다.
/**
 * @author Geloin
 */
package com.geloin.esample.util;

import java.util.UUID;

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.fasterxml.jackson.databind.ObjectMapper;
import com.geloin.esample.BaseTest;
import com.geloin.esample.entity.Person;

/**
 * @author Geloin
 * 
 */
public class TermQueryTest extends BaseTest {

	@Test
	public void termQuery() {
		String index = "user";
		String type = "tb_person";
		try {
			//  
			Person p = new Person();
			p.setId(UUID.randomUUID().toString());
			p.setAge(20);
			p.setIsStudent(false);
			p.setSex(" ");
			p.setName(" ");

			ObjectMapper mapper = new ObjectMapper();
			String source = mapper.writeValueAsString(p);

			client.prepareIndex(index, type, p.getId()).setSource(source)
					.execute().actionGet();

			//  
			QueryBuilder qb = QueryBuilders.termQuery("name", " ");

			SearchResponse sResponse = client.prepareSearch(index)
					.setTypes(type).setQuery(qb).setFrom(0).setSize(12)
					.execute().actionGet();
			SearchHits hits = sResponse.getHits();

			if (null != hits && hits.totalHits() > 0) {
				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());
				}
			} else {
				log.info(" !");
			}

			//  : 
			Thread.sleep(100000);
		} catch (Exception e) {
			e.printStackTrace();
		}

	}
}

좋은 웹페이지 즐겨찾기