Solr4.10使用教程(三)：solr crud

时间：2015-01-19 12:48:16 阅读：165 评论：0 收藏：0 [点我收藏+]

标签：

solr的增删改查，啥都不说，直接代码

package com.johnny.lucene06.solr;

import java.io.IOException;
import java.util.ArrayList;
import java.util.Collection;
import java.util.List;

import org.apache.solr.client.solrj.SolrQuery;
import org.apache.solr.client.solrj.SolrResponse;
import org.apache.solr.client.solrj.SolrServerException;
import org.apache.solr.client.solrj.impl.HttpSolrServer;
import org.apache.solr.client.solrj.response.QueryResponse;
import org.apache.solr.common.SolrDocument;
import org.apache.solr.common.SolrDocumentList;
import org.apache.solr.common.SolrInputDocument;
import org.junit.Test;

public class SolrHelloWorldTest {
   //solr server URL指的时solr发布到web工程后的访问路径
   private final static String SolrURL = "http://localhost:8080/solr";

   private HttpSolrServer solrServer = null;
   /**如果要使用下面的test，需要确保solr的tomcat服务器以已经启动**/
   //使用Field添加doc
   @Test
   public void test01(){
       try {
           /**1、创建solrServer(HttpSolrServer和EmbeddedSolrServer)
           * 其中HttpSolrServer必须依赖tomcat等WEB容器，EmbeddedSolrServer则不需要，但是需要
           * 引入其它jar包，具体可以参照doc下得solr wiki.html
           * **/
           HttpSolrServer server = getSolrServer();
           server.deleteByQuery("*:*");//先删除默认数据，防止对理解产生混淆
           /**2、solr要求doc的Field中必须存在一个Field为id,并且值为java.lang.String类型
           * 并且要保证Id的唯一，否则最后添加的相同Id的域会覆盖前面的域，也就等于是更新
           * **/
           SolrInputDocument doc = new SolrInputDocument();
           doc.addField("id",String.valueOf(1));
           /**3、对于需要使用doc添加的Field，必须先在schema.xml中进行配置，然后才可以使用,
           * 关于schema的配置说明，可以参照lucene-solr.txt中得说明
           * **/
           doc.addField("my_title","这是我的solr Hello world ");
           doc.addField("my_content","大家好，欢迎查看我的第一篇solr text");
           server.add(doc);
           SolrInputDocument doc2 = new SolrInputDocument();
           doc2.addField("id", String.valueOf(2));
           doc2.addField("my_title","我是中国人 ");
           doc2.addField("my_content","我爱你，伟大的祖国，我爱北京天安门 hello");
           server.add(doc2);
           server.commit();//提交，将所有更细提交到索引中
       } catch (SolrServerException e) {
           e.printStackTrace();
       } catch (IOException e) {
           e.printStackTrace();
       }
   }
   //solrServer是线程安全的，所以在使用时需要使用单例的模式，减少资源的消耗
   public HttpSolrServer getSolrServer(){
       if(solrServer==null){
           solrServer = new HttpSolrServer(SolrURL);
       }
       return solrServer;
   }

