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

Interface DbConnection

All Superinterfaces:

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

All Known Implementing Classes:

DefaultDbConnection, OracleDbConnection, XADbConnection

public interface DbConnection
extends org.mule.runtime.extension.api.connectivity.TransactionalConnection

Wraps a Connection adding connector's specific functionality

Method Summary

Modifier and Type	Method and Description
void	beginStreaming() Starts streaming.
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 isStreaming() is false

Methods inherited from interface org.mule.runtime.extension.api.tx.Transactional

begin, commit, rollback

Method Detail

getStatementResultIteratorFactory

StatementResultIteratorFactory getStatementResultIteratorFactory(ResultSetHandler resultSetHandler)

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

Parameters:

resultSetHandler - used to process resultSets created from this connection

Returns:

the StatementResultIterator for this connection.

getCustomDataTypes

List<DbType> getCustomDataTypes()

Returns:

A list of customer defined DbTypes

getVendorDataTypes

List<DbType> getVendorDataTypes()

Returns:

A list of DbTypes which are specific to the Database vendor

getJdbcConnection

Connection getJdbcConnection()

Returns:

The underlying JDBC connection

release

void release()

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

beginStreaming

void beginStreaming()

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

isStreaming

boolean isStreaming()

Returns:

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

endStreaming

void endStreaming()

Marks that the streaming is over