com.toolsverse.etl.core.connection

Interface EtlConnectionFactory

All Superinterfaces:

ConnectionFactory

All Known Implementing Classes:

EtlConnectionFactoryImpl

public interface EtlConnectionFactory
extends ConnectionFactory

The ETL extension of ConnectionFactory interface. The idea is to have a class which is responsible for creating and closing of the database connections used by ETl framework. Also, it must maintain lists of connections and aliases and provide lookup methods like "find connection by alias" and vise versa.

Since:

1.0

Version:

2.0

Method Summary

Modifier and Type	Method and Description
Connection	addConnection(Connection con, ConnectionParams params, String name, String defName) Creates a new connection if needed and adds it to the map of named connections.
Connection	getConnection(ConnectionParams params, boolean isNew) Create and return new connection using given ConnectionParams.
Connection	getConnection(String name, boolean isNew) Creates and returns a new connection by name.
ConnectionParams	getConnectionParams(Connection conn) Gets the connection params for the given connection.
ConnectionParams	getConnectionParams(String name) Gets the connection params by the given name.
void	releaseConnections() Releases all connections.

Methods inherited from interface com.toolsverse.etl.sql.connection.ConnectionFactory

getConnection, getConnection, isReadyToCommit, releaseConnection

Method Detail

getConnection

Connection getConnection(ConnectionParams params,
                         boolean isNew)
                  throws Exception

Create and return new connection using given ConnectionParams.

Parameters:

params - the ConnectionParams

isNew - boolena, if true always create new connection

Returns:

the connection

Throws:

Exception - in case of any error

getConnection

Connection getConnection(String name,
                         boolean isNew)
                  throws Exception

Creates and returns a new connection by name.

Parameters:

name - the connection name

isNew - boolean, if true creates new connection

Returns:

the connection

Throws:

Exception - in case of any error

addConnection

Connection addConnection(Connection con,
                         ConnectionParams params,
                         String name,
                         String defName)
                  throws Exception

Creates a new connection if needed and adds it to the map of named connections.

Throws:

Exception

getConnectionParams

ConnectionParams getConnectionParams(Connection conn)

Gets the connection params for the given connection.

Parameters:

conn - the connection

Returns:

the connection params

getConnectionParams

ConnectionParams getConnectionParams(String name)

Gets the connection params by the given name.

Parameters:

name - the name

Returns:

the connection params

releaseConnections

void releaseConnections()

Releases all connections.