solrlucene3.6.0源码解析（三）

public final class UpdateRequestProcessorChain implements PluginInfoInitialized
{private UpdateRequestProcessorFactory[] chain;private final SolrCore solrCore;public UpdateRequestProcessorChain(SolrCore solrCore) {this.solrCore &＃61; solrCore;}public void init(PluginInfo info) {List list &＃61; solrCore.initPlugins(info.getChildren("processor"),UpdateRequestProcessorFactory.class,null);if(list.isEmpty()){throw new RuntimeException( "updateRequestProcessorChain require at least one processor");}chain &＃61; list.toArray(new UpdateRequestProcessorFactory[list.size()]); }public UpdateRequestProcessorChain( UpdateRequestProcessorFactory[] chain , SolrCore solrCore) {this.chain &＃61; chain;this.solrCore &＃61; solrCore;}public UpdateRequestProcessor createProcessor(SolrQueryRequest req, SolrQueryResponse rsp) {UpdateRequestProcessor processor &＃61; null;UpdateRequestProcessor last &＃61; null;for (int i &＃61; chain.length-1; i>&＃61;0; i--) {processor &＃61; chain[i].getInstance(req, rsp, last);last &＃61; processor &＃61;&＃61; null ? last : processor;}return last;}public UpdateRequestProcessorFactory[] getFactories() {return chain;}
}

/*** A factory to generate an UpdateRequestProcessor for each request. * * If the factory needs access to {&＃64;link SolrCore} in initialization, it could * implement {&＃64;link SolrCoreAware}* * &＃64;since solr 1.3*/
public abstract class UpdateRequestProcessorFactory implements NamedListInitializedPlugin
{ public void init( NamedList args ){// could process the Node
}abstract public UpdateRequestProcessor getInstance( SolrQueryRequest req, SolrQueryResponse rsp, UpdateRequestProcessor next );
}

/*** This is a good place for subclassed update handlers to process the document before it is * indexed. You may wish to add/remove fields or check if the requested user is allowed to * update the given document...* * Perhaps you continue adding an error message (without indexing the document)...* perhaps you throw an error and halt indexing (remove anything already indexed??)* * By default, this just passes the request to the next processor in the chain.* * &＃64;since solr 1.3*/
public abstract class UpdateRequestProcessor {protected final Logger log &＃61; LoggerFactory.getLogger(getClass());protected final UpdateRequestProcessor next;public UpdateRequestProcessor( UpdateRequestProcessor next) {this.next &＃61; next;}public void processAdd(AddUpdateCommand cmd) throws IOException {if (next !&＃61; null) next.processAdd(cmd);}public void processDelete(DeleteUpdateCommand cmd) throws IOException {if (next !&＃61; null) next.processDelete(cmd);}public void processMergeIndexes(MergeIndexesCommand cmd) throws IOException {if (next !&＃61; null) next.processMergeIndexes(cmd);}public void processCommit(CommitUpdateCommand cmd) throws IOException{if (next !&＃61; null) next.processCommit(cmd);}/*** &＃64;since Solr 1.4*/public void processRollback(RollbackUpdateCommand cmd) throws IOException{if (next !&＃61; null) next.processRollback(cmd);}public void finish() throws IOException {if (next !&＃61; null) next.finish(); }
}

/*** Pass the command to the UpdateHandler without any modifications* * &＃64;since solr 1.3*/
public class RunUpdateProcessorFactory extends UpdateRequestProcessorFactory
{&＃64;Overridepublic UpdateRequestProcessor getInstance(SolrQueryRequest req, SolrQueryResponse rsp, UpdateRequestProcessor next) {return new RunUpdateProcessor(req, next);}
}class RunUpdateProcessor extends UpdateRequestProcessor
{private final SolrQueryRequest req;private final UpdateHandler updateHandler;public RunUpdateProcessor(SolrQueryRequest req, UpdateRequestProcessor next) {super( next );this.req &＃61; req;this.updateHandler &＃61; req.getCore().getUpdateHandler();}&＃64;Overridepublic void processAdd(AddUpdateCommand cmd) throws IOException {cmd.doc &＃61; DocumentBuilder.toDocument(cmd.getSolrInputDocument(), req.getSchema());updateHandler.addDoc(cmd);super.processAdd(cmd);}&＃64;Overridepublic void processDelete(DeleteUpdateCommand cmd) throws IOException {if( cmd.id !&＃61; null ) {updateHandler.delete(cmd);}else {updateHandler.deleteByQuery(cmd);}super.processDelete(cmd);}&＃64;Overridepublic void processMergeIndexes(MergeIndexesCommand cmd) throws IOException {updateHandler.mergeIndexes(cmd);super.processMergeIndexes(cmd);}&＃64;Overridepublic void processCommit(CommitUpdateCommand cmd) throws IOException{updateHandler.commit(cmd);super.processCommit(cmd);}/*** &＃64;since Solr 1.4*/&＃64;Overridepublic void processRollback(RollbackUpdateCommand cmd) throws IOException{updateHandler.rollback(cmd);super.processRollback(cmd);}
}

