solr 模拟数据库like查询(不使用分词)

发布时间:2020-03-24作者:laosun阅读(3753)

solr

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;
        }
    public static String escapeQueryChars(String s) {
            StringBuilder sb = new StringBuilder();
            for (int i = 0; i < s.length(); i++) {
                char c = s.charAt(i);
                // These characters are part of the query syntax and must be escaped
                if (c == '\\' || c == '+' || c == '-' || c == '!' || c == '(' || c == ')' || c == ':' || c == '^'
                        || c == '[' || c == ']' || c == '\"' || c == '{' || c == '}' || c == '~' || c == '*' || c == '?'
                        || c == '|' || c == '&' || c == ';' || c == '/' || Character.isWhitespace(c)) {
                    sb.append('\\');
                }
                sb.append(c);
            }
            return sb.toString();
        }

    上边有一点需要谨记,多条件查询的时候,连接符AND,要使用大写才能生效。


5 +1

版权声明

 Java  源码  solr

 请文明留言

3 条评论