pom

  1.  <dependency>
  2.             <groupId>org.springframework.boot</groupId>
  3.             <artifactId>spring-boot-starter-web</artifactId>
  4.         </dependency>
  5.         <dependency>
  6.             <groupId>org.springframework.boot</groupId>
  7.             <artifactId>spring-boot-starter-data-jpa</artifactId>
  8.         </dependency>
  9.         <!--test-->
  10.         <dependency>
  11.             <groupId>org.springframework.boot</groupId>
  12.             <artifactId>spring-boot-starter-test</artifactId>
  13.         </dependency>
  14.         <dependency>
  15.             <groupId>org.springframework.boot</groupId>
  16.             <artifactId>spring-boot-starter-data-solr</artifactId>
  17.         </dependency>

代码：

  1. package com.example.solrdemo.controller;
  3. import com.example.solrdemo.pojo.TbItem;
  4. import com.example.solrdemo.pojo.TbItemDesc;
  5. import com.example.solrdemo.repository.TbItemDescRepository;
  6. import com.example.solrdemo.repository.TbItemRepository;
  7. import org.apache.solr.client.solrj.SolrClient;
  8. import org.apache.solr.client.solrj.SolrQuery;
  9. import org.apache.solr.client.solrj.SolrServerException;
  10. import org.apache.solr.client.solrj.response.QueryResponse;
  11. import org.apache.solr.common.SolrDocument;
  12. import org.apache.solr.common.SolrDocumentList;
  13. import org.apache.solr.common.SolrInputDocument;
  14. import org.junit.Test;
  15. import org.junit.runner.RunWith;
  16. import org.springframework.beans.factory.annotation.Autowired;
  17. import org.springframework.boot.test.context.SpringBootTest;
  18. import org.springframework.test.context.junit4.SpringRunner;
  19. import org.springframework.web.bind.annotation.RequestMapping;
  21. import java.io.IOException;
  22. import java.util.List;
  23. import java.util.Map;
  24. import java.util.UUID;
  26. @SpringBootTest
  27. @RunWith(SpringRunner.class)
  28. public class SolrControllerTest {
  30.     @Autowired
  31.     private SolrClient client;
  32.     @Autowired
  33.     TbItemRepository repository;
  34.     @Autowired
  35.     TbItemDescRepository tbItemDescRepository;
  37.     //录入数据
  38.     @Test
  39.     public void luru() throws IOException, SolrServerException {
  40.         List<TbItem> list = repository.findAll();
  41.         for (TbItem item:list){
  42.             SolrInputDocument doc = new SolrInputDocument();
  43.             doc.setField("id", item.getId());
  44.             doc.setField("item_title", item.getTitle());
  45.             doc.setField("item_sell_point", item.getSellPoint());
  46.             doc.setField("item_price", item.getPrice());
  47.             doc.setField("item_image", item.getImage());
  48.             doc.setField("item_category", item.getCid());
  49.             TbItemDesc des = tbItemDescRepository.findById(item.getId()).get();
  50.             if (des!=null&&des.getItemDesc()!=null){
  51.                 doc.setField("item_desc",des.getItemDesc() );
  52.             }
  53.             client.add("collection1", doc);
  54.             client.commit("collection1");
  56.             System.out.println(item);
  57.         }
  60.     }
  64.     //增加
  65.     @Test
  66.     public void teAdd() {
  67.         try {
  68.             SolrInputDocument doc = new SolrInputDocument();
  69.             doc.setField("id", "test001");
  70.             doc.setField("item_title", "测试商品");
  71.             doc.setField("item_price", "123213");
  72.             client.add("collection1", doc);
  73.             //client.commit();
  74.             client.commit("collection1");
  75.         } catch (Exception e) {
  76.             e.printStackTrace();
  77.         }
  78.     }
  80.     //查询
  81.     @Test
  82.     public void getById() throws IOException, SolrServerException {
  83.         SolrDocument document = client.getById("collection1", "test001");
  84.         System.out.println(document);
  85.     }
  88.     @Test
  89.     public void slelectParm() throws IOException, SolrServerException {
  90.         SolrQuery params = new SolrQuery();
  91.         //查询条件, 这里的 q 对应 下面图片标红的地方
  92.         params.set("q", "魔音"); //匹配title含有手机的
  93.         //过滤条件
  94.         //params.set("fq", "item_price:[100 TO 100000]");
  96.         //排序
  97.        // params.addSort("item_price", SolrQuery.ORDER.asc);
  99.         //分页
  100.         params.setStart(0);
  101.         params.setRows(20);
  103.         //默认域
  104.         //params.set("df", "item_title");//搜索匹配的对象，值匹配item_title存在的关键字
  105.         params.set("df", "item_keywords");//使用复制域做搜索对象，可以匹配多个对象
  107.         //只查询指定域
  108.         params.set("fl", "id,item_title,item_price,item_sell_point,item_desc");//搜索返回的数据项
  110.         //高亮
  111.         //打开开关
  112.         params.setHighlight(true);
  113.         //指定高亮域
  114.         params.addHighlightField("item_title");
  115.         //设置前缀
  116.         params.setHighlightSimplePre("<span style='color:red'>");
  117.         //设置后缀
  118.         params.setHighlightSimplePost("</span>");
  120.         QueryResponse queryResponse = client.query(params);
  122.         SolrDocumentList results = queryResponse.getResults();
  124.         long numFound = results.getNumFound();
  126.         System.out.println(numFound);
  128.         Map<String, Map<String, List<String>>> highlight = queryResponse.getHighlighting();//获取高亮显示的结果, 高亮显示的结果和查询结果是分开放的
  130.         for (SolrDocument result : results) {
  131.             System.out.println(result.get("id"));
  132.             System.out.println(result.get("item_title"));
  133.             System.out.println(result.get("item_price"));
  134.             Map<String, List<String>> map = highlight.get(result.get("id"));
  135.             List<String> list = map.get("item_title");
  136.             System.out.println(list.get(0));
  138.             System.out.println("------------------");
  139.             System.out.println();
  140.         }
  143.     }
  146.     /* /**
  147.      * 根据id删除索引
  148.      * @param id
  149.      * @return
  150.      */
  151.     public String delete(String id)  {
  152.         try {
  153.             client.deleteById("collection1",id);
  154.             client.commit("collection1");
  156.             return id;
  157.         } catch (Exception e) {
  158.             e.printStackTrace();
  159.         }
  162.         return "error";
  163.     }
  165.     /**
  166.      * 删除所有的索引
  167.      * @return
  168.      */
  169.     public String deleteAll(){
  170.         try {
  172.             client.deleteByQuery("collection1","*:*");
  173.             client.commit("collection1");
  175.             return "success";
  176.         } catch (Exception e) {
  177.             e.printStackTrace();
  178.         }
  179.         return "error";
  180.     }
  182. }

sorl的域配置：

  1. <field name="item_title" type="text_ik" indexed="true" stored="true"/>
  2. <field name="item_sell_point" type="text_ik" indexed="true" stored="true"/>
  3. <field name="item_price" type="text_ik" indexed="true" stored="true"/>
  4. <field name="item_image" type="text_ik" indexed="true" stored="true"/>
  5. <field name="item_category" type="text_ik" indexed="true" stored="true"/>
  6. <field name="item_desc" type="text_ik" indexed="true" stored="false"/>
  8. <field name="item_keywords" type="text_ik" indexed="true" stored="false" multiValued="true"/>
  9. <copyField source="item_title" dest="item_keywords"/>
  10. <copyField source="item_sell_point" dest="item_keywords"/>
  11. <copyField source="item_category" dest="item_keywords"/>
  12. <copyField source="item_desc" dest="item_keywords"/>