net.sf.jailer.database

Class DMLTransformer

java.lang.Object

net.sf.jailer.database.Session.AbstractResultSetReader

net.sf.jailer.database.DMLTransformer

All Implemented Interfaces:

Session.ResultSetReader

public class DMLTransformer
extends Session.AbstractResultSetReader

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

Author:

Ralf Wisser

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DMLTransformer.Factory Factory.

Field Summary

Fields

Modifier and Type	Field and Description
static java.util.concurrent.atomic.AtomicLong	numberOfExportedLOBs Counts the exported LOBs.
protected Quoting	quoting For quoting of column names.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	DMLTransformer(Table table, java.io.OutputStreamWriter scriptFileWriter, boolean upsertOnly, int maxBodySize, Session session, DBMS targetDBMSConfiguration, ImportFilterTransformer importFilterTransformer, java.util.concurrent.atomic.AtomicReference<Table> identityInsertTable, 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, int callerId, java.lang.String suffix) Converts cell content to SQL literals.
protected Quoting	createQuoting(Session session)
void	flush() Flushes the export-reader.
protected java.lang.String	qualifiedTableName(Table t) Gets qualified table name.
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

Field Detail

numberOfExportedLOBs

public static final java.util.concurrent.atomic.AtomicLong numberOfExportedLOBs

Counts the exported LOBs. (GUI support)

quoting

protected Quoting quoting

For quoting of column names.

Constructor Detail

DMLTransformer

protected DMLTransformer(Table table,
                         java.io.OutputStreamWriter scriptFileWriter,
                         boolean upsertOnly,
                         int maxBodySize,
                         Session session,
                         DBMS targetDBMSConfiguration,
                         ImportFilterTransformer importFilterTransformer,
                         java.util.concurrent.atomic.AtomicReference<Table> identityInsertTable,
                         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)

upsertOnly - use 'upsert' statements for all entities

session - the session

targetDBMSConfiguration - configuration of the target DBMS

executionContext -

Throws:

java.sql.SQLException

Method Detail

createQuoting

protected Quoting createQuoting(Session session)
                         throws java.sql.SQLException

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

convertToSql

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

qualifiedTableName

protected java.lang.String qualifiedTableName(Table t)

Gets qualified table name.

Parameters:

t - the table

Returns:

qualified name of t

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