org.mule.providers.jdbc
Class JdbcConnector

java.lang.Object
  extended byorg.mule.providers.AbstractConnector
      extended byorg.mule.providers.AbstractServiceEnabledConnector
          extended byorg.mule.providers.jdbc.JdbcConnector
All Implemented Interfaces:
Disposable, ExceptionListener, Initialisable, UMOConnectable, UMOConnector

public class JdbcConnector
extends AbstractServiceEnabledConnector


Field Summary
protected  DataSource dataSource
           
protected  String dataSourceJndiName
           
static long DEFAULT_POLLING_FREQUENCY
           
protected  Context jndiContext
           
protected  String jndiInitialFactory
           
protected  String jndiProviderUrl
           
protected  long pollingFrequency
           
static String PROPERTY_POLLING_FREQUENCY
           
protected  Set propertyExtractors
           
protected  Map providerProperties
           
protected  Map queries
           
protected  String queryRunner
           
protected  Set queryValueExtractors
           
protected  String resultSetHandler
           
 
Fields inherited from class org.mule.providers.AbstractServiceEnabledConnector
serviceDescriptor, serviceOverrides
 
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
 
Fields inherited from interface org.mule.umo.provider.UMOConnector
INT_VALUE_NOT_SET
 
Constructor Summary
JdbcConnector()
           
 
Method Summary
protected  void createDataSource()
           
protected  QueryRunner createQueryRunner()
           
 UMOMessageReceiver createReceiver(UMOComponent component, UMOEndpoint endpoint)
           
protected  ResultSetHandler createResultSetHandler()
           
 void doInitialise()
           
 Connection getConnection()
           
 DataSource getDataSource()
           
 String getDataSourceJndiName()
           
 Context getJndiContext()
           
 String getJndiInitialFactory()
           
 String getJndiProviderUrl()
           
 Object[] getParams(UMOImmutableEndpoint endpoint, List paramNames, Object message)
           
 long getPollingFrequency()
           
 String getProtocol()
           
 Map getProviderProperties()
           
 Map getQueries()
           
 String getQuery(UMOImmutableEndpoint endpoint, String stmt)
           
 String getQueryRunner()
           
 Set getQueryValueExtractors()
           
 String[] getReadAndAckStatements(UMOImmutableEndpoint endpoint)
           
 String getResultSetHandler()
           
 Object getSessionFactory(UMOEndpoint endpoint)
           
protected  void initJndiContext()
           
 String parseStatement(String stmt, List params)
          Parse the given statement filling the parameter list and return the ready to use statement.
 void setDataSource(DataSource dataSource)
           
 void setDataSourceJndiName(String dataSourceJndiName)
           
 void setJndiContext(Context jndiContext)
           
 void setJndiInitialFactory(String jndiInitialFactory)
           
 void setJndiProviderUrl(String jndiProviderUrl)
           
 void setPollingFrequency(long pollingFrequency)
           
 void setProviderProperties(Map providerProperties)
           
 void setQueries(Map queries)
           
 void setQueryRunner(String queryRunner)
           
 void setQueryValueExtractors(Set queryValueExtractors)
           
 void setResultSetHandler(String resultSetHandler)
           
 
Methods inherited from class org.mule.providers.AbstractServiceEnabledConnector
getMessageAdapter, getServiceDescriptor, getServiceOverrides, getStreamMessageAdapter, initFromServiceDescriptor, initialiseFromUrl, setServiceOverrides
 
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
 

Field Detail

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
Constructor Detail

JdbcConnector

public JdbcConnector()
Method Detail

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.