com.espertech.esper.common.internal.epl.historical.database.connection

Class DatabaseConfigServiceImpl

java.lang.Object

com.espertech.esper.common.internal.epl.historical.database.connection.DatabaseConfigServiceImpl

All Implemented Interfaces:

DatabaseConfigService, DatabaseConfigServiceCompileTime, DatabaseConfigServiceRuntime

public class DatabaseConfigServiceImpl
extends Object
implements DatabaseConfigServiceCompileTime, DatabaseConfigServiceRuntime

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

Constructor Summary

Constructors

Constructor and Description
DatabaseConfigServiceImpl(Map<String,ConfigurationCommonDBRef> mapDatabaseRef, ClasspathImportService classpathImportService) Ctor.

Method Summary

Modifier and Type	Method and Description
ConnectionCache	getConnectionCache(String databaseName, String preparedStatementText)
DatabaseConnectionFactory	getConnectionFactory(String databaseName) Returns a connection factory for a configured database.
HistoricalDataCache	getDataCache(String databaseName, AgentInstanceContext agentInstanceContext, int streamNumber, int scheduleCallbackId) Returns a new cache implementation for this database.
ColumnSettings	getQuerySetting(String databaseName) Returns the column metadata settings for the 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,ConfigurationCommonDBRef> mapDatabaseRef,
                                 ClasspathImportService classpathImportService)

Ctor.

Parameters:

mapDatabaseRef - is a map of database name and database configuration entries

classpathImportService - imports

Method Detail

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

getQuerySetting

public ColumnSettings getQuerySetting(String databaseName)
                               throws DatabaseConfigException

Description copied from interface: DatabaseConfigServiceCompileTime

Returns the column metadata settings for the database.

Specified by:

getQuerySetting in interface DatabaseConfigServiceCompileTime

Parameters:

databaseName - is the database name

Returns:

indicators for change case, metadata retrieval strategy and others

Throws:

DatabaseConfigException - if the name was not configured

getDataCache

public HistoricalDataCache getDataCache(String databaseName,
                                        AgentInstanceContext agentInstanceContext,
                                        int streamNumber,
                                        int scheduleCallbackId)
                                 throws DatabaseConfigException

Description copied from interface: DatabaseConfigServiceRuntime

Returns a new cache implementation for this database.

Specified by:

getDataCache in interface DatabaseConfigServiceRuntime

Parameters:

databaseName - is the name of the database to return a new cache implementation for for

agentInstanceContext - agent instance context

streamNumber - stream number

scheduleCallbackId - callback id

Returns:

cache implementation

Throws:

DatabaseConfigException - is thrown to indicate database configuration errors

getConnectionCache

public ConnectionCache getConnectionCache(String databaseName,
                                          String preparedStatementText)
                                   throws DatabaseConfigException

Specified by:

getConnectionCache in interface DatabaseConfigServiceRuntime

Throws:

DatabaseConfigException