分布式搜索Elasticsearch——QueryBuilders.matchPhrasePrefixQuery-低调大师

分布式搜索Elasticsearch——QueryBuilders.matchPhrasePrefixQuery

2016-10-19 692

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

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

[java] view plain copy

/**
* 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没有任何差别。而当text为英文时，差别就显现出来了：matchPhraseQuery的text是一个英文单词，而matchPhrasePrefixQuery的text则无这一约束，你可以从一个英文单词中抽几个连接在一起的字母进行查询。

示例代码如下所示：

[java] view plain copy

/**
* @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\", \"<span style="font-size:14px;">wa</span>\")没有查询到任何结果！");
} 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();
}
}
}
}

你会发现，使用matchPhraseQuery并未查询出结果，而matchPhrasePrefixQuery查询出的，则是我们需要的结果。

http://blog.csdn.net/geloin/article/details/8939387

微信关注我们

原文链接：https://yq.aliyun.com/articles/269354

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

ElasticSearch大数据分布式弹性搜索引擎使用—从0到1

阅读目录：背景安装查找、下载rpm包、执行rpm包安装配置elasticsearch专属账户和组设置elasticsearch文件所有者切换到elasticsearch专属账户测试能否成功启动安装自启动elasticsearch servicewrapper包下载elasticsearch servicewrapper 包 elasticsearch servicewrapper开源包的配置小bug servicewrapper安装 chkconfig -add 加入linux启动服务列表安装_plugin/head管理插件（辅助管理）安装chrom中的elasticsearch客户端插件使用elasticsearch自带的_cat工具 clone 虚机（修改IP、HWaddr、UUID配置，最后修改下系统时间）配置 elasticsearch.yml配置 IP访问限制、默认端口修改9200 集群发现IP列表、node、cluster 名称 master node 启动切换 linux 打开最大文件数设置（用作index时候的系统阀值）安装中文分词器ik（注...

2016-10-20

675

阿里云E-Mapreduce动态 E-Mapreduce团队 1.6.0版本交互式查询（支持hive、spark）资讯开源大数据技术专场（上午）:Spark、HBase、JStorm应用与实践阿里在09年就开始尝试使用Hadoop技术，先后包括Hadoop、Spark、Hbase及JStorm，这些开源技术在不同的业务线广泛使用，推动阿里业务的发展。开源大数据技术专场（下午）:Databircks、Intel、阿里、梨视频的技术实践本论坛第一次聚集阿里Hadoop、Spark、Hbase、Jtorm各领域的技术专家，讲述Hadoop生态的过去现在未来及阿里在Hadoop大生态领域的实践与探索。后Hadoop时代，我们该如何去架构自己的大数据平台环顾时下，未来的大数据引擎究竟采用什么样的方式尚不可知，不过在大数据平台构建过程中如何去做好

2016-10-20

697

资源下载

更多资源

优质分享App

近一个月的开发和优化，本站点的第一个app全新上线。该app采用极致压缩，本体才4.36MB。系统里面做了大量数据访问、缓存优化。方便用户在手机上查看文章。后续会推出HarmonyOS的适配版本。

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能，例如代码缩略图，Python的插件，代码段等。还可自定义键绑定，菜单和工具栏。Sublime Text 的主要功能包括：拼写检查，书签，完整的 Python API ， Goto 功能，即时项目切换，多选择，多窗口等等。Sublime Text 是一个跨平台的编辑器，同时支持Windows、Linux、Mac OS X等操作系统。