首页 > 代码库 > 6.Solr4.10.3API使用(CURD)
6.Solr4.10.3API使用(CURD)
转载请出自出处:http://www.cnblogs.com/hd3013779515/
1.在工程中引入solr-solrj-4.10.3.jar
<dependency> <groupId>org.apache.solr</groupId> <artifactId>solr-solrj</artifactId> <version>4.10.3</version> </dependency>
2.Solr的增删改查
(1) schema.xml配置修改
<field name="stu_name" type="text_ik" indexed="true" stored="true" multiValued="false" /> <field name="stu_sex" type="int" indexed="true" stored="true" multiValued="false" /> <field name="stu_address" type="text_ik" indexed="true" stored="true" multiValued="false" />
(2)Student.java
package cn.ljh.ssm.test; import org.apache.solr.client.solrj.beans.Field; public class Student{ @Field("id") private String id; @Field("stu_name") private String name; @Field("stu_sex") private int sex; @Field("stu_address") private String address; public String getId() { return id; } public void setId(String id) { this.id = id; } public String getName() { return name; } public void setName(String name) { this.name = name; } public int getSex() { return sex; } public void setSex(int sex) { this.sex = sex; } public String getAddress() { return address; } public void setAddress(String address) { this.address = address; } @Override public String toString() { return "Student [id=" + id + ", name=" + name + ", sex=" + sex + ", address=" + address + "]"; } }
(3) HttpSolrServerSingleton.java
package cn.ljh.ssm.test; import org.apache.solr.client.solrj.impl.HttpSolrServer; public class HttpSolrServerSingleton { //solr server URL指的时solr发布到web工程后的访问路径 private final static String SolrURL = "http://192.168.137.168:8080/solr"; //使用懒汉式单例中的静态内部类方式 private static class HttpSolrServerSingletonContainer{ private static HttpSolrServer instance = new HttpSolrServer( HttpSolrServerSingleton.SolrURL); } //solrServer是线程安全的,所以在使用时需要使用单例的模式,减少资源的消耗 public static HttpSolrServer getInstance(){ return HttpSolrServerSingletonContainer.instance; } }
(4) SolrHelloWorldTest.java
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 class SolrHelloWorldTest { @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 id:3"); server.commit(); } catch (Exception e) { e.printStackTrace(); } } }
6.Solr4.10.3API使用(CURD)
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。