数据准备
ElasticSearch 实现分词全文检索 - 测试数据准备
ElasticSearch的各种查询
不会对查询关键字进行分词
term 查询
term的查询是代表完全匹配，搜索之前不会对你搜索的关键字进行分词，对你的关键字去文档分词库中的去匹配内容
# term 查询 -- 完整匹配 POST /sms-logs-index/_search { "from":0, "size":5, //获取5条，类似分页 "query":{ "term": { "province": { "value": "江苏" } } } }
返回值
{ "took" : 1, //执行花了ms "timed_out" : false, //没有超时 "_shards" : { "total" : 1, //总共多少分片 "successful" : 1, //成功了多少分片 "skipped" : 0, "failed" : 0 }, "hits" : { //hits 中是我们要看的数据 "total" : { "value" : 10, //一共查了N条 "relation" : "eq" }, "max_score" : 0.046520013, //匹配程度，匹配度越高，分数越高 "hits" : [ { "_index" : "sms-logs-index", "_type" : "_doc", "_id" : "Q5XEloYBGlLaT58Lnwjj", "_score" : 0.046520013, "_source" : { //完成内容 "corpName" : "corpName1", "createDate" : "2023-02-28 14:45:14", "fee" : 47, "ipAddr" : "172.16.0.66", "longCode" : "张三1", "mobile" : "13845591752", "operatorld" : 1, "province" : "江苏", "sendDate" : "2023-02-28 14:43:14", "smsContent" : "【阿里云】尊敬的vipsoft：您有2台云服务器ECS配置升级成功。如有CPU、内存变更或0Mbps带宽升级，您需要在ECS控制台手动重启云服务器后才能生效。", "state" : 1 } },
SpringBoot 代码term查询
@Test void termQuery() throws Exception{ String indexName = "sms-logs-index"; RestHighLevelClient client = ESClient.getClient(); //1. 创建Request对象 SearchRequest request = new SearchRequest(indexName); //2. 指定查询条件 SearchSourceBuilder builder = new SearchSourceBuilder(); builder.from(0); builder.size(5); builder.query(QueryBuilders.termQuery("province","江苏")); request.source(builder); //3. 执行查询 SearchResponse resp = client.search(request, RequestOptions.DEFAULT); //4. 获取到 _source 中的数据，并展示 for (SearchHit hit : resp.getHits().getHits()) { Map<String, Object> result = hit.getSourceAsMap(); System.out.println(result); } }
terms 查询
terms和term的查询机制是一样，都不会将指定的查询关键字进行分词，直接去分词库中匹配，找到相应文档内容。
terms是在针对一个字段包含多个值的时候使用。
term: where province = 江苏
terms: where province = 江苏 or province = ? or province = ?
Restful
# terms 查询 POST /sms-logs-index/_search { "query":{ "terms": { "province": [ "江苏", "上海" ] } } }
Java
@Test void termsQuery() throws Exception{ String indexName = "sms-logs-index"; RestHighLevelClient client = ESClient.getClient(); //1. 创建Request对象 SearchRequest request = new SearchRequest(indexName); //2. 指定查询条件 SearchSourceBuilder builder = new SearchSourceBuilder(); builder.query(QueryBuilders.termsQuery("province","江苏","上海")); request.source(builder); //3. 执行查询 SearchResponse resp = client.search(request, RequestOptions.DEFAULT); //4. 获取到 _source 中的数据，并展示 for (SearchHit hit : resp.getHits().getHits()) { Map<String, Object> result = hit.getSourceAsMap(); System.out.println(result); } }
在线ik分词器：https://www.sojson.com/analyzer
