public class SelectMessageProcessor extends AbstractSingleQueryDbMessageProcessor
MuleEvent
being processed.dbConfigResolver
logger, muleContext, next, notificationHandler
PHASE_NAME
PROPERTY_NAME
Constructor and Description |
---|
SelectMessageProcessor(DbConfigResolver dbConfigResolver,
QueryResolver queryResolver,
QueryExecutorFactory queryExecutorFactory,
TransactionalAction transactionalAction,
boolean streaming) |
Modifier and Type | Method and Description |
---|---|
protected Object |
doExecuteQuery(DbConnection connection,
Query query) |
protected List<QueryType> |
getValidQueryTypes() |
protected boolean |
mustCloseConnection() |
executeQuery, getMessageProcessorDebugInfo
getDebugInfo, getInputMetaData, getOutputMetaData, getQueryMetadataProvider, getSource, getTarget, initialise, process, resolveSource, setQueryMetadataProvider, setSource, 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
public SelectMessageProcessor(DbConfigResolver dbConfigResolver, QueryResolver queryResolver, QueryExecutorFactory queryExecutorFactory, TransactionalAction transactionalAction, boolean streaming)
protected boolean mustCloseConnection()
mustCloseConnection
in class AbstractDbMessageProcessor
protected List<QueryType> getValidQueryTypes()
getValidQueryTypes
in class AbstractDbMessageProcessor
protected Object doExecuteQuery(DbConnection connection, Query query) throws SQLException
doExecuteQuery
in class AbstractSingleQueryDbMessageProcessor
SQLException
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.