org.mule.extension.db.internal.domain.connection

Class DefaultDbConnection

java.lang.Object

org.mule.extension.db.internal.domain.connection.DefaultDbConnection

All Implemented Interfaces:

DbConnection, org.mule.runtime.extension.api.connectivity.TransactionalConnection, org.mule.runtime.extension.api.tx.Transactional

Direct Known Subclasses:

OracleDbConnection

public class DefaultDbConnection
extends Object
implements DbConnection

Constructor Summary

Constructors

Constructor and Description
DefaultDbConnection(Connection jdbcConnection, List<DbType> customDataTypes)

Method Summary

Modifier and Type	Method and Description
void	begin()
void	beginStreaming() Starts streaming.
void	commit()
void	endStreaming() Marks that the streaming is over
List<DbType>	getCustomDataTypes()
Connection	getJdbcConnection()
StatementResultIteratorFactory	getStatementResultIteratorFactory(ResultSetHandler resultSetHandler) Returns the StatementResultIteratorFactory used to create the StatementResultIterator for this connection.
List<DbType>	getVendorDataTypes()
boolean	isStreaming()
void	release() Closes the underlying JDBC connection, provided that DbConnection.isStreaming() is false
void	rollback()

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultDbConnection

public DefaultDbConnection(Connection jdbcConnection,
                           List<DbType> customDataTypes)

Method Detail

getStatementResultIteratorFactory

public StatementResultIteratorFactory getStatementResultIteratorFactory(ResultSetHandler resultSetHandler)

Returns the StatementResultIteratorFactory used to create the StatementResultIterator for this connection.

Specified by:

getStatementResultIteratorFactory in interface DbConnection

Parameters:

resultSetHandler - used to process resultSets created from this connection

Returns:

the StatementResultIterator for this connection.

getVendorDataTypes

public List<DbType> getVendorDataTypes()

Specified by:

getVendorDataTypes in interface DbConnection

Returns:

A list of DbTypes which are specific to the Database vendor

getJdbcConnection

public Connection getJdbcConnection()

Specified by:

getJdbcConnection in interface DbConnection

Returns:

The underlying JDBC connection

getCustomDataTypes

public List<DbType> getCustomDataTypes()

Specified by:

getCustomDataTypes in interface DbConnection

Returns:

A list of customer defined DbTypes

begin

public void begin()
           throws Exception

Specified by:

begin in interface org.mule.runtime.extension.api.tx.Transactional

Throws:

Exception

commit

public void commit()
            throws SQLException

Specified by:

commit in interface org.mule.runtime.extension.api.tx.Transactional

Throws:

SQLException

rollback

public void rollback()
              throws SQLException

Specified by:

rollback in interface org.mule.runtime.extension.api.tx.Transactional

Throws:

SQLException

release

public void release()

Closes the underlying JDBC connection, provided that DbConnection.isStreaming() is false

Specified by:

release in interface DbConnection

beginStreaming

public void beginStreaming()

Description copied from interface: DbConnection

Starts streaming. Invoke this method when a streaming resultset generated with this connection is about to be iterated

Specified by:

beginStreaming in interface DbConnection

isStreaming

public boolean isStreaming()

Specified by:

isStreaming in interface DbConnection

Returns:

whether DbConnection.beginStreaming() has been invoked on this instance but DbConnection.endStreaming() has not

endStreaming

public void endStreaming()

Description copied from interface: DbConnection

Marks that the streaming is over

Specified by:

endStreaming in interface DbConnection