net.sf.jailer.database

Class UpdateTransformer

java.lang.Object

net.sf.jailer.database.Session.AbstractResultSetReader

net.sf.jailer.database.UpdateTransformer

All Implemented Interfaces:

Session.ResultSetReader

public class UpdateTransformer
extends Session.AbstractResultSetReader

A Session.ResultSetReader that writes the read rows as UPDATE statements into the export-script.

Author:

Ralf Wisser

Constructor Summary

Constructors

Constructor and Description
UpdateTransformer(Table table, Set<Column> columns, OutputStreamWriter scriptFileWriter, int maxBodySize, Session session, DBMS targetDBMSConfiguration, ImportFilterTransformer importFilterTransformer, ExecutionContext executionContext) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Flushes the export-reader.
protected String	convertToSql(CellContentConverter cellContentConverter, ResultSet resultSet, int i, Object content) Converts cell content to SQL literals.
void	flush() Flushes the export-reader.
void	readCurrentRow(ResultSet resultSet) Reads result-set and writes into export-script.

Methods inherited from class net.sf.jailer.database.Session.AbstractResultSetReader

getCellContentConverter, getMetaData

Methods inherited from class java.lang.Object

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

Constructor Detail

UpdateTransformer

public UpdateTransformer(Table table,
                 Set<Column> columns,
                 OutputStreamWriter scriptFileWriter,
                 int maxBodySize,
                 Session session,
                 DBMS targetDBMSConfiguration,
                 ImportFilterTransformer importFilterTransformer,
                 ExecutionContext executionContext)
                  throws SQLException

Constructor.

Parameters:

table - the table to read from

scriptFileWriter - the file to write to

maxBodySize - maximum length of SQL values list (for generated inserts)

session - the session

targetDBMSConfiguration - configuration of the target DBMS

Throws:

SQLException

Method Detail

convertToSql

protected String convertToSql(CellContentConverter cellContentConverter,
                  ResultSet resultSet,
                  int i,
                  Object content)
                       throws SQLException

Converts cell content to SQL literals.

Parameters:

cellContentConverter - converter

resultSet - points to current row

i - current result set index

content - cell content

Returns:

SQL literal

Throws:

SQLException

readCurrentRow

public void readCurrentRow(ResultSet resultSet)
                    throws SQLException

Reads result-set and writes into export-script.

Parameters:

resultSet - the result-set

Throws:

SQLException

flush

public void flush()

Flushes the export-reader.

close

public void close()

Flushes the export-reader.

Specified by:

close in interface Session.ResultSetReader

Overrides:

close in class Session.AbstractResultSetReader