org.mule.module.db.internal.processor
Class ExecuteDdlMessageProcessor

java.lang.Object
  org.mule.processor.AbstractInterceptingMessageProcessorBase
      org.mule.processor.AbstractInterceptingMessageProcessor
          org.mule.module.db.internal.processor.AbstractDbMessageProcessor
              org.mule.module.db.internal.processor.AbstractSingleQueryDbMessageProcessor
                  org.mule.module.db.internal.processor.ExecuteDdlMessageProcessor

All Implemented Interfaces:

AnnotatedObject, MuleContextAware, Initialisable, InterceptingMessageProcessor, MessageProcessor, MessageProcessorContainer, MessageSource, org.mule.common.Capability, org.mule.common.metadata.MetaDataDescriptor, org.mule.common.metadata.OperationMetaDataEnabled

public class ExecuteDdlMessageProcessor
extends AbstractSingleQueryDbMessageProcessor

Executes a DDL query on a database

Both database and bulk query are resolved, if required, using the MuleEvent being processed.

Field Summary

Fields inherited from class org.mule.module.db.internal.processor.AbstractDbMessageProcessor

dbConfigResolver

Fields inherited from class org.mule.processor.AbstractInterceptingMessageProcessorBase

logger, muleContext, next, notificationHandler

Fields inherited from interface org.mule.api.lifecycle.Initialisable

PHASE_NAME

Fields inherited from interface org.mule.api.AnnotatedObject

PROPERTY_NAME

Constructor Summary

ExecuteDdlMessageProcessor(DbConfigResolver dbConfigResolver, QueryResolver queryResolver, QueryExecutorFactory queryExecutorFactory, TransactionalAction transactionalAction)

Method Summary

protected Object	doExecuteQuery(DbConnection connection, Query query)
protected List<QueryType>	getValidQueryTypes()

Methods inherited from class org.mule.module.db.internal.processor.AbstractSingleQueryDbMessageProcessor

executeQuery

Methods inherited from class org.mule.module.db.internal.processor.AbstractDbMessageProcessor

getInputMetaData, getOutputMetaData, getQueryMetadataProvider, getSource, getTarget, initialise, mustCloseConnection, process, resolveSource, setQueryMetadataProvider, setSource, setTarget, validateQueryType

Methods inherited from class org.mule.processor.AbstractInterceptingMessageProcessorBase

addMessageProcessorPathElements, getAnnotation, getAnnotations, getListener, getMuleContext, isEventValid, processNext, setAnnotations, setListener, setMuleContext, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.mule.api.source.MessageSource

setListener

Constructor Detail

ExecuteDdlMessageProcessor

public ExecuteDdlMessageProcessor(DbConfigResolver dbConfigResolver,
                                  QueryResolver queryResolver,
                                  QueryExecutorFactory queryExecutorFactory,
                                  TransactionalAction transactionalAction)

Method Detail

getValidQueryTypes

protected List<QueryType> getValidQueryTypes()

Specified by:

getValidQueryTypes in class AbstractDbMessageProcessor

doExecuteQuery

protected Object doExecuteQuery(DbConnection connection,
                                Query query)
                         throws SQLException

Specified by:

doExecuteQuery in class AbstractSingleQueryDbMessageProcessor

Throws:

SQLException