论坛 › solr › Java中Solr集群的测试

wss1051 发表于 2017-12-19 13:33:46

Java中Solr集群的测试

import org.apache.solr.client.solrj.impl.CloudSolrServer;　　

import org.apache.solr.common.SolrInputDocument;　　

import org.junit.Test;　　

　　

public>
　　@Test
public void testAddDocument() throws Exception {//创建一个和solr集群的连接　　String zkHost = "192.168.242.135:2181,192.168.242.135:2182,192.168.242.135:2183";
　　CloudSolrServer solrServer = new CloudSolrServer(zkHost);
　　//指定默认的collection
　　solrServer.setDefaultCollection("collection2");
　　//创建一个文档对象
　　SolrInputDocument document = new SolrInputDocument();
　　//向文档中添加域
　　document.addField("id", "test001");
　　document.addField("item_title", "测试商品");
　　//把文档添加到索引库
　　
      solrServer.add(document);
　　//提交
　　
      solrServer.commit();
　　}
　　@Test
　　public void deleteDoucment()throws Exception {
　　//创建一个和solr集群的连接
　　String zkHost = "192.168.242.135:2181,192.168.242.135:2182,192.168.242.135:2183";
　　CloudSolrServer solrServer = new CloudSolrServer(zkHost);
　　//指定默认的collection
　　solrServer.setDefaultCollection("collection2");
　　solrServer.deleteByQuery("*:*");
　　solrServer.commit();
　　}
　　
}

查看完整版本: Java中Solr集群的测试