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, java.beans.ExceptionListener, Initialisable, Startable, Stoppable, UMOConnector

public class JdbcConnector
extends AbstractServiceEnabledConnector

Version:
$Revision: 1.4 $
Author:
Guillaume Nodet

Field Summary
 
Fields inherited from class org.mule.providers.AbstractServiceEnabledConnector
serviceDescriptor, serviceOverrides
 
Fields inherited from class org.mule.providers.AbstractConnector
DEFAULT_RETRY_COUNT, DEFAULT_RETRY_FREQUENCY, defaultInboundTransformer, defaultOutboundTransformer, defaultResponseTransformer, dispatcherFactory, dispatchers, disposed, exceptionListener, initialised, logger, name, receivers, started
 
Constructor Summary
JdbcConnector()
           
 
Method Summary
protected  void createDataSource()
           
 UMOMessageReceiver createReceiver(UMOComponent component, UMOEndpoint endpoint)
           
 void doInitialise()
           
 java.sql.Connection getConnection()
           
 javax.sql.DataSource getDataSource()
           
 java.lang.String getDataSourceJndiName()
           
 javax.naming.Context getJndiContext()
           
 java.lang.String getJndiInitialFactory()
           
 java.lang.String getJndiProviderUrl()
           
 long getPollingFrequency()
           
 java.lang.String getProtocol()
           
 java.util.Map getProviderProperties()
           
 java.util.Map getQueries()
           
 java.lang.String getQuery(UMOEndpoint endpoint, java.lang.String stmt)
           
 java.lang.String[] getReadAndAckStatements(UMOEndpointURI endpointUri, UMOEndpoint endpoint)
           
 java.lang.Object getSessionFactory(UMOEndpoint endpoint)
           
protected  void initJndiContext()
           
 void setDataSource(javax.sql.DataSource dataSource)
           
 void setDataSourceJndiName(java.lang.String dataSourceJndiName)
           
 void setJndiContext(javax.naming.Context jndiContext)
           
 void setJndiInitialFactory(java.lang.String jndiInitialFactory)
           
 void setJndiProviderUrl(java.lang.String jndiProviderUrl)
           
 void setPollingFrequency(long pollingFrequency)
           
 void setProviderProperties(java.util.Map providerProperties)
           
 void setQueries(java.util.Map queries)
           
 
Methods inherited from class org.mule.providers.AbstractServiceEnabledConnector
getMessageAdapter, getServiceDescriptor, getServiceOverrides, initFromServiceDescriptor, initialiseFromUrl, setServiceOverrides
 
Methods inherited from class org.mule.providers.AbstractConnector
checkDisposed, createDispatcher, destroyReceiver, dispose, disposeConnector, exceptionThrown, getDefaultInboundTransformer, getDefaultOutboundTransformer, getDefaultResponseTransformer, getDispatcher, getDispatcherFactory, getDispatchers, getDispatcherThreadingProfile, getExceptionListener, getName, getReceiverKey, getReceiverThreadingProfile, getReplyToHandler, getRetryCount, getRetryFrequency, handleException, initialise, isDisposed, isDisposeDispatcherOnCompletion, isStarted, registerListener, setDefaultInboundTransformer, setDefaultOutboundTransformer, setDefaultResponseTransformer, setDispatcherFactory, setDispatcherThreadingProfile, setDisposeDispatcherOnCompletion, setExceptionListener, setName, setReceiverThreadingProfile, setRetryCount, setRetryFrequency, start, startConnector, stop, stopConnector, unregisterListener
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

JdbcConnector

public JdbcConnector()
Method Detail

getProtocol

public java.lang.String getProtocol()
Specified by:
getProtocol in interface UMOConnector
Specified by:
getProtocol in class AbstractConnector

createReceiver

public UMOMessageReceiver createReceiver(UMOComponent component,
                                         UMOEndpoint endpoint)
                                  throws java.lang.Exception
Overrides:
createReceiver in class AbstractServiceEnabledConnector
Throws:
java.lang.Exception

initJndiContext

protected void initJndiContext()
                        throws javax.naming.NamingException
Throws:
javax.naming.NamingException

createDataSource

protected void createDataSource()
                         throws InitialisationException,
                                javax.naming.NamingException
Throws:
InitialisationException
javax.naming.NamingException

doInitialise

public void doInitialise()
                  throws InitialisationException
Overrides:
doInitialise in class AbstractServiceEnabledConnector
Throws:
InitialisationException

getReadAndAckStatements

public java.lang.String[] getReadAndAckStatements(UMOEndpointURI endpointUri,
                                                  UMOEndpoint endpoint)

getQuery

public java.lang.String getQuery(UMOEndpoint endpoint,
                                 java.lang.String stmt)

getDataSource

public javax.sql.DataSource getDataSource()
Returns:
Returns the dataSource.

setDataSource

public void setDataSource(javax.sql.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 java.util.Map getQueries()
Returns:
Returns the queries.

setQueries

public void setQueries(java.util.Map queries)
Parameters:
queries - The queries to set.

getDataSourceJndiName

public java.lang.String getDataSourceJndiName()
Returns:
Returns the dataSourceJndiName.

setDataSourceJndiName

public void setDataSourceJndiName(java.lang.String dataSourceJndiName)
Parameters:
dataSourceJndiName - The dataSourceJndiName to set.

getJndiContext

public javax.naming.Context getJndiContext()
Returns:
Returns the jndiContext.

setJndiContext

public void setJndiContext(javax.naming.Context jndiContext)
Parameters:
jndiContext - The jndiContext to set.

getJndiInitialFactory

public java.lang.String getJndiInitialFactory()
Returns:
Returns the jndiInitialFactory.

setJndiInitialFactory

public void setJndiInitialFactory(java.lang.String jndiInitialFactory)
Parameters:
jndiInitialFactory - The jndiInitialFactory to set.

getJndiProviderUrl

public java.lang.String getJndiProviderUrl()
Returns:
Returns the jndiProviderUrl.

setJndiProviderUrl

public void setJndiProviderUrl(java.lang.String jndiProviderUrl)
Parameters:
jndiProviderUrl - The jndiProviderUrl to set.

getProviderProperties

public java.util.Map getProviderProperties()
Returns:
Returns the providerProperties.

setProviderProperties

public void setProviderProperties(java.util.Map providerProperties)
Parameters:
providerProperties - The providerProperties to set.

getSessionFactory

public java.lang.Object getSessionFactory(UMOEndpoint endpoint)
                                   throws java.lang.Exception
Throws:
java.lang.Exception

getConnection

public java.sql.Connection getConnection()
                                  throws java.lang.Exception
Throws:
java.lang.Exception


Copyright © 2003-2005 SymphonySoft Limited. All Rights Reserved.