Apache Solr - 更新数据

使用XML更新文档

以下是用于更新现有文档中字段的XML文件.将其保存在名为 update.xml 的文件中.

                 001           Raj           Malhotra           9000000000          Delhi       

正如您所看到的，写入更新数据的XML文件就像我们用来添加文档的XML文件一样.但唯一的区别是我们使用字段的 update 属性.

在我们的示例中，我们将使用上面的文档并尝试更新字段id 001 的文档.

假设XML文档存在于Solr的 bin 目录中.由于我们正在更新名为 my_core 的核心中存在的索引，因此您可以使用 post 工具进行更新，如下所示 :

[Hadoop@localhost bin]$ ./post -c my_core update.xml

执行上述命令时，您将得到以下输出.

/home/Hadoop/java/bin/java -classpath /home/Hadoop/Solr/dist/Solr-core6.2.0.jar -Dauto = yes -Dc = my_core -Ddata = files org.apache.Solr.util.SimplePostTool update.xml SimplePostTool version 5.0.0 Posting files to [base] url http://localhost:8983/Solr/my_core/update... Entering auto mode. File endings considered are xml,json,jsonl,csv,pdf,doc,docx,ppt,pptx,xls,xlsx,odt,odp,ods,ott,otp,ots,rtf,htm,html,txt,log POSTing file update.xml (application/xml) to [base] 1 files indexed. COMMITting Solr index changes to http://localhost:8983/Solr/my_core/update... Time spent: 0:00:00.159

验证

访问Apache Solr Web界面的主页，选择核心 my_core .尝试通过在文本区域 q 中传递查询":"来检索所有文档并执行查询.执行时，您可以观察到文档已更新.

使用Java更新文档(客户端API)

以下是将文档添加到Apache Solr索引的Java程序.将此代码保存在名为 UpdatingDocument.java 的文件中.

import java.io.IOException;  import org.apache.Solr.client.Solrj.SolrClient; import org.apache.Solr.client.Solrj.SolrServerException; import org.apache.Solr.client.Solrj.impl.HttpSolrClient; import org.apache.Solr.client.Solrj.request.UpdateRequest; import org.apache.Solr.client.Solrj.response.UpdateResponse;import org.apache.Solr.common.SolrInputDocument;  public class UpdatingDocument {    public static void main(String args[]) throws SolrServerException, IOException {       //Preparing the Solr client       String urlString = "http://localhost:8983/Solr/my_core";       SolrClient Solr = new HttpSolrClient.Builder(urlString).build();               //Preparing the Solr document       SolrInputDocument doc = new SolrInputDocument();          UpdateRequest updateRequest = new UpdateRequest();        updateRequest.setAction( UpdateRequest.ACTION.COMMIT, false, false);          SolrInputDocument myDocumentInstantlycommited = new SolrInputDocument();              myDocumentInstantlycommited.addField("id", "002");       myDocumentInstantlycommited.addField("name", "Rahman");       myDocumentInstantlycommited.addField("age","27");       myDocumentInstantlycommited.addField("addr","hyderabad");             updateRequest.add( myDocumentInstantlycommited);        UpdateResponse rsp = updateRequest.process(Solr);       System.out.println("Documents Updated");    } }

通过在终端中执行以下命令来编译上述代码 :

[Hadoop@localhost bin]$ javac UpdatingDocument [Hadoop@localhost bin]$ java UpdatingDocument

在执行上述命令时，您将获得以下输出.

Documents updated