solrJ基础

我就是我 2022-04-13 20:30 223阅读 0赞

》

##### 使用solr，那么solr是什么呢？ #####

solr是基于Lucene开发的一个企业级搜索应用服务器(即搜索系统)。  
应用服务器：就是把开发出的系统war包运行在Tomcat中，运行该系统的Tomcat就是应用服务器。  
可以通过Solr系统管理索引库(core)。

> ###### 1、在solr 服务器中添加field 2种方式 ######
> 
>  *  1、添加 document
>  *  2、添加 JavaBean
> 
> 代码思想步骤  
> 1、连接jetty服务器  
> 2、创建文档对象，在document添加字段  
> 3、commit 提交

> 以下测试源码分享：  
> [https://github.com/medoo-Ai/solrj][https_github.com_medoo-Ai_solrj]

》

> ###### 2、添加JavaBean的方式长见的错误： ######
> 
> pojo中属性没有注解@Field，导致solrJ并不知道哪个属性要对应到索引库中：  
> 创建pojo

public class Item implements Serializable { 
        private static final long serialVersionUID=1L;
        @Field("id")
        private String id;
        @Field("title")
        private String title;
        @Field("price")
        private Float price;
        // 提供 getter 、setter 重写toString()
        }

> ###### 1、 添加solr索引库的 2种方式： ######
> 
> 1、通过 document 的方式  
> 2、通过 javabean 的方式

添加 javaBean单元测试:

//通过 document 的方式
       @Test
        public void test() throws IOException, SolrServerException { 
            HttpSolrServer server = new HttpSolrServer("http://localhost:8080/solr/core1");
            SolrInputDocument document = new SolrInputDocument();
            document.addField("id", "4");
            document.addField("title", "五菱宏光，神车");
            document.addField("price", 30000F);
            //
            server.add(document);
            //提交
            server.commit();
        }
    //pojo中属性没有注解@Field，导致solrJ并不知道哪个属性要对应到索引库中
        @Test
        public void testCreateIndexBean() throws IOException, SolrServerException { 
            HttpSolrServer server = new HttpSolrServer("http://localhost:8080/solr/core1");
            //
            Item item = new Item();
            item.setId("9");
            item.setPrice(3000F);
            item.setTitle("小米手机");
            // server中添加bean
            server.addBean(item);
            server.commit();
        }

运行通过、  
![1][]

> ###### 2、删除core1索引库中数据2种方式： ######
> 
> 1、根据 id  
> 2、根据查询条件删除索引

//testDeleteIndexById 根据id 删除
        @Test
        public void testDeleteIndexById() throws IOException, SolrServerException { 
            //使用solrj的jar
            HttpSolrServer server = new HttpSolrServer("http://localhost:8080/solr/core1");
            server.deleteById("1");
            server.commit();
        }
       //根据查询条件删除索引
        @Test
        public void testDeleteIndexByQuery() throws IOException, SolrServerException { 
            HttpSolrServer server = new HttpSolrServer("http://localhost:8080/solr/core1");
            server.deleteByQuery("title:iphone");
            server.commit();
        }

测试通过；  
![在这里插入图片描述][20181125224602417.png]

> ###### 3、query查询返回数据的2种形式： ######
> 
> 1、query返回document 的形式  
> 2、query返回javabean 的形式

//query返回document 的形式
        @Test
        public void testQueryToDocument() throws IOException, SolrServerException { 
            HttpSolrServer server = new HttpSolrServer("http://localhost:8080/solr/core1");
            //public class SolrQuery extends ModifiableSolrParams
            SolrQuery query = new SolrQuery("title:手机");
            //public QueryResponse query(SolrParams params)
            QueryResponse response = server.query(query);
            SolrDocumentList list = response.getResults();
            /** * 遍历list ，取出document */
            for (SolrDocument entries : list) { 
                System.out.println(entries.getFieldValue("id"));
                System.out.println(entries.getFieldValue("title"));
                System.out.println(entries.getFieldValue("price"));
            }
            System.out.println("查询的总条数：" + list.size());
        }
    
    //query返回javabean 的形式
        @Test
        public void testQueryToJavabean() throws IOException, SolrServerException { 
            HttpSolrServer server = new HttpSolrServer("http://localhost:8080/solr/core1");
            /** * 普通查询 */
    // SolrQuery query = new SolrQuery("title:iphone");
            /** * boolean 查询 */
    // SolrQuery query = new SolrQuery("title:iphone OR title:小米");
            /** * 相似度查询 ，类似于Lucene的编辑距离0-2 */
    // SolrQuery query = new SolrQuery("title:ipHOne~2");
            /** * 范围查询 xx TO xx * 闭区间 */
            SolrQuery query = new SolrQuery("price:[10 TO 10000]");
    
            //
            QueryResponse response = server.query(query);
            List<Item> itemList = response.getBeans(Item.class);
            for (Item item : itemList) { 
                System.out.println(item);
            }
            System.out.println("搜多到的条数：" + itemList.size());
        }

测试范围查询通过：  
![各回各家][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjMyMzgwMg_size_16_color_FFFFFF_t_70]

> ###### 4、solrJ查询的使用、3种常用的方式： ######
> 
> 1、solrJ 的排序查询  
> 2、solrJ 查询高亮显示  
> 3、solrJ 的分页

》solrJ 的排序查询

> 排序查询，核心在于使用setSort( )这个方法，对query对象进行排序规则的设置；  
> 设置排序源码如下:  
> public SolrQuery setSort(String field, ORDER order) \{  
> return setSort(new SortClause(field, order));  
> \}

@Test
        public void testQueryOrder() throws SolrServerException { 
            //连接solr服务器、创建query对象、设置查询排序参数 、查询
            HttpSolrServer server = new HttpSolrServer("http://localhost:8080/solr/core1");
            SolrQuery query = new SolrQuery("title:手机");
            //排序规则设置
            query.setSort("price", SolrQuery.ORDER.desc);
            QueryResponse response = server.query(query);
            //
            List<Item> itemList = response.getBeans(Item.class);
            for (Item item : itemList) { 
                System.out.println(item.toString());
            }
            System.out.println("搜索到的条数：" + itemList.size());
        }

按照price 降序测试通过：  
![sdf][]  
》solrJ 查询高亮显示

>  *  使用 solrj 高亮显示 ,核心步骤在于针对query对象：  
>     \* 1、set高亮标签，add高亮字段  
>     \* 2、高亮工具

@Test
        public void testHighlightingQuery() throws SolrServerException { 
            //连接solr服务器、创建query对象、高亮、查询
            HttpSolrServer server = new HttpSolrServer("http://localhost:8080/solr/core1");
            SolrQuery query = new SolrQuery("title:手机");
            // 标签、字段
            query.setHighlightSimplePre("<em>");
            query.setHighlightSimplePost("</em>");
            query.addHighlightField("title");
            //
            QueryResponse response = server.query(query);
            /** * 高亮的响应结果 是一个双层map ： * id :对应id的高亮字段 * 高亮字段：高亮值 为list */
            Map<String, Map<String, List<String>>> map = response.getHighlighting();
            /** * 普通查询结果 */
            List<Item> itemList = response.getBeans(Item.class);
            for (Item item : itemList) { 
                System.out.println("id" + item.getId());
                // 高亮值 为list
                System.out.println("title" + map.get(item.getId()).get("title").get(0));
                System.out.println("price" + item.getPrice());
            }
            System.out.println("搜索到的条数：" + itemList.size());
        }

高亮测试通过：  
![fd][]

》分页

>  *  使用 solrJ 进行分页，核心步骤在于对query对象设置分页规则及参数  
>     \* 1、准备参数  
>     \* 2、设置到query中

@Test
        public void testPagedQuery() throws SolrServerException { 
            //连接solr服务器、创建query对象、设置查询排序参数 、查询
            HttpSolrServer server = new HttpSolrServer("http://localhost:8080/solr/core1");
            SolrQuery query = new SolrQuery("title:手机");
            // 设置分页
            int currentPage = 2;
            final int PAGE_SIZE = 4;
            int start = (currentPage - 1) * PAGE_SIZE;
            // 设置起始页，设置每页显示数目
            query.setStart(start);
            query.setRows(PAGE_SIZE);
            //
            QueryResponse response = server.query(query);
            List<Item> itemList = response.getBeans(Item.class);
            //展示数据
            System.out.println("当前页："+currentPage+"共查询数据："+itemList.size());
            for (Item item : itemList) { 
                System.out.println("数据："+item.toString());
            }
        }

分页测试通过：  
![SDF][]

[https_github.com_medoo-Ai_solrj]: https://github.com/medoo-Ai/solrj
[1]: /images/20220414/4bccee2c63f949f8a0bfb9f22b4c4b6f.png
[20181125224602417.png]: /images/20220414/34090c7cda9d4f278febabde7156820c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjMyMzgwMg_size_16_color_FFFFFF_t_70]: /images/20220414/6c8abdff483f4b0dbb34bb9185c8fcf5.png
[sdf]: /images/20220414/fb520bdbc6fd465cab16a83b2743d665.png
[fd]: /images/20220414/37d74c9e52c8446da2d9d9007134ebce.png
[SDF]: /images/20220414/4b5c686ebe24451c98069bde459a5922.png