学步园

        注：该文项目基础为分布式搜索Elasticsearch——项目过程（一）和分布式搜索Elasticsearch——项目过程（二），项目骨架可至这里下载。

        ES源代码中对matchQuery的描述如下所示：

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

        总的来说，matchQuery能够使用某一field的值对Document进行查询。

        示例代码如下所示：

/**
 * @author Geloin
 */
package com.geloin.esample.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.geloin.esample.BaseTest;
import com.geloin.esample.entity.Person;

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

	@Test
	public void matchQuery() {
		try {
			String name = "name";
			String text = "别克";
			BulkRequestBuilder requestBuilder = client.prepareBulk();
			// 创建索引
			for (int i = 0; i < 10; i++) {
				Person p = new Person();
				p.setAge(20 + i);
				p.setId(UUID.randomUUID().toString());
				p.setIsStudent(true);
				p.setName("小别克听老别克讲别克的故事" + i);
				p.setSex("男");

				String source = ElasticSearchUtil.BeanToJson(p);
				IndexRequest request = client
						.prepareIndex(index, type, p.getId()).setSource(source)
						.request();

				requestBuilder.add(request);
			}
			BulkResponse response = requestBuilder.execute().actionGet();
			if (response.hasFailures()) {
				Assert.fail("创建索引失败！");
			}

			// 检索
			QueryBuilder qb = QueryBuilders.matchQuery(name, text);
			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("没有查询到任何结果！");
				return;
			} 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());
				}
			}
			
			Thread.sleep(1000000);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}