使用solrj 对solr进行增删改查操作

package com._656464.solr.test;
import java.io.IOException;
import org.apache.solr.client.solrj.SolrServer;
import org.apache.solr.client.solrj.SolrServerException;
import org.apache.solr.client.solrj.impl.HttpSolrServer;
import org.apache.solr.common.SolrInputDocument;
import org.junit.Before;
import org.junit.Test;
/**
 * 使用solrj 来调用solr 的服务
 */
public class SolrTest {
    SolrServer solr = null;
    @Before
    public void init(){
        String urlString = "http://localhost:8983/solr";
        solr = new HttpSolrServer(urlString);
    }
    @Test
    public void addIndex() throws SolrServerException, IOException{
        SolrInputDocument document=new SolrInputDocument();
        //第一种添加方式,通过添加Field创建索引文档
        document.addField("id", "1");
        document.addField("name", "领悟书生");
        solr.add(document);
        solr.commit();
    }
}

package com._656464.solr.test;
import org.apache.solr.client.solrj.beans.Field;
public class TestObj {
    @Field(value = "id")
    private int id;
    @Field(value = "name")
    private String name;
    @Field(value = "content")
    private String content;
    @Field(value = "price")
    private double price;
    public int getId() {
        return id;
    }
    public void setId(int id) {
        this.id = id;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public String getContent() {
        return content;
    }
    public void setContent(String content) {
        this.content = content;
    }
    public double getPrice() {
        return price;
    }
    public void setPrice(double price) {
        this.price = price;
    }
}

//第二种添加方式，通过添加bean创建索引文档
TestObj obj=new TestObj();
obj.setId(2);
obj.setName("领悟书生");
obj.setContent("书生在学solr");
obj.setPrice(1024);
solr.addBean(obj);
solr.commit();

//第三种添加方式，通过添加bean列表创建多个索引文档
List<TestObj> list=new ArrayList<TestObj>();
TestObj obj=null;
for(int i=1;i<=25;i++){
    obj=new TestObj();
    obj.setId(i);
    obj.setName("领悟书生"+i);
    obj.setContent("书生在学solr"+i);
    obj.setPrice(1024);
    list.add(obj);
}
solr.addBeans(list);
solr.commit();

@Test
public void delete() throws SolrServerException, IOException {
    String urlString = "http://localhost:8983/solr";
    SolrServer solr = new HttpSolrServer(urlString);
    solr.deleteById("1");
    solr.commit();
}

@Test
public void testFind() throws SolrServerException {
    // 以后参数都是通过这个对象去构造...
    SolrQuery solrParams = new SolrQuery();
    solrParams.setQuery("name:书生");
    QueryResponse queryResponse = solr.query(solrParams);
    // 返回结果，默认只返回10条记录
    SolrDocumentList documentList = queryResponse.getResults();
    for (SolrDocument solrDocument : documentList) {
        Object id = solrDocument.get("id");
        Object name = solrDocument.get("name");
        System.out.println(id);
        System.out.println(name);
    }
}