public class PreparedBulkUpdateMessageProcessor extends AbstractDbMessageProcessor
MuleEvent
being processed.dbConfigResolver
logger, muleContext, next, notificationHandler
PHASE_NAME
PROPERTY_NAME
Constructor and Description |
---|
PreparedBulkUpdateMessageProcessor(DbConfigResolver dbConfigResolver,
QueryResolver queryResolver,
BulkQueryExecutorFactory bulkUpdateExecutorFactory,
TransactionalAction transactionalAction,
List<QueryType> validQueryTypes) |
Modifier and Type | Method and Description |
---|---|
protected Object |
executeQuery(DbConnection connection,
MuleEvent muleEvent) |
String |
getSource() |
protected List<QueryType> |
getValidQueryTypes() |
void |
setAutoGeneratedKeyStrategy(AutoGeneratedKeyStrategy autoGeneratedKeyStrategy) |
void |
setSource(String source) |
getInputMetaData, getOutputMetaData, getQueryMetadataProvider, getTarget, initialise, mustCloseConnection, process, resolveSource, setQueryMetadataProvider, setTarget, validateQueryType
addMessageProcessorPathElements, getAnnotation, getAnnotations, getListener, getMuleContext, isEventValid, processNext, setAnnotations, setListener, setMuleContext, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
setListener
public PreparedBulkUpdateMessageProcessor(DbConfigResolver dbConfigResolver, QueryResolver queryResolver, BulkQueryExecutorFactory bulkUpdateExecutorFactory, TransactionalAction transactionalAction, List<QueryType> validQueryTypes)
protected Object executeQuery(DbConnection connection, MuleEvent muleEvent) throws SQLException
executeQuery
in class AbstractDbMessageProcessor
SQLException
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–2015 MuleSoft, Inc.. All rights reserved.