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, java.util.Set<Column> columns, java.io.OutputStreamWriter scriptFileWriter, int maxBodySize, Session session, DBMS targetDBMSConfiguration, ImportFilterTransformer importFilterTransformer, boolean inSourceSchema, java.lang.String reason, ExecutionContext executionContext) Constructor.

Method Summary

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

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

getCellContentConverter, getMetaData, init

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,
                         java.util.Set<Column> columns,
                         java.io.OutputStreamWriter scriptFileWriter,
                         int maxBodySize,
                         Session session,
                         DBMS targetDBMSConfiguration,
                         ImportFilterTransformer importFilterTransformer,
                         boolean inSourceSchema,
                         java.lang.String reason,
                         ExecutionContext executionContext)
                  throws java.sql.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

inSourceSchema - if true, use source-schema-mapping, else use schema-mapping

reason - to be written as comment

Throws:

java.sql.SQLException

Method Detail

convertToSql

protected java.lang.String convertToSql(CellContentConverter cellContentConverter,
                                        java.sql.ResultSet resultSet,
                                        int i,
                                        java.lang.Object content)
                                 throws java.sql.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:

java.sql.SQLException

readCurrentRow

public void readCurrentRow(java.sql.ResultSet resultSet)
                    throws java.sql.SQLException

Reads result-set and writes into export-script.

Parameters:

resultSet - the result-set

Throws:

java.sql.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