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	Description
UpdateTransformer(Table table, Set<Column> columns, OutputStreamWriter scriptFileWriter, int maxBodySize, Session session, DBMS targetDBMSConfiguration, ImportFilterTransformer importFilterTransformer, boolean inSourceSchema, String reason, ExecutionContext executionContext)	Constructor.

Method Summary

Modifier and Type	Method	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, init

Methods inherited from class java.lang.Object

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

Constructor Details

UpdateTransformer

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

Constructor.

Parameters:

table - the table to read from

columns - the columns to update

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

importFilterTransformer - transforms import filters into SQL expressions

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

reason - to be written as comment

executionContext - the execution context

Throws:

SQLException

Method Details

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