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
getInputMetaData, getOutputMetaData, getQueryMetadataProvider, getSource, getTarget, initialise, process, resolveSource, setQueryMetadataProvider, setSource, 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 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–2015 MuleSoft, Inc.. All rights reserved.