net.esper.eql.db
Class DatabaseConfigServiceImpl

java.lang.Object
  extended by net.esper.eql.db.DatabaseConfigServiceImpl
All Implemented Interfaces:
DatabaseConfigService

public class DatabaseConfigServiceImpl
extends Object
implements DatabaseConfigService

Implementation provides database instance services such as connection factory and connection settings.


Constructor Summary
DatabaseConfigServiceImpl(Map<String,ConfigurationDBRef> mapDatabaseRef, SchedulingService schedulingService, ScheduleBucket scheduleBucket)
          Ctor.
 
Method Summary
 ConnectionCache getConnectionCache(String databaseName, String preparedStatementText)
          Returns true to indicate a setting to retain connections between lookups.
 DatabaseConnectionFactory getConnectionFactory(String databaseName)
          Returns a connection factory for a configured database.
 DataCache getDataCache(String databaseName)
          Returns a new cache implementation for this database.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

DatabaseConfigServiceImpl

public DatabaseConfigServiceImpl(Map<String,ConfigurationDBRef> mapDatabaseRef,
                                 SchedulingService schedulingService,
                                 ScheduleBucket scheduleBucket)
Ctor.

Parameters:
mapDatabaseRef - is a map of database name and database configuration entries
schedulingService - is for scheduling callbacks for a cache
scheduleBucket - is a system bucket for all scheduling callbacks for caches
Method Detail

getConnectionCache

public ConnectionCache getConnectionCache(String databaseName,
                                          String preparedStatementText)
                                   throws DatabaseConfigException
Description copied from interface: DatabaseConfigService
Returns true to indicate a setting to retain connections between lookups.

Specified by:
getConnectionCache in interface DatabaseConfigService
Parameters:
databaseName - is the name of the database
preparedStatementText - is the sql text
Returns:
a cache implementation to cache connection and prepared statements
Throws:
DatabaseConfigException - is thrown to indicate database configuration errors

getConnectionFactory

public DatabaseConnectionFactory getConnectionFactory(String databaseName)
                                               throws DatabaseConfigException
Description copied from interface: DatabaseConfigService
Returns a connection factory for a configured database.

Specified by:
getConnectionFactory in interface DatabaseConfigService
Parameters:
databaseName - is the name of the database
Returns:
is a connection factory to use to get connections to the database
Throws:
DatabaseConfigException - is thrown to indicate database configuration errors

getDataCache

public DataCache getDataCache(String databaseName)
                       throws DatabaseConfigException
Description copied from interface: DatabaseConfigService
Returns a new cache implementation for this database.

Specified by:
getDataCache in interface DatabaseConfigService
Parameters:
databaseName - is the name of the database to return a new cache implementation for for
Returns:
cache implementation
Throws:
DatabaseConfigException - is thrown to indicate database configuration errors