上文說由DataImporter類進一步處理，DataImporter類的簡要代碼如下

/***********************************************************************

?*?Module:??DataImporter.java

?*?Author:??Administrator

?*?Purpose:?Defines?the?Class?DataImporter

?***********************************************************************/



import?java.util.*;



/**?@pdOid?6bcd8340-c69a-4f17-b886-2c530258bdb6?*/

public?class?DataImporter?{


???/**?@param?key?

????*?@param?name?

????*?@param?ctx

????*?@pdOid?f7657de8-0309-4376-895f-ee6d10261de2?*/

???DataSource?getDataSourceInstance(DataConfig.Entity?key,?String?name,?Context?ctx)?{

???DataSource?dataSrc?=?new?JdbcDataSource();

???return?DataSource;

???}

???

???/**?@param?reqParams?

????*?@param?sw

????*?@pdOid?d62e4f04-48dc-485b-bb00-be1a56117e92?*/

???void?runCmd(RequestParams?reqParams,?SolrWriter?sw)?{

???

?????doFullImport(sw,reqParams);

?????

?????doDeltaImport(sw,reqParams);

???

???}

???

???/**?@pdOid?bd4adb15-5fad-4770-a57e-3443bf440533?*/

???public?DocBuilder?docBuilder;

???

???/**?@param?writer?

????*?@param?requestParams

????*?@pdOid?8743a461-6a20-44ad-bd75-d1cdfd97ede0?*/

???public?void?doFullImport(SolrWriter?writer,?RequestParams?requestParams)?{
? ? ?docBuilder?=?new?DocBuilder(this,?writer,?propWriter,?requestParams);

? ? ?docBuilder.execute();

???}

???

???/**?@param?writer?

????*?@param?requestParams

????*?@pdOid?a43ada26-0d41-4b02-ba66-a22a4a369a46?*/

???public?void?doDeltaImport(SolrWriter?writer,?RequestParams?requestParams)?{

? ? ?docBuilder?=?new?DocBuilder(this,?writer,?propWriter,?requestParams);

? ? ?docBuilder.execute();

???}

}?

其中runCmd方法根據請求參數決定調用自身的doFullImport(sw,reqParams);?方法或doDeltaImport(sw,reqParams);方法，分別對應全部導入和增量導入

DataImporter類持有對DocBuilder?的引用，具體的InputDocument的創建由DocBuilder?類實現

?

轉載于:https://www.cnblogs.com/chenying99/archive/2012/09/09/2677726.html

總結

以上是生活随笔為你收集整理的solr dataimport 数据导入源码分析（二）的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。