6.Solr4.10.3API使用(CURD)

xuanhao

package cn.ljh.ssm.test;　　

　　

import java.io.IOException;　　

import java.util.ArrayList;　　

import java.util.List;　　

import java.util.Random;　　

　　

import org.apache.solr.client.solrj.SolrQuery;　　

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>　　@Test
public void testAdd(){try {　　HttpSolrServer server
= HttpSolrServerSingleton.getInstance();//先删除所有数据　　server.deleteByQuery("*:*");
　　SolrInputDocument doc = new SolrInputDocument();
　　doc.addField("id",String.valueOf(1));
　　doc.addField("name","apple phone");
　　doc.addField("price","6000");
　　server.add(doc);
　　SolrInputDocument doc2 = new SolrInputDocument();
　　doc2.addField("id",String.valueOf(2));
　　doc2.addField("name","huawei phone");
　　doc2.addField("price","1000");
　　server.add(doc2);
　　SolrInputDocument doc3 = new SolrInputDocument();
　　doc3.addField("id",String.valueOf(3));
　　doc3.addField("name","mi phone");
　　doc3.addField("price","2000");
　　server.add(doc3);
　　SolrInputDocument doc5 = new SolrInputDocument();
　　doc5.addField("id",String.valueOf(15));
　　doc5.addField("name","mi phone02");
　　doc5.addField("price","2000");
　　server.add(doc5);
　　Random random = new Random();
　　for (int i = 0; i < 10; i++) {
　　SolrInputDocument doc4 = new SolrInputDocument();
　　doc4.addField("id",i+4);
　　doc4.addField("name","phone"+i);
　　doc4.addField("price",random.nextInt(2000));
　　server.add(doc4);
　　}
　　server.commit();//提交，将所有更新提交到索引中
　　} catch (SolrServerException e) {
　　e.printStackTrace();
　　} catch (IOException e) {
　　e.printStackTrace();
　　}
　　}
　　/**
　　* 使用POJO添加document
　　*/
　　@Test
　　public void testAddStudent(){
　　try {
　　HttpSolrServer server = HttpSolrServerSingleton.getInstance();
　　List<Student> studentList = new ArrayList<Student>();
　　Student stu1 = new Student();
　　stu1.setId("103");
　　stu1.setName("张小强");
　　stu1.setSex(1);
　　stu1.setAddress("北京市海淀区知春路");
　　studentList.add(stu1);
　　stu1 = new Student();
　　stu1.setId("104");
　　stu1.setName("刘小米");
　　stu1.setSex(0);
　　stu1.setAddress("北京市海淀区北苑路");
　　studentList.add(stu1);
　　server.addBeans(studentList);
　　server.commit();
　　} catch (SolrServerException e) {
　　e.printStackTrace();
　　} catch (IOException e) {
　　e.printStackTrace();
　　}
　　}
　　@Test
　　public void testQueryStudent(){
　　try {
　　HttpSolrServer server = HttpSolrServerSingleton.getInstance();
　　String strQuery = "stu_name:小米";//q表示查询的内容
　　SolrQuery query = new SolrQuery(strQuery);
　　QueryResponse resp = server.query(query);
　　SolrDocumentList sdList = resp.getResults();
　　long totalResults = sdList.getNumFound();//命中的总记录数
　　
            
　　System.out.println("totalResults-->"+totalResults);
　　for(SolrDocument sd:sdList){
　　Student student = server.getBinder().getBean(Student.class, sd);
　　System.out.println(student);
　　}
　　} catch (SolrServerException e) {
　　e.printStackTrace();
　　}
　　}
　　@Test
　　public void testQuery(){
　　try {
　　HttpSolrServer server = HttpSolrServerSingleton.getInstance();
　　String strQuery = "name:apple";//q表示查询的内容
　　SolrQuery query = new SolrQuery();
　　query.set("q",strQuery);
　　QueryResponse resp = server.query(query);
　　SolrDocumentList sdList = resp.getResults();
　　long totalResults = sdList.getNumFound();//命中的总记录数
　　
            
　　System.out.println("totalResults-->"+totalResults);
　　for(SolrDocument sd:sdList){
　　System.out.print("id:" + sd.getFieldValue("id") +
　　" " + "name:" + sd.getFieldValue("name") +
　　" " + "price:" + sd.getFieldValue("price"));
　　}
　　} catch (SolrServerException e) {
　　e.printStackTrace();
　　}
　　}
　　@Test
　　public void testDelete(){
　　try {
　　HttpSolrServer server = HttpSolrServerSingleton.getInstance();
　　server.deleteById("1");

　　server.deleteByQuery("id:2>　　server.commit();
　　} catch (Exception e) {
　　e.printStackTrace();
　　}
　　}
　　
}