solr(四)solrj - how to delete/query documents
solr(4)solrj - how to delete/query documents
solr(4)solrj - how to delete/query documents
1. Delete the document in index files
@Test
public void remove() {
try {
query("id:1");
//删除id为1的索引
this.embeddedSolrServer.deleteById("1");
this.embeddedSolrServer.commit();
query("id:1");
query("id:3 id:2");
//根据id集合，删除多个索引
List<String> ids = new ArrayList<String>();
ids.add("2");
ids.add("3");
this.embeddedSolrServer.deleteById(ids);
this.embeddedSolrServer.commit(true, true);
query("id:3 id:2");
//删除查询到的索引信息
this.embeddedSolrServer.deleteByQuery("id:4 id:6");
this.embeddedSolrServer.commit(true, true);
queryAll();
} catch (SolrServerException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
2. query all the documents in index
@Test
public void queryAll() {
ModifiableSolrParams params = new ModifiableSolrParams();
// 查询关键词，*:*代表所有属性、所有值，即所有index
params.set("q", "*:*");
// 分页，start=0就是从0开始，，rows=5当前返回5条记录，第二页就是变化start这个值为5就可以了。
params.set("start", 0);
params.set("rows", Integer.MAX_VALUE);
// 排序，，如果按照id 排序，，那么将score desc 改成 id desc(or asc)
//params.set("sort", "score desc");
params.set("sort", "id asc");
// 返回信息 * 为全部 这里是全部加上score，如果不加下面就不能使用score
params.set("fl", "*,score");
try {
QueryResponse response = embeddedSolrServer.query(params);
SolrDocumentList list = response.getResults();
for (int i = 0; i < list.size(); i++) {
SolrDocument docTmp = list.get(i);
System.out.print(docTmp.get("name") + "------");
System.out.println(docTmp);
}
} catch (SolrServerException e) {
e.printStackTrace();
}
}
3. System method for solrj
@Test
public void systemMethod() {
System.out.println(solrServer.getBinder());
try {
System.out.println(solrServer.optimize());// 合并索引文件，可以优化索引、提供性能，但需要一定的时间
System.out.println(solrServer.ping());// ping服务器是否连接成功
} catch (SolrServerException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
4. Rollback method
@Test
public void rollback() {
try {
Product p299 = new Product();
p299.setId("299");
p299.setName("add bean index199");
p299.setManu("index bean manu199");
p299.setCat(new String[] { "a199", "b199" });
UpdateResponse response = solrServer.addBean(p299);
System.out.println("response: " + response);
// 回滚掉之前的操作，rollback addBean operation
System.out.println("rollback: " + solrServer.rollback());
// 提交操作，提交后无法回滚之前操作；发现addBean没有成功添加索引
System.out.println("commit: " + solrServer.commit());
queryAll();
} catch (SolrServerException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
5. Case Query
@Test
public void queryCase() {
// AND 并且
SolrQuery params = new SolrQuery("name:apple AND manu:inc");
// OR 或者
params.setQuery("name:apple OR manu:apache");
// 空格 等同于 OR
params.setQuery("name:server manu:dell");
// 查询name包含solr apple
params.setQuery("name:solr,apple");
// manu不包含inc
params.setQuery("name:solr,apple NOT manu:inc");
// 50 <= price <= 200
params.setQuery("price:[50 TO 200]");
params.setQuery("popularity:[5 TO 6]");
// 50 <= price <= 200 AND 5 <= popularity <= 6
params.setQuery("price:[50 TO 200] AND popularity:[5 TO 6]");
params.setQuery("price:[50 TO 200] OR popularity:[5 TO 6]");
// 过滤器查询，可以提高性能, filter 类似多个条件组合，如and
// params.addFilterQuery("id:VA902B");
// params.addFilterQuery("price:[50 TO 200]");
// params.addFilterQuery("popularity:[* TO 5]");
// params.addFilterQuery("weight:*");
// 0 < popularity < 6 ，没有等于
// params.addFilterQuery("popularity:{0 TO 6}");
// 排序
params.addSortField("id", ORDER.asc);
// 分页：start开始页，rows每页显示记录条数
// params.add("start", "0");
// params.add("rows", "200");
// params.setStart(0);
// params.setRows(200);
// 设置高亮
params.setHighlight(true); // 开启高亮组件
params.addHighlightField("name");// 高亮字段
params.setHighlightSimplePre("<font color='red'>");
// 标记，高亮关键字前缀
params.setHighlightSimplePost("</font>");
// 后缀
params.setHighlightSnippets(1);// 结果分片数，默认为1
params.setHighlightFragsize(1000);// 每个分片的最大长度，默认为100
// 分片信息
params.setFacet(true).setFacetMinCount(1).setFacetLimit(5)// 段
.addFacetField("name")// 分片字段
.addFacetField("inStock");
try {
QueryResponse response = solrServer.query(params);
List<Product> products = response.getBeans(Product.class);
for (int i = 0; i < products.size(); i++) {
System.out.println(products.get(i));
}
// 输出查询结果集
SolrDocumentList list = response.getResults();
System.out.println("query result nums: " + list.getNumFound());
for (int i = 0; i < list.size(); i++) {
System.out.println(list.get(i));
}
// 输出分片信息
List<FacetField> facets = response.getFacetFields();
for (FacetField facet : facets) {
System.out.println(facet);
List<Count> facetCounts = facet.getValues();
for (FacetField.Count count : facetCounts) {
System.out.println(count.getName() + ": "
+ count.getCount());
}
}
} catch (SolrServerException e) {
e.printStackTrace();
}
}
6. Facet Search
@Test
public void facetQueryCase() {
SolrQuery params = new SolrQuery("*:*");
//排序
params.addSortField("id", ORDER.asc);
params.setStart(0);
params.setRows(200);
//Facet为solr中的层次分类查询
//分片信息
params.setFacet(true)
.setQuery("*:*")
.setFacetMinCount(1)
.setFacetLimit(5)//段
//.setFacetPrefix("electronics", "cat")
.setFacetPrefix("cor")//查询manu、name中关键字前缀是cor的
.addFacetField("manu")
.addFacetField("name");//分片字段
try {
QueryResponse response = solrServer.query(params);
//输出查询结果集
SolrDocumentList list = response.getResults();
System.out.println("Query result nums: " + list.getNumFound());
for (int i = 0; i < list.size(); i++) {
System.out.println(list.get(i));
}
System.out.println("All facet filed result: ");
//输出分片信息
List<FacetField> facets = response.getFacetFields();
for (FacetField facet : facets) {
System.out.println(facet);
List<Count> facetCounts = facet.getValues();
for (FacetField.Count count : facetCounts) {
//关键字 - 出现次数
System.out.println(count.getName() + ": " + count.getCount());
}
}
System.out.println("Search facet [name] filed result: ");
//输出分片信息
FacetField facetField = response.getFacetField("name");
List<Count> facetFields = facetField.getValues();
for (Count count : facetFields) {
//关键字 - 出现次数
System.out.println(count.getName() + ": " + count.getCount());
}
} catch (SolrServerException e) {
e.printStackTrace();
}
}
7. hight the results
@Test
public void queryHight() {
SolrQuery params = new SolrQuery();
params.setQuery("manu:SolrInputDocuments");
params.setHighlight(true);
params.addHighlightField("manu");// 高亮字段
params.setHighlightSimplePre("<font color='red'>");
// 标记，高亮关键字前缀
params.setHighlightSimplePost("</font>");
// 后缀
params.setHighlightSnippets(1);// 结果分片数，默认为1
params.setHighlightFragsize(1000);// 每个分片的最大长度，默认为100
try {
QueryResponse response = solrServer.query(params);
// 输出查询结果集
SolrDocumentList list = response.getResults();
System.out.println("query result nums: " + list.getNumFound());
for (int i = 0; i < list.size(); i++) {
SolrDocument doc = list.get(i);
String id = (String) doc.getFieldValue("id");
if (response.getHighlighting().get(id) != null) {
List<String> highlightSnippets = response
.getHighlighting().get(id).get("manu");
System.out.println("hightlight=" + highlightSnippets);
}
}
} catch (SolrServerException e) {
e.printStackTrace();
}
}
references:
http://www.blogjava.net/hoojo/archive/2011/10/21/361747.html
http://wiki.apache.org/solr/Solrj
solr(4)solrj - how to delete/query documents
1. Delete the document in index files
@Test
public void remove() {
try {
query("id:1");
//删除id为1的索引
this.embeddedSolrServer.deleteById("1");
this.embeddedSolrServer.commit();
query("id:1");
query("id:3 id:2");
//根据id集合，删除多个索引
List<String> ids = new ArrayList<String>();
ids.add("2");
ids.add("3");
this.embeddedSolrServer.deleteById(ids);
this.embeddedSolrServer.commit(true, true);
query("id:3 id:2");
//删除查询到的索引信息
this.embeddedSolrServer.deleteByQuery("id:4 id:6");
this.embeddedSolrServer.commit(true, true);
queryAll();
} catch (SolrServerException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
2. query all the documents in index
@Test
public void queryAll() {
ModifiableSolrParams params = new ModifiableSolrParams();
// 查询关键词，*:*代表所有属性、所有值，即所有index
params.set("q", "*:*");
// 分页，start=0就是从0开始，，rows=5当前返回5条记录，第二页就是变化start这个值为5就可以了。
params.set("start", 0);
params.set("rows", Integer.MAX_VALUE);
// 排序，，如果按照id 排序，，那么将score desc 改成 id desc(or asc)
//params.set("sort", "score desc");
params.set("sort", "id asc");
// 返回信息 * 为全部 这里是全部加上score，如果不加下面就不能使用score
params.set("fl", "*,score");
try {
QueryResponse response = embeddedSolrServer.query(params);
SolrDocumentList list = response.getResults();
for (int i = 0; i < list.size(); i++) {
SolrDocument docTmp = list.get(i);
System.out.print(docTmp.get("name") + "------");
System.out.println(docTmp);
}
} catch (SolrServerException e) {
e.printStackTrace();
}
}
3. System method for solrj
@Test
public void systemMethod() {
System.out.println(solrServer.getBinder());
try {
System.out.println(solrServer.optimize());// 合并索引文件，可以优化索引、提供性能，但需要一定的时间
System.out.println(solrServer.ping());// ping服务器是否连接成功
} catch (SolrServerException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
4. Rollback method
@Test
public void rollback() {
try {
Product p299 = new Product();
p299.setId("299");
p299.setName("add bean index199");
p299.setManu("index bean manu199");
p299.setCat(new String[] { "a199", "b199" });
UpdateResponse response = solrServer.addBean(p299);
System.out.println("response: " + response);
// 回滚掉之前的操作，rollback addBean operation
System.out.println("rollback: " + solrServer.rollback());
// 提交操作，提交后无法回滚之前操作；发现addBean没有成功添加索引
System.out.println("commit: " + solrServer.commit());
queryAll();
} catch (SolrServerException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
5. Case Query
@Test
public void queryCase() {
// AND 并且
SolrQuery params = new SolrQuery("name:apple AND manu:inc");
// OR 或者
params.setQuery("name:apple OR manu:apache");
// 空格 等同于 OR
params.setQuery("name:server manu:dell");
// 查询name包含solr apple
params.setQuery("name:solr,apple");
// manu不包含inc
params.setQuery("name:solr,apple NOT manu:inc");
// 50 <= price <= 200
params.setQuery("price:[50 TO 200]");
params.setQuery("popularity:[5 TO 6]");
// 50 <= price <= 200 AND 5 <= popularity <= 6
params.setQuery("price:[50 TO 200] AND popularity:[5 TO 6]");
params.setQuery("price:[50 TO 200] OR popularity:[5 TO 6]");
// 过滤器查询，可以提高性能, filter 类似多个条件组合，如and
// params.addFilterQuery("id:VA902B");
// params.addFilterQuery("price:[50 TO 200]");
// params.addFilterQuery("popularity:[* TO 5]");
// params.addFilterQuery("weight:*");
// 0 < popularity < 6 ，没有等于
// params.addFilterQuery("popularity:{0 TO 6}");
// 排序
params.addSortField("id", ORDER.asc);
// 分页：start开始页，rows每页显示记录条数
// params.add("start", "0");
// params.add("rows", "200");
// params.setStart(0);
// params.setRows(200);
// 设置高亮
params.setHighlight(true); // 开启高亮组件
params.addHighlightField("name");// 高亮字段
params.setHighlightSimplePre("<font color='red'>");
// 标记，高亮关键字前缀
params.setHighlightSimplePost("</font>");
// 后缀
params.setHighlightSnippets(1);// 结果分片数，默认为1
params.setHighlightFragsize(1000);// 每个分片的最大长度，默认为100
// 分片信息
params.setFacet(true).setFacetMinCount(1).setFacetLimit(5)// 段
.addFacetField("name")// 分片字段
.addFacetField("inStock");
try {
QueryResponse response = solrServer.query(params);
List<Product> products = response.getBeans(Product.class);
for (int i = 0; i < products.size(); i++) {
System.out.println(products.get(i));
}
// 输出查询结果集
SolrDocumentList list = response.getResults();
System.out.println("query result nums: " + list.getNumFound());
for (int i = 0; i < list.size(); i++) {
System.out.println(list.get(i));
}
// 输出分片信息
List<FacetField> facets = response.getFacetFields();
for (FacetField facet : facets) {
System.out.println(facet);
List<Count> facetCounts = facet.getValues();
for (FacetField.Count count : facetCounts) {
System.out.println(count.getName() + ": "
+ count.getCount());
}
}
} catch (SolrServerException e) {
e.printStackTrace();
}
}
6. Facet Search
@Test
public void facetQueryCase() {
SolrQuery params = new SolrQuery("*:*");
//排序
params.addSortField("id", ORDER.asc);
params.setStart(0);
params.setRows(200);
//Facet为solr中的层次分类查询
//分片信息
params.setFacet(true)
.setQuery("*:*")
.setFacetMinCount(1)
.setFacetLimit(5)//段
//.setFacetPrefix("electronics", "cat")
.setFacetPrefix("cor")//查询manu、name中关键字前缀是cor的
.addFacetField("manu")
.addFacetField("name");//分片字段
try {
QueryResponse response = solrServer.query(params);
//输出查询结果集
SolrDocumentList list = response.getResults();
System.out.println("Query result nums: " + list.getNumFound());
for (int i = 0; i < list.size(); i++) {
System.out.println(list.get(i));
}
System.out.println("All facet filed result: ");
//输出分片信息
List<FacetField> facets = response.getFacetFields();
for (FacetField facet : facets) {
System.out.println(facet);
List<Count> facetCounts = facet.getValues();
for (FacetField.Count count : facetCounts) {
//关键字 - 出现次数
System.out.println(count.getName() + ": " + count.getCount());
}
}
System.out.println("Search facet [name] filed result: ");
//输出分片信息
FacetField facetField = response.getFacetField("name");
List<Count> facetFields = facetField.getValues();
for (Count count : facetFields) {
//关键字 - 出现次数
System.out.println(count.getName() + ": " + count.getCount());
}
} catch (SolrServerException e) {
e.printStackTrace();
}
}
7. hight the results
@Test
public void queryHight() {
SolrQuery params = new SolrQuery();
params.setQuery("manu:SolrInputDocuments");
params.setHighlight(true);
params.addHighlightField("manu");// 高亮字段
params.setHighlightSimplePre("<font color='red'>");
// 标记，高亮关键字前缀
params.setHighlightSimplePost("</font>");
// 后缀
params.setHighlightSnippets(1);// 结果分片数，默认为1
params.setHighlightFragsize(1000);// 每个分片的最大长度，默认为100
try {
QueryResponse response = solrServer.query(params);
// 输出查询结果集
SolrDocumentList list = response.getResults();
System.out.println("query result nums: " + list.getNumFound());
for (int i = 0; i < list.size(); i++) {
SolrDocument doc = list.get(i);
String id = (String) doc.getFieldValue("id");
if (response.getHighlighting().get(id) != null) {
List<String> highlightSnippets = response
.getHighlighting().get(id).get("manu");
System.out.println("hightlight=" + highlightSnippets);
}
}
} catch (SolrServerException e) {
e.printStackTrace();
}
}
references:
http://www.blogjava.net/hoojo/archive/2011/10/21/361747.html
http://wiki.apache.org/solr/Solrj