net.sf.jailer.importfilter

Class ImportFilterManager

java.lang.Object

net.sf.jailer.importfilter.ImportFilterManager

All Implemented Interfaces:

ImportFilterTransformer

public abstract class ImportFilterManager
extends java.lang.Object
implements ImportFilterTransformer

Manages filtering of data during import.

Author:

Ralf Wisser

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	MAPPINGTABLE_NAME_PREFIX

Constructor Summary

Constructors

Constructor and Description
ImportFilterManager(Session localSession, java.io.OutputStreamWriter result, java.util.Set<Table> progress, Quoting targetQuoting, ExecutionContext executionContext) Constructor.

Method Summary

Modifier and Type	Method and Description
void	createMappingTables(DBMS configuration, java.io.OutputStreamWriter result) Creates the DDL for the mapping tables.
void	dropMappingTables(java.io.OutputStreamWriter result) Creates the DROP-statements for the mapping tables.
void	fillAndWriteMappingTables(EntityGraph entityGraph, JobManager jobManager, java.io.OutputStreamWriter dmlResultWriter, int numberOfEntities, Session targetSession, DBMS targetDBMSConfiguration) Insert the values of columns with non-derived-import-filters into the local database.
void	shutDown()
protected abstract void	sync(java.io.OutputStreamWriter result)
java.lang.String	transform(Column column, java.lang.String oldValue) Transforms columns with import-Filters into SQL-expressions.

Methods inherited from class java.lang.Object

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

Field Detail

MAPPINGTABLE_NAME_PREFIX

public static java.lang.String MAPPINGTABLE_NAME_PREFIX

Constructor Detail

ImportFilterManager

public ImportFilterManager(Session localSession,
                           java.io.OutputStreamWriter result,
                           java.util.Set<Table> progress,
                           Quoting targetQuoting,
                           ExecutionContext executionContext)
                    throws java.io.FileNotFoundException,
                           java.sql.SQLException

Constructor.

Parameters:

result - to write results into

targetQuoting -

Throws:

java.io.FileNotFoundException

java.sql.SQLException

Method Detail

createMappingTables

public void createMappingTables(DBMS configuration,
                                java.io.OutputStreamWriter result)
                         throws java.io.IOException,
                                java.sql.SQLException

Creates the DDL for the mapping tables.

Throws:

java.io.IOException

java.sql.SQLException

dropMappingTables

public void dropMappingTables(java.io.OutputStreamWriter result)
                       throws java.io.IOException,
                              java.sql.SQLException

Creates the DROP-statements for the mapping tables.

Throws:

java.io.IOException

java.sql.SQLException

sync

protected abstract void sync(java.io.OutputStreamWriter result)
                      throws java.io.IOException

Throws:

java.io.IOException

shutDown

public void shutDown()
              throws java.sql.SQLException

Throws:

java.sql.SQLException

fillAndWriteMappingTables

public void fillAndWriteMappingTables(EntityGraph entityGraph,
                                      JobManager jobManager,
                                      java.io.OutputStreamWriter dmlResultWriter,
                                      int numberOfEntities,
                                      Session targetSession,
                                      DBMS targetDBMSConfiguration)
                               throws CancellationException,
                                      java.sql.SQLException

Insert the values of columns with non-derived-import-filters into the local database.

Parameters:

entityGraph -

jobManager -

dmlResultWriter -

Throws:

CancellationException

java.sql.SQLException

transform

public java.lang.String transform(Column column,
                                  java.lang.String oldValue)

Description copied from interface: ImportFilterTransformer

Transforms columns with import-Filters into SQL-expressions.

Specified by:

transform in interface ImportFilterTransformer