/** An index update command encapsulated in an object (Command pattern)** &＃64;version $Id: UpdateCommand.java 1065312 2011-01-30 16:08:25Z rmuir $*/public class UpdateCommand {protected String commandName;public UpdateCommand(String commandName) {this.commandName &＃61; commandName;}&＃64;Overridepublic String toString() {return commandName;}}

/*** &＃64;version $Id: AddUpdateCommand.java 1145201 2011-07-11 15:18:47Z yonik $*/
public class AddUpdateCommand extends UpdateCommand {// optional id in "internal" indexed form... if it is needed and not supplied,// it will be obtained from the doc.public String indexedId;// The Lucene document to be indexedpublic Document doc;// Higher level SolrInputDocument, normally used to construct the Lucene Document// to index.public SolrInputDocument solrDoc;public boolean allowDups;public boolean overwritePending;public boolean overwriteCommitted;public Term updateTerm;public int commitWithin &＃61; -1;/** Reset state to reuse this object with a different document in the same request */public void clear() {doc &＃61; null;solrDoc &＃61; null;indexedId &＃61; null;}public SolrInputDocument getSolrInputDocument() {return solrDoc;}public Document getLuceneDocument(IndexSchema schema) {if (doc &＃61;&＃61; null && solrDoc !&＃61; null) {// TODO?? build the doc from the SolrDocument?
}return doc; }public String getIndexedId(IndexSchema schema) {if (indexedId &＃61;&＃61; null) {SchemaField sf &＃61; schema.getUniqueKeyField();if (sf !&＃61; null) {if (doc !&＃61; null) {schema.getUniqueKeyField();Fieldable storedId &＃61; doc.getFieldable(sf.getName());indexedId &＃61; sf.getType().storedToIndexed(storedId);}if (solrDoc !&＃61; null) {SolrInputField field &＃61; solrDoc.getField(sf.getName());if (field !&＃61; null) {indexedId &＃61; sf.getType().toInternal( field.getFirstValue().toString() );}}}}return indexedId;}public String getPrintableId(IndexSchema schema) {SchemaField sf &＃61; schema.getUniqueKeyField();if (indexedId !&＃61; null && sf !&＃61; null) {return sf.getType().indexedToReadable(indexedId);}if (doc !&＃61; null) {return schema.printableUniqueKey(doc);}if (solrDoc !&＃61; null && sf !&＃61; null) {SolrInputField field &＃61; solrDoc.getField(sf.getName());if (field !&＃61; null) {return field.getFirstValue().toString();}}return "(null)";}public AddUpdateCommand() {super("add");}&＃64;Overridepublic String toString() {StringBuilder sb &＃61; new StringBuilder(commandName);sb.append(&＃39;:&＃39;);if (indexedId !&＃61;null) sb.append("id&＃61;").append(indexedId);sb.append(",allowDups&＃61;").append(allowDups);sb.append(",overwritePending&＃61;").append(overwritePending);sb.append(",overwriteCommitted&＃61;").append(overwriteCommitted);return sb.toString();}}

/*** &＃64;version $Id: DeleteUpdateCommand.java 1235304 2012-01-24 15:39:17Z janhoy $*/
public class DeleteUpdateCommand extends UpdateCommand {public String id; // external (printable) id, for delete-by-idpublic String query; // query string for delete-by-querypublic boolean fromPending;public boolean fromCommitted;public int commitWithin &＃61; -1;public DeleteUpdateCommand() {super("delete");}&＃64;Overridepublic String toString() {StringBuilder sb &＃61; new StringBuilder(commandName);sb.append(&＃39;:&＃39;);if (id!&＃61;null) sb.append("id&＃61;").append(id);else sb.append("query&＃61;&＃96;").append(query).append(&＃39;&＃96;&＃39;);sb.append(",fromPending&＃61;").append(fromPending);sb.append(",fromCommitted&＃61;").append(fromCommitted);sb.append(",commitWithin&＃61;").append(commitWithin);return sb.toString();}
}