solr 模拟数据库like查询(不使用分词)
IK分词个别拆分的不够完美,另外个别业务逻辑是需要替代数据库的like查询。所以本篇文章是介绍如何在solr中使用类似数据库的like查询
本片文章是介绍如何在solr中使用类似数据库的like操作。
首先我们抛弃text_ik。IK分词,因为使用的是like操作,所以这块不能在使用分词了。
我们需要在在conf目录下找到managed-schema配置文件。
增加节点如下:
<fieldType name="string_ci" class="solr.TextField" sortMissingLast="true" omitNorms="true"> <analyzer> <tokenizer class="solr.KeywordTokenizerFactory"/> <filter class="solr.LowerCaseFilterFactory" /> </analyzer> </fieldType>
另外配置一下查询字段,如下所示:
<field name="name" type="string_ci" indexed="true" stored="true"/>
这种简单的配置即可完成like操作。
另外上边的配置增加 LowerCaseFilterFactory 。也就是忽略大小写的意思。
现在博主贴出一个query测试案例:
public static Page<TScanqrSeller> querySellerFromSolrByName(Integer pageNumber, Integer pageSize, Kv cond) {
Page<TScanqrSeller> page = new Page<TScanqrSeller>();
if(StringUtils.isNotBlank(cond.getStr("name"))){
String name = StringKit.escapeQueryChars(cond.getStr("name"));
cond.set("name", name);
}
SolrQuery query = new SolrQuery();
query.setHighlight(false);
query.addHighlightField("name");
query.setHighlightSimplePre("<mark>");
query.setHighlightSimplePost("</mark>");
query.setStart((pageNumber-1)*pageSize);
query.setRows(pageSize);
String sql = Const.BLANK;
if(StringUtils.isNotBlank(cond.getStr("name"))) {
sql += " AND name:*"+cond.getStr("name")+"*";
}
if(StringUtils.isNotBlank(cond.getStr("companyId"))) {
sql += " AND company_id:"+cond.getStr("companyId");
}
sql = sql.substring(5, sql.length());
query.set("q", sql);
List<TScanqrSeller> articles = new ArrayList<TScanqrSeller>();
SolrClient solrClient = createSolrServer(SolrUrlEnum.SOLR_SELLER.getValue());
try {
QueryResponse response = solrClient.query(query);
SolrDocumentList docList = response.getResults();
Iterator<SolrDocument> it = docList.iterator();
while (it.hasNext()) {
SolrDocument doc = it.next();
String id = doc.getFieldValue("id").toString();
String name = doc.getFieldValue("name")==null?null:doc.getFieldValue("name").toString();
Long key = doc.getFieldValue("key")==null?0L:Long.valueOf(doc.getFieldValue("key").toString());
String shortName = doc.getFieldValue("short_name")==null?null:doc.getFieldValue("short_name").toString();
String companyId = doc.getFieldValue("company_id")==null?null:doc.getFieldValue("company_id").toString();
TScanqrSeller seller = new TScanqrSeller();
seller.set("id", id);
seller.put("name_text", name);
seller.set("key", key);
seller.set("short_name", shortName);
seller.set("company_id", companyId);
if(StringUtils.isNotBlank(cond.getStr("name"))) {
Pattern p = Pattern.compile(cond.getStr("name"), Pattern.CASE_INSENSITIVE);
Matcher m = p.matcher(name);
while(m.find()) {
for(int i=0; i<=m.groupCount(); i++){
String oldValue = m.group(i);
name = name.replaceFirst(StringKit.escapeQueryChars(oldValue), "<mark>"+oldValue+"</mark>");
}
}
seller.set("name", name);
}
// name = name.replaceAll("(?i)"+reqparam, "<mark>"+"(?i)"+reqparam+"</mark>");
articles.add(seller);
}
Integer totalRow = Integer.valueOf(docList.getNumFound()+"");
Integer totalPage = (int) (totalRow % pageSize == 0 ? totalRow / pageSize : Math.ceil((double)totalRow / (double)pageSize)) ;
page = new Page<TScanqrSeller>(articles, pageNumber, pageSize, totalPage, totalRow);
} catch (SolrServerException e) {
e.printStackTrace();
} catch (Exception e) {
e.printStackTrace();
} finally{
try {
solrClient.close();
} catch (IOException e) {
e.printStackTrace();
}
}
return page;
}上边有一点需要谨记,多条件查询的时候,连接符AND,要使用大写才能生效。