zoukankan      html  css  js  c++  java
  • 我与solr(四)--solrJ

    SolrJ索引库:

    solr提供的一个客户端操作框架,在文件/solr6.2/dist下面可以找到该jar包solrj.jar以及相关jar包,可以使用maven添加。

    java使用solrJ如下:

    @Service
    public class IntelligenceWordSolrDAOImpl implements IntelligenceWordSolrDAO {
    
        private static final String URL = Config.getString("config.solr.url.mycore");
    
        /**
         * 获取solrService对象
         *
         * @return
         */
        private SolrClient getSolrService() {
    
            String urlString = "http://192.168.1.12:8080/solr/mycore";
            SolrClient solr = new HttpSolrClient.Builder(urlString).build();
    
            return solr;
        }
    
        /**
         * 在搜索器引擎中创建索引
         *
         * @param intelligenceList
         */
        public void add(List<Intelligence> intelligenceList) throws Exception {
    
            SolrClient solr = getSolrService();
    
            List<SolrInputDocument> SolrInputDocumentList = Lists.newArrayList();
            intelligenceList.forEach(intelligence -> SolrInputDocumentList.add(initProperty(intelligence)));
    
            solr.add(SolrInputDocumentList);
            solr.commit();
        }
    
        /**
         * 查询数据
         *
         * @param param 匹配的参数集合
         * @return 文档的数量
         * @throws Exception
         */
        public Long query(String[] param, Integer limit) throws Exception {
    
            Integer branchId = LoginContext.getBranchId();
            SolrClient solr = getSolrService();
            SolrQuery query = new SolrQuery();
    
            StringBuffer buffer = new StringBuffer();
            for (int i = 0; i < param.length; i++) {
                if (i + 1 == param.length) {
                    buffer.append(""" + param[i] + """);
                } else {
                    buffer.append(""" + param[i] + """ + " OR ");
                }
            }
    
            //根据时间限制设置选定条件
            DateTime dateTime = new DateTime();
            dateTime.minusDays(limit);
            Date queryTime = dateTime.toDate();
    
            String queryStr = "text:(" + buffer.toString() + ")";
            query.add(queryStr);
    
            //时间限定
            String limitStr = "collectTime:[" + queryTime + " TO *]";
            String branchStr = "branchId:("+branchId+")";
            query.add(limitStr);
            query.add(branchStr);
    
            // String allQuery = queryStr+" AND "+limitStr+" AND "+branchStr;
    
            //query.setQuery(allQuery);
    
            QueryResponse response = solr.query(query);
    
            //获取返回的数据
            SolrDocumentList solrDocumentList = response.getResults();
            return solrDocumentList.getNumFound();
        }
    
        /**
         * 初始化
         *
         * @param param
         * @return
         */
        public SolrInputDocument initProperty(Intelligence param) {
    
            Assert.notNull(param, "param not be null");
            SolrInputDocument document = new SolrInputDocument();
            document.addField("id", param.getIntelligenceId());
            document.addField("intelligenceId", param.getIntelligenceId());
            document.addField("title", param.getTitle());
            document.addField("content", param.getContent());
            document.addField("collectTime", param.getCollectTime().getTime());
            document.addField("branchId", param.getBranchId());
    
            return document;
        }
    
    }
  • 相关阅读:
    (OK)(OK) running two Android-x86 in VirtualBox, they connect to NS3(MANETs) via "ethernet bridge"
    (OK) running two Android-x86 in VirtualBox, they connect to "ethernet bridge"
    (OK) virtualbox — VBoxManage internalcommands — with UUID already exists
    (OK) netcat transfer file to android from fedora23
    Setting VirtualBox to use it's built-in VNC server (ver. >= 4.2 I think)
    (OK) Android 6.0 (Marshmallow) Install apk
    netcat——Useful netcat examples on Linux
    Android下pm 命令详解
    (OK) Ubuntu 15.10: KVM vs. Xen vs. VirtualBox Virtualization Performance
    Virtualization solutions on Linux systems
  • 原文地址:https://www.cnblogs.com/DASOU/p/5904572.html
Copyright © 2011-2022 走看看