net.sf.jailer.importfilter

Class ImportFilterManager

java.lang.Object

net.sf.jailer.importfilter.ImportFilterManager

All Implemented Interfaces:

ImportFilterTransformer

public abstract class ImportFilterManager
extends Object
implements ImportFilterTransformer

Manages filtering of data during import.

Author:

Ralf Wisser

Field Summary

Fields

Modifier and Type	Field and Description
static String	MAPPINGTABLE_NAME_PREFIX

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
void	createMappingTables(DBMS configuration, OutputStreamWriter result) Creates the DDL for the mapping tables.
void	dropMappingTables(OutputStreamWriter result) Creates the DROP-statements for the mapping tables.
void	fillAndWriteMappingTables(EntityGraph entityGraph, JobManager jobManager, 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(OutputStreamWriter result)
String	transform(Column column, 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 String MAPPINGTABLE_NAME_PREFIX

Constructor Detail

ImportFilterManager

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

Constructor.

Parameters:

result - to write results into

targetQuoting -

Throws:

FileNotFoundException

SQLException

Method Detail

createMappingTables

public void createMappingTables(DBMS configuration,
                       OutputStreamWriter result)
                         throws IOException,
                                SQLException

Creates the DDL for the mapping tables.

Throws:

IOException

SQLException

dropMappingTables

public void dropMappingTables(OutputStreamWriter result)
                       throws IOException,
                              SQLException

Creates the DROP-statements for the mapping tables.

Throws:

IOException

SQLException

sync

protected abstract void sync(OutputStreamWriter result)
                      throws IOException

Throws:

IOException

shutDown

public void shutDown()
              throws SQLException

Throws:

SQLException

fillAndWriteMappingTables

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

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

Parameters:

entityGraph -

jobManager -

dmlResultWriter -

Throws:

CancellationException

SQLException

transform

public String transform(Column column,
               String oldValue)

Description copied from interface: ImportFilterTransformer

Transforms columns with import-Filters into SQL-expressions.

Specified by:

transform in interface ImportFilterTransformer