   /**
   * 使用POJO添加document
   */
   @Test
   public void testAddDocumentByObject(){
       try {
           HttpSolrServer server = getSolrServer();
           List<Message> msgs = new ArrayList<Message>();
           msgs.add(new Message("3","测试Hello POJO添加", "pojo应该可以添加成功"));
           msgs.add(new Message("4","Hello，我又添加了一条","现在Id已经是4了"));
           msgs.add(new Message("5", "我已经添加5条记录了", "hello ok,在添加我就吐了。。"));
           server.addBeans(msgs);
           server.commit();
       } catch (SolrServerException e) {
           e.printStackTrace();
       } catch (IOException e) {
           e.printStackTrace();
       }
   }
   /**修改记录，
   * 修改时是按照Id进行覆盖的
   * **/
   @Test
   public void testUpdate(){
       try {
           HttpSolrServer server = getSolrServer();
           server.addBean(new Message("5","id为5的数据被修改了", "hello,看来我真的被修改了"));
           server.commit();
       } catch (IOException e) {
           e.printStackTrace();
       } catch (SolrServerException e) {
           e.printStackTrace();
       }
   }
   /**
   * 查询,默认如果需要查看全部结果，需要使用*进行查询，不过可以在展示和提交的时候和空格进行转换
   */
   @Test
   public void testQuery(){
       try {
           HttpSolrServer server = getSolrServer();
           String q = "my_content:hello";//q表示查询的内容
           SolrQuery query = new SolrQuery(q);
           query.setStart(0)
                 .setRows(3);//进行分页查询
           query.setHighlight(true).setHighlightSimplePre("<span color=‘red‘>")
                 .setHighlightSimplePost("</span>");//高亮

           query.setParam("hl.fl", "my_content");
           //只有将内容存储后才能进行展示，比如title_content查询结果就为空
           //query.setParam("hl.fl", "my_title,my_content");
           QueryResponse resp = server.query(query);
           SolrDocumentList sdList = resp.getResults();
           long totalResults = sdList.getNumFound();//命中的总记录数
           System.out.println("totalResults-->"+totalResults);
           for(SolrDocument sd:sdList){
               Collection<String> strs = sd.getFieldNames();
               System.out.println(sd.getFieldValue("my_title"));
               System.out.println(sd.getFieldValue("my_content"));
               Object id = sd.getFieldValue("id");
               if(resp.getHighlighting().get(id)!=null){
                   System.out.println("高亮的结果-->"
                           +resp.getHighlighting().get(id).get("my_content"));
               }
               System.out.println("-------------------------------");

           }
       } catch (SolrServerException e) {
           e.printStackTrace();
       }
   }
}

配置说明：

关于schema.xml的配置说明
（1）如果需要添加mmseg4j对solr的中文分词支持，添加：
     
       <fieldtype name="textComplex" class="solr.TextField" positionIncrementGap="100">
           <analyzer>
               <tokenizer class="com.chenlb.mmseg4j.solr.MMSegTokenizerFactory" mode="complex" dicPath="dic"/>
           </analyzer>
       </fieldtype>
       <fieldtype name="textMaxWord" class="solr.TextField" positionIncrementGap="100">
           <analyzer>
               <tokenizer class="com.chenlb.mmseg4j.solr.MMSegTokenizerFactory" mode="max-word" />
           </analyzer>
       </fieldtype>
       <fieldtype name="textSimple" class="solr.TextField" positionIncrementGap="100">
           <analyzer>
               <tokenizer class="com.chenlb.mmseg4j.solr.MMSegTokenizerFactory" mode="simple" dicPath="n:/custom/path/to/my_dic" />
           </analyzer>
       </fieldtype>
（2）添加自己的查询字段：
     <field name="my_title" type="string" indexed="true" stored="true"/>
     <field name="my_content" type="string" indexed="true" stored="true"/>
       其中，name:表示要添加的查询字段
             type:字段的类型，以及在schema.xml中有定义
             indexed:是否索引
             stored:是否存储
（3）如果需要同时在title和content中进行查询，可以添加如下字段：
       <field name="title_content" type="textComplex" indexed="true" stored="false" multiValued="true"/>
      <copyField source="my_title" dest="title_content"/>
      <copyField source="my_content" dest="title_content"/>
      其中：title_content为新定义的查询字段，如果需要同时在title和content中进行查询，那么就使用这个查询字段
（4）设置默认查询字段，这样的话就不需要在Query中进行查询时使用my_title:hello这样的格式
    将solrconfig.xml中得 <str name="df">text</str>
    修改为： <str name="df">title_content</str>
    这样，如果需要查询内容在标题字段或内容字段出现的结果的时候，只需要在查询条件中填写hello就可以了

Solr4.10使用教程(三)：solr crud

标签：

原文地址：http://blog.csdn.net/seven_zhao/article/details/42871645

踩

(0)

评论一句话评论（0）

分享档案

更多>

2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)

周排行