com.exalead.papi.connectors.jdbc

Class ColumnMappingContainer

java.lang.Object

com.exalead.papi.connectors.jdbc.ColumnMappingContainer

All Implemented Interfaces:

java.lang.Cloneable

public class ColumnMappingContainer
extends java.lang.Object
implements java.lang.Cloneable

A ColumnMappingContainer eases operations on a bunch of ColumnMappings.

Field Summary

Fields

Modifier and Type	Field and Description
protected ColumnMapping[]	mappings

Constructor Summary

Constructors

Constructor and Description
ColumnMappingContainer(DatabaseColumnMappingConfig[] configs, java.sql.ResultSetMetaData metaData, DatabaseConnector connector) builds a container of fully resolved mappings from a set of configurations and meta data

Method Summary

Modifier and Type	Method and Description
JDBCURI	buildKeyFromRow(ResultSetProxy row)
JDBCURI	buildKeyFromRow(ResultSetProxy row, JDBCURI previousURI) builds a JDBCURI from the given row
void	end()
void	endDocument() notify all processors that the document will be sent
ColumnMapping[]	getMappings()
void	processRow(ResultSetProxy row) process a row with all processors found in the container's mappings
void	setDocument(JDBCDocument document) sets the document that processors should work on.
void	startDocument() notify all processors that a new document is processed

Methods inherited from class java.lang.Object

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

Field Detail

mappings

protected ColumnMapping[] mappings

Constructor Detail

ColumnMappingContainer

public ColumnMappingContainer(DatabaseColumnMappingConfig[] configs,
                              java.sql.ResultSetMetaData metaData,
                              DatabaseConnector connector)
                       throws java.lang.Exception

builds a container of fully resolved mappings from a set of configurations and meta data

Parameters:

configs -

metaData -

connector -

Throws:

java.lang.Exception

Method Detail

setDocument

public void setDocument(JDBCDocument document)

sets the document that processors should work on.

Parameters:

document -

buildKeyFromRow

public JDBCURI buildKeyFromRow(ResultSetProxy row,
                               JDBCURI previousURI)
                        throws java.lang.Exception

builds a JDBCURI from the given row

Parameters:

row -

Returns:

the corresponding document uri

Throws:

java.sql.SQLException

java.lang.Exception

buildKeyFromRow

public JDBCURI buildKeyFromRow(ResultSetProxy row)
                        throws java.lang.Exception

Throws:

java.lang.Exception

processRow

public void processRow(ResultSetProxy row)
                throws java.lang.Exception

process a row with all processors found in the container's mappings

Parameters:

row -

Throws:

java.sql.SQLException

java.lang.Exception

startDocument

public void startDocument()
                   throws java.lang.Exception

notify all processors that a new document is processed

Throws:

java.lang.Exception

endDocument

public void endDocument()
                 throws java.lang.Exception

notify all processors that the document will be sent

Throws:

java.lang.Exception

end

public void end()
         throws java.lang.Exception

Throws:

java.lang.Exception

getMappings

public ColumnMapping[] getMappings()