com.toolsverse.etl.core.connection

Class EtlConnectionFactoryImpl

Object

com.toolsverse.etl.core.connection.EtlConnectionFactoryImpl

All Implemented Interfaces:

EtlConnectionFactory, ConnectionFactory

public class EtlConnectionFactoryImpl
extends Object
implements EtlConnectionFactory

The default implementation of the EtlConnectionFactory interface.

Since:

1.0

Version:

2.0

Constructor Summary

Constructors

Constructor and Description
EtlConnectionFactoryImpl() Instantiates a new etl connection factory.

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) Gets the connection by ConnectionParams.
Connection	getConnection(ConnectionParams params, boolean isNew) Create and return new connection using given ConnectionParams.
Connection	getConnection(String name) Gets the connection by name.
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.
boolean	isReadyToCommit(Connection con) Checks if connection is ready to commit.
void	releaseConnection(Connection con) Releases connection.
void	releaseConnections() Releases all connections.

Methods inherited from class Object

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

Constructor Detail

EtlConnectionFactoryImpl

public EtlConnectionFactoryImpl()

Instantiates a new etl connection factory.

Method Detail

addConnection

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

Description copied from interface: EtlConnectionFactory

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

Specified by:

addConnection in interface EtlConnectionFactory

Throws:

Exception

getConnection

public Connection getConnection(ConnectionParams params,
                                boolean isNew)
                         throws Exception

Description copied from interface: EtlConnectionFactory

Create and return new connection using given ConnectionParams.

Specified by:

getConnection in interface EtlConnectionFactory

Parameters:

params - the ConnectionParams

isNew - boolena, if true always create new connection

Returns:

the connection

Throws:

Exception - in case of any error

getConnection

public Connection getConnection(ConnectionParams params)
                         throws Exception

Description copied from interface: ConnectionFactory

Gets the connection by ConnectionParams.

Specified by:

getConnection in interface ConnectionFactory

Parameters:

params - the ConnectionParams

Returns:

the connection

Throws:

Exception - in case of any error

getConnection

public Connection getConnection(String name)

Description copied from interface: ConnectionFactory

Gets the connection by name.

Specified by:

getConnection in interface ConnectionFactory

Parameters:

name - the name

Returns:

the connection

getConnection

public Connection getConnection(String name,
                                boolean isNew)
                         throws Exception

Description copied from interface: EtlConnectionFactory

Creates and returns a new connection by name.

Specified by:

getConnection in interface EtlConnectionFactory

Parameters:

name - the connection name

isNew - boolean, if true creates new connection

Returns:

the connection

Throws:

Exception - in case of any error

getConnectionParams

public ConnectionParams getConnectionParams(Connection conn)

Description copied from interface: EtlConnectionFactory

Gets the connection params for the given connection.

Specified by:

getConnectionParams in interface EtlConnectionFactory

Parameters:

conn - the connection

Returns:

the connection params

getConnectionParams

public ConnectionParams getConnectionParams(String name)

Description copied from interface: EtlConnectionFactory

Gets the connection params by the given name.

Specified by:

getConnectionParams in interface EtlConnectionFactory

Parameters:

name - the name

Returns:

the connection params

isReadyToCommit

public boolean isReadyToCommit(Connection con)

Description copied from interface: ConnectionFactory

Checks if connection is ready to commit. It usually means that the connection currently referenced just from one place.

Specified by:

isReadyToCommit in interface ConnectionFactory

Parameters:

con - the connection

Returns:

true, if is ready to commit

releaseConnection

public void releaseConnection(Connection con)

Description copied from interface: ConnectionFactory

Releases connection.

Specified by:

releaseConnection in interface ConnectionFactory

Parameters:

con - the connection

releaseConnections

public void releaseConnections()

Description copied from interface: EtlConnectionFactory

Releases all connections.

Specified by:

releaseConnections in interface EtlConnectionFactory