📅  最后修改于: 2020-12-02 05:46:37             🧑  作者: Mango
以下是用于更新现有文档中的字段的XML文件。将其保存在名为update.xml的文件中。
001
Raj
Malhotra
9000000000
Delhi
如您所见,编写用于更新数据的XML文件就像我们用来添加文档的XML文件一样。但是唯一的区别是我们使用字段的update属性。
在我们的示例中,我们将使用上面的文档,并尝试使用id 001更新文档的字段。
假设XML文档存在于Solr的bin目录中。由于我们正在更新名为my_core的内核中存在的索引,因此可以使用发布工具进行更新,如下所示:
[Hadoop@localhost bin]$ ./post -c my_core update.xml
执行上述命令后,您将获得以下输出。
/home/Hadoop/java/bin/java -classpath /home/Hadoop/Solr/dist/Solr-core
6.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中传递查询“:”来检索所有文档,然后执行查询。执行时,您可以观察到文档已更新。
以下是将文档添加到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