Solr数据导入之SolrInputDocument导入数据
public static void main(String[] args) throws Exception {String zkHost = "192.168.137.200:2181,192.168.137.201:2181";
CloudSolrClient server = new CloudSolrClient(zkHost);
server.setDefaultCollection("mycollection");
addDocs(server);
query(server);
server.close();
}
public static void addDocs(CloudSolrClient server) throws Exception{
SolrInputDocument doc1 = new SolrInputDocument();
doc1.addField("id", "00003");
doc1.addField("content", "id测试");
SolrInputDocument doc2 = new SolrInputDocument();
doc2.addField("id", "00004");
doc2.addField("content", "id测试2");
Collection docs = new ArrayList();
docs.add(doc1);
docs.add(doc2);
server.add(docs);
server.commit();
}
public static void query(CloudSolrClient server) throws Exception{
SolrQuery parameters = new SolrQuery();
parameters.set("q", "*:*");
parameters.set("qt", "/select");
parameters.set("collection", "mycollection");
QueryResponse response = server.query(parameters);
//SolrDocumentList list = response.getResults();
System.out.println(response);
}
页:
[1]