org.mule.providers.jdbc
Class JdbcConnector
java.lang.Object
org.mule.providers.AbstractConnector
org.mule.providers.AbstractServiceEnabledConnector
org.mule.providers.jdbc.JdbcConnector
- All Implemented Interfaces:
- Disposable, ExceptionListener, Initialisable, UMOConnectable, UMOConnector
- public class JdbcConnector
- extends AbstractServiceEnabledConnector
| Fields inherited from class org.mule.providers.AbstractConnector |
connected, connecting, createDispatcherPerRequest, createMultipleTransactedReceivers, defaultInboundTransformer, defaultOutboundTransformer, defaultResponseTransformer, dispatcherFactory, dispatchers, disposed, disposing, exceptionListener, initialised, logger, name, receivers, serverSide, sessionHandler, started, startOnConnect |
| Methods inherited from class org.mule.providers.AbstractConnector |
checkDisposed, connect, createDispatcher, destroyReceiver, disconnect, dispose, disposeDispatchers, disposeReceivers, doConnect, doDisconnect, doDispose, doStart, doStop, exceptionThrown, fireNotification, getConnectEventId, getConnectionDescription, getConnectionStrategy, getDefaultInboundTransformer, getDefaultOutboundTransformer, getDefaultResponseTransformer, getDispatcher, getDispatcher, getDispatcherFactory, getDispatchers, getDispatcherThreadingProfile, getExceptionListener, getName, getReceiver, getReceiver, getReceiverKey, getReceivers, getReceivers, getReceiverThreadingProfile, getReplyToHandler, getSessionHandler, getSupportedProtocols, handleException, handleWorkException, initialise, isConnected, isCreateDispatcherPerRequest, isCreateMultipleTransactedReceivers, isDisposed, isDisposing, isEnableMessageEvents, isRemoteSyncEnabled, isServerSide, isStarted, isUseSingleDispatcherThreadPool, isUseSingleReceiverThreadPool, lookupDispatcher, lookupReceiver, registerListener, registerSupportedProtocol, registerSupportedProtocolWithotPrefix, setConnectionStrategy, setCreateDispatcherPerRequest, setCreateMultipleTransactedReceivers, setDefaultInboundTransformer, setDefaultOutboundTransformer, setDefaultResponseTransformer, setDispatcherFactory, setDispatcherThreadingProfile, setEnableMessageEvents, setExceptionListener, setName, setReceiverThreadingProfile, setServerSide, setSessionHandler, setSupportedProtocols, setUseSingleDispatcherThreadPool, setUseSingleReceiverThreadPool, startConnector, stopConnector, supportsProtocol, unregisterListener, unregisterSupportedProtocol, workAccepted, workCompleted, workRejected, workStarted |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
PROPERTY_POLLING_FREQUENCY
public static final String PROPERTY_POLLING_FREQUENCY
- See Also:
- Constant Field Values
DEFAULT_POLLING_FREQUENCY
public static final long DEFAULT_POLLING_FREQUENCY
- See Also:
- Constant Field Values
pollingFrequency
protected long pollingFrequency
dataSource
protected DataSource dataSource
dataSourceJndiName
protected String dataSourceJndiName
jndiContext
protected Context jndiContext
jndiInitialFactory
protected String jndiInitialFactory
jndiProviderUrl
protected String jndiProviderUrl
providerProperties
protected Map providerProperties
queries
protected Map queries
resultSetHandler
protected String resultSetHandler
queryRunner
protected String queryRunner
queryValueExtractors
protected Set queryValueExtractors
propertyExtractors
protected Set propertyExtractors
JdbcConnector
public JdbcConnector()
getProtocol
public String getProtocol()
- Specified by:
getProtocol in interface UMOConnector- Specified by:
getProtocol in class AbstractConnector
createReceiver
public UMOMessageReceiver createReceiver(UMOComponent component,
UMOEndpoint endpoint)
throws Exception
- Overrides:
createReceiver in class AbstractServiceEnabledConnector
- Throws:
Exception
initJndiContext
protected void initJndiContext()
throws NamingException
- Throws:
NamingException
createDataSource
protected void createDataSource()
throws InitialisationException,
NamingException
- Throws:
InitialisationException
NamingException
doInitialise
public void doInitialise()
throws InitialisationException
- Overrides:
doInitialise in class AbstractServiceEnabledConnector
- Throws:
InitialisationException
getReadAndAckStatements
public String[] getReadAndAckStatements(UMOImmutableEndpoint endpoint)
getQuery
public String getQuery(UMOImmutableEndpoint endpoint,
String stmt)
getDataSource
public DataSource getDataSource()
- Returns:
- Returns the dataSource.
setDataSource
public void setDataSource(DataSource dataSource)
- Parameters:
dataSource - The dataSource to set.
getPollingFrequency
public long getPollingFrequency()
- Returns:
- Returns the pollingFrequency.
setPollingFrequency
public void setPollingFrequency(long pollingFrequency)
- Parameters:
pollingFrequency - The pollingFrequency to set.
getQueries
public Map getQueries()
- Returns:
- Returns the queries.
setQueries
public void setQueries(Map queries)
- Parameters:
queries - The queries to set.
getDataSourceJndiName
public String getDataSourceJndiName()
- Returns:
- Returns the dataSourceJndiName.
setDataSourceJndiName
public void setDataSourceJndiName(String dataSourceJndiName)
- Parameters:
dataSourceJndiName - The dataSourceJndiName to set.
getJndiContext
public Context getJndiContext()
- Returns:
- Returns the jndiContext.
setJndiContext
public void setJndiContext(Context jndiContext)
- Parameters:
jndiContext - The jndiContext to set.
getJndiInitialFactory
public String getJndiInitialFactory()
- Returns:
- Returns the jndiInitialFactory.
setJndiInitialFactory
public void setJndiInitialFactory(String jndiInitialFactory)
- Parameters:
jndiInitialFactory - The jndiInitialFactory to set.
getJndiProviderUrl
public String getJndiProviderUrl()
- Returns:
- Returns the jndiProviderUrl.
setJndiProviderUrl
public void setJndiProviderUrl(String jndiProviderUrl)
- Parameters:
jndiProviderUrl - The jndiProviderUrl to set.
getProviderProperties
public Map getProviderProperties()
- Returns:
- Returns the providerProperties.
setProviderProperties
public void setProviderProperties(Map providerProperties)
- Parameters:
providerProperties - The providerProperties to set.
getSessionFactory
public Object getSessionFactory(UMOEndpoint endpoint)
throws Exception
- Throws:
Exception
getConnection
public Connection getConnection()
throws Exception
- Throws:
Exception
getResultSetHandler
public String getResultSetHandler()
- Returns:
- Returns the resultSetHandler.
setResultSetHandler
public void setResultSetHandler(String resultSetHandler)
- Parameters:
resultSetHandler - The resultSetHandler class name to set.
createResultSetHandler
protected ResultSetHandler createResultSetHandler()
- Returns:
- a new instance of the ResultSetHandler class as defined in the
JdbcConnector
getQueryValueExtractors
public Set getQueryValueExtractors()
setQueryValueExtractors
public void setQueryValueExtractors(Set queryValueExtractors)
getQueryRunner
public String getQueryRunner()
- Returns:
- Returns the queryRunner.
setQueryRunner
public void setQueryRunner(String queryRunner)
- Parameters:
queryRunner - The QueryRunner class name to set.
createQueryRunner
protected QueryRunner createQueryRunner()
- Returns:
- a new instance of the QueryRunner class as defined in the
JdbcConnector
parseStatement
public String parseStatement(String stmt,
List params)
- Parse the given statement filling the parameter list and return the ready to
use statement.
- Parameters:
stmt - params -
- Returns:
getParams
public Object[] getParams(UMOImmutableEndpoint endpoint,
List paramNames,
Object message)
throws Exception
- Throws:
Exception
Copyright © 2003-2006 MuleSource Inc.. All Rights Reserved.