org.mule.db.commons.internal.result.row

Class AbstractMapRowHandler

java.lang.Object

org.mule.db.commons.internal.result.row.AbstractMapRowHandler

All Implemented Interfaces:

RowHandler

Direct Known Subclasses:

ColumnNumberMapRowHandler, InsensitiveMapRowHandler, NonStreamingColumnNumberMapRowHandler

public abstract class AbstractMapRowHandler
extends Object
implements RowHandler

Abstract base class for row handlers that provides common functionality for processing ResultSet data. This class contains all the shared logic for handling different data types and streaming.

Field Summary

Fields

Modifier and Type	Field and Description
protected Charset	charset
protected DbConnection	dbConnection

Constructor Summary

Constructors

Constructor and Description
AbstractMapRowHandler(DbConnection dbConnection)
AbstractMapRowHandler(DbConnection dbConnection, Charset charset)

Method Summary

Modifier and Type	Method and Description
protected abstract String	getColumnKey(ResultSetMetaData metaData, int columnIndex) Determines the key to use for a column.
protected Object	getMuleConsumableValue(Object value)
protected org.mule.runtime.api.metadata.TypedValue<Object>	handleBlobType(Blob value)
protected org.mule.runtime.api.metadata.TypedValue<Object>	handleClobType(Clob value)
protected org.mule.runtime.api.metadata.TypedValue<Object>	handleSqlXmlType(SQLXML value)
Map<String,Object>	process(ResultSet resultSet) Process a row from a resultSet
protected void	validateResult(Map<String,Object> result, int columnCount) Validates the result after processing.

Methods inherited from class java.lang.Object

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

Field Detail

dbConnection

protected DbConnection dbConnection

charset

protected Charset charset

Constructor Detail

AbstractMapRowHandler

public AbstractMapRowHandler(DbConnection dbConnection)

AbstractMapRowHandler

public AbstractMapRowHandler(DbConnection dbConnection,
                             Charset charset)

Method Detail

process

public Map<String,Object> process(ResultSet resultSet)
                           throws SQLException

Description copied from interface: RowHandler

Process a row from a resultSet

Specified by:

process in interface RowHandler

Parameters:

resultSet - resultset containing the row to process. Non null

Returns:

a map where each key represents a column name and the value is the value for that column in the current row. Non null.

Throws:

SQLException - if a database access error occurs or this method is called on a closed result set

getColumnKey

protected abstract String getColumnKey(ResultSetMetaData metaData,
                                       int columnIndex)
                                throws SQLException

Determines the key to use for a column. Subclasses can override this to use column names or numbers.

Parameters:

metaData - the ResultSetMetaData

columnIndex - the column index (1-based)

Returns:

the key to use for this column

Throws:

SQLException - if an error occurs

validateResult

protected void validateResult(Map<String,Object> result,
                              int columnCount)
                       throws SQLException

Validates the result after processing. Subclasses can override this to add specific validation logic.

Parameters:

result - the processed result map

columnCount - the number of columns

Throws:

SQLException - if validation fails

getMuleConsumableValue

protected Object getMuleConsumableValue(Object value)
                                 throws SQLException

Throws:

SQLException

handleSqlXmlType

protected org.mule.runtime.api.metadata.TypedValue<Object> handleSqlXmlType(SQLXML value)
                                                                     throws SQLException

Throws:

SQLException

handleBlobType

protected org.mule.runtime.api.metadata.TypedValue<Object> handleBlobType(Blob value)
                                                                   throws SQLException

Throws:

SQLException

handleClobType

protected org.mule.runtime.api.metadata.TypedValue<Object> handleClobType(Clob value)
                                                                   throws SQLException

Throws:

SQLException