public abstract class AbstractBulkUpdateMessageProcessor extends AbstractDbMessageProcessor
Modifier and Type | Field and Description |
---|---|
protected AutoGeneratedKeyStrategy |
autoGeneratedKeyStrategy |
protected BulkQueryExecutorFactory |
bulkUpdateExecutorFactory |
protected QueryResolver |
queryResolver |
protected String |
source |
protected List<QueryType> |
validQueryTypes |
dbConfigResolver
logger, muleContext, next, notificationHandler
PHASE_NAME
PROPERTY_NAME
Constructor and Description |
---|
AbstractBulkUpdateMessageProcessor(DbConfigResolver dbConfigResolver,
TransactionalAction transactionalAction,
List<QueryType> validQueryTypes,
QueryResolver queryResolver,
BulkQueryExecutorFactory bulkUpdateExecutorFactory) |
Modifier and Type | Method and Description |
---|---|
protected Iterator<Object> |
getIterator(MuleEvent muleEvent) |
String |
getSource() |
protected List<QueryType> |
getValidQueryTypes() |
void |
setAutoGeneratedKeyStrategy(AutoGeneratedKeyStrategy autoGeneratedKeyStrategy) |
void |
setSource(String source) |
executeQuery, getDebugInfo, getInputMetaData, getMessageProcessorDebugInfo, getOutputMetaData, getQueryMetadataProvider, getTarget, initialise, mustCloseConnection, process, resolveSource, setQueryMetadataProvider, setStatementStreamingResultSetCloser, setTarget, validateQueryType
addMessageProcessorPathElements, getListener, getMuleContext, isEventValid, processNext, setListener, setMuleContext, toString
getAnnotation, getAnnotations, setAnnotations
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
setListener
protected final QueryResolver queryResolver
protected final BulkQueryExecutorFactory bulkUpdateExecutorFactory
protected AutoGeneratedKeyStrategy autoGeneratedKeyStrategy
protected String source
public AbstractBulkUpdateMessageProcessor(DbConfigResolver dbConfigResolver, TransactionalAction transactionalAction, List<QueryType> validQueryTypes, QueryResolver queryResolver, BulkQueryExecutorFactory bulkUpdateExecutorFactory)
protected List<QueryType> getValidQueryTypes()
getValidQueryTypes
in class AbstractDbMessageProcessor
public String getSource()
getSource
in class AbstractDbMessageProcessor
public void setSource(String source)
setSource
in class AbstractDbMessageProcessor
public void setAutoGeneratedKeyStrategy(AutoGeneratedKeyStrategy autoGeneratedKeyStrategy)
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.