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

Class DatabaseDMConnFactory

java.lang.Object

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

All Implemented Interfaces:

DatabaseConnectionFactory

public class DatabaseDMConnFactory
extends Object
implements DatabaseConnectionFactory

Database connection factory using DriverManager to obtain connections.

Constructor Summary

Constructors

Constructor	Description
DatabaseDMConnFactory(ConfigurationCommonDBRef.DriverManagerConnection driverConfig, ConfigurationCommonDBRef.ConnectionSettings connectionSettings, ClasspathImportService classpathImportService)	Ctor.

Method Summary

Modifier and Type	Method	Description
Connection	getConnection()	Creates a new database connection.
protected static void	setConnectionOptions(Connection connection, ConfigurationCommonDBRef.ConnectionSettings connectionSettings)	Method to set connection-level configuration settings.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DatabaseDMConnFactory

public DatabaseDMConnFactory(ConfigurationCommonDBRef.DriverManagerConnection driverConfig,
 ConfigurationCommonDBRef.ConnectionSettings connectionSettings,
 ClasspathImportService classpathImportService)
                      throws DatabaseConfigException

Ctor.

Parameters:

driverConfig - is the driver manager configuration

connectionSettings - are connection-level settings

classpathImportService - imports

Throws:

DatabaseConfigException - thrown if the driver class cannot be loaded

Method Details

getConnection

public Connection getConnection()
                         throws DatabaseConfigException

Description copied from interface: DatabaseConnectionFactory

Creates a new database connection.

Specified by:

getConnection in interface DatabaseConnectionFactory

Returns:

new connection

Throws:

DatabaseConfigException - throws to indicate a problem getting a new connection

setConnectionOptions

protected static void setConnectionOptions(Connection connection,
 ConfigurationCommonDBRef.ConnectionSettings connectionSettings)
                                    throws DatabaseConfigException

Method to set connection-level configuration settings.

Parameters:

connection - is the connection to set on

connectionSettings - are the settings to apply

Throws:

DatabaseConfigException - is thrown if an SQLException is thrown