使用solrJ管理索引库

素颜马尾好姑娘i 2022-05-29 03:51 149阅读 0赞

1.添加文档

@Test
        public void addDocument() throws Exception {
            // 第一步：把solrJ的jar包添加到工程中。
            // 第二步：创建一个SolrServer，使用HttpSolrServer创建对象。
            SolrServer solrServer = new HttpSolrServer("http://localhost:8080/solr");
            // 第三步：创建一个文档对象SolrInputDocument对象。
            SolrInputDocument document = new SolrInputDocument();
            // 第四步：向文档中添加域。必须有id域，域的名称必须在schema.xml中定义。
            document.addField("id", "test001");
            document.addField("item_title", "测试商品");
            document.addField("item_price", "199");
            // 第五步：把文档添加到索引库中。
            solrServer.add(document);
            // 第六步：提交。
            solrServer.commit();
        }

2.删除文档  
2.1 根据id删除 索引内容

@Test
        public void deleteDocumentById() throws Exception {
            // 第一步：创建一个SolrServer对象。
            SolrServer solrServer = new HttpSolrServer("http://localhost:8080/solr");
            // 第二步：调用SolrServer对象的根据id删除的方法。
            solrServer.deleteById("1");
            // 第三步：提交。
            solrServer.commit();
        }

2.2根据查询删除

@Test
        public void deleteDocumentByQuery() throws Exception {
            SolrServer solrServer = new HttpSolrServer("http://localhost:8080/solr");
            solrServer.deleteByQuery("title:change.me");
            solrServer.commit();
        }

1.  查询索引库  
    3.1 简单查询

@Test
        public void queryDocument() throws Exception {
            // 第一步：创建一个SolrServer对象
            SolrServer solrServer = new HttpSolrServer("http://localhost:8080/solr");
            // 第二步：创建一个SolrQuery对象。
            SolrQuery query = new SolrQuery();
            // 第三步：向SolrQuery中添加查询条件、过滤条件。。。
            query.setQuery("*:*");
            // 第四步：执行查询。得到一个Response对象。
            QueryResponse response = solrServer.query(query);
            // 第五步：取查询结果。
            SolrDocumentList solrDocumentList = response.getResults();
            System.out.println("查询结果的总记录数：" + solrDocumentList.getNumFound());
            // 第六步：遍历结果并打印。
            for (SolrDocument solrDocument : solrDocumentList) {
                System.out.println(solrDocument.get("id"));
                System.out.println(solrDocument.get("item_title"));
                System.out.println(solrDocument.get("item_price"));
            }
        }

3.2 带高亮显示

@Test
        public void queryDocumentWithHighLighting() throws Exception {
            // 第一步：创建一个SolrServer对象
            SolrServer solrServer = new HttpSolrServer("http://localhost:8080/solr");
            // 第二步：创建一个SolrQuery对象。
            SolrQuery query = new SolrQuery();
            // 第三步：向SolrQuery中添加查询条件、过滤条件。。。
            query.setQuery("测试");
            //指定默认搜索域
            query.set("df", "item_keywords");
            //开启高亮显示
            query.setHighlight(true);
            //高亮显示的域
            query.addHighlightField("item_title");
            query.setHighlightSimplePre("<em>");
            query.setHighlightSimplePost("</em>");
            // 第四步：执行查询。得到一个Response对象。
            QueryResponse response = solrServer.query(query);
            // 第五步：取查询结果。
            SolrDocumentList solrDocumentList = response.getResults();
            System.out.println("查询结果的总记录数：" + solrDocumentList.getNumFound());
            // 第六步：遍历结果并打印。
            for (SolrDocument solrDocument : solrDocumentList) {
                System.out.println(solrDocument.get("id"));
                //取高亮显示
                Map<String, Map<String, List<String>>> highlighting = response.getHighlighting();
                List<String> list = highlighting.get(solrDocument.get("id")).get("item_title");
                String itemTitle = null;
                if (list != null && list.size() > 0) {
                    itemTitle = list.get(0);
                } else {
                    itemTitle = (String) solrDocument.get("item_title");
                }
                System.out.println(itemTitle);
                System.out.println(solrDocument.get("item_price"));
            }
        }