net.sf.jailer.entitygraph.intradatabase

Class IntraDatabaseEntityGraph

java.lang.Object

net.sf.jailer.entitygraph.EntityGraph

net.sf.jailer.entitygraph.remote.RemoteEntityGraph

net.sf.jailer.entitygraph.intradatabase.IntraDatabaseEntityGraph

public class IntraDatabaseEntityGraph
extends RemoteEntityGraph

Specialized RemoteEntityGraph for exporting data into a different schema within the same database.

Author:

Ralf Wisser

Field Summary

Fields inherited from class net.sf.jailer.entitygraph.remote.RemoteEntityGraph

birthdayOfSubject, rowIdSupport, session, universalPrimaryKey

Fields inherited from class net.sf.jailer.entitygraph.EntityGraph

dataModel, DEPENDENCY, ENTITY, ENTITY_GRAPH, ENTITY_SET_ELEMENT, executionContext, explainIdOfAssociation, graphID, importFilterManager, inDeleteMode, maxTotalRowcount

Method Summary

Methods

Modifier and Type	Method and Description
EntityGraph	copy(int newGraphID, Session session) Copies an entity-graph.
static IntraDatabaseEntityGraph	create(DataModel dataModel, int graphID, Session session, PrimaryKey universalPrimaryKey, ExecutionContext executionContext) Creates a new entity-graph.
void	dropMappingTables(OutputStreamWriter result, DBMS targetDBMSConfiguration) Creates the DROP-statements for the mapping tables.
void	fillAndWriteMappingTables(JobManager jobManager, OutputStreamWriter receiptWriter, int numberOfEntities, Session targetSession, DBMS targetDBMSConfiguration, DBMS dbmsConfiguration) Insert the values of columns with non-derived-import-filters into the local database.
EntityGraph	find(int graphID, Session session, PrimaryKey universalPrimaryKey) Finds an entity-graph.
void	readEntities(Table table, boolean orderByPK) Reads all entities of a given table.
void	readMarkedEntities(Table table, boolean orderByPK) Reads all entities of a given table which are marked as independent or as roots.
void	updateEntities(Table table, Set<Column> columns, OutputStreamWriter scriptFileWriter, DBMS targetConfiguration) Updates columns of a table.

Methods inherited from class net.sf.jailer.entitygraph.remote.RemoteEntityGraph

addDependencies, addEntities, close, countEntities, delete, deleteEntities, deleteIndependentEntities, filteredSelectionClause, filteredSelectionClause, getAge, getDatamodel, getDistinctDependencyIDs, getSession, getSize, getSize, getTargetSession, getTotalRowcount, getUniversalPrimaryKey, init, markDependentEntitiesAsTraversed, markIndependentEntities, markRoots, pkEqualsEntityID, prefixColumnName, readDependentEntities, readEntities, readMarkedEntities, readNonTraversedDependencies, readUnfilteredEntityColumns, removeAssociatedDestinations, removeReflexiveDependencies, resolveAssociation, setAge, setBirthdayOfSubject, setExplain, shutDown, uniteWith

Methods inherited from class net.sf.jailer.entitygraph.EntityGraph

createUniqueGraphID, dmlTableReference, getImportFilterManager, getTransformerFactory, incLobCount, removeDependencies, setDeleteMode, setImportFilterManager, setTransformerFactory, typeName

Methods inherited from class java.lang.Object

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

Method Detail

create

public static IntraDatabaseEntityGraph create(DataModel dataModel,
                              int graphID,
                              Session session,
                              PrimaryKey universalPrimaryKey,
                              ExecutionContext executionContext)
                                       throws SQLException

Creates a new entity-graph.

Parameters:

graphID - the unique ID of the graph

session - for executing SQL-Statements

universalPrimaryKey - the universal primary key

Returns:

the newly created entity-graph

Throws:

SQLException

copy

public EntityGraph copy(int newGraphID,
               Session session)
                 throws SQLException

Copies an entity-graph.

Overrides:

copy in class RemoteEntityGraph

Parameters:

newGraphID - the unique ID of the new graph

session - for executing SQL-Statements

Returns:

the newly created entity-graph

Throws:

SQLException

find

public EntityGraph find(int graphID,
               Session session,
               PrimaryKey universalPrimaryKey)
                 throws SQLException

Finds an entity-graph.

Overrides:

find in class RemoteEntityGraph

Parameters:

graphID - the unique ID of the graph

universalPrimaryKey - the universal primary key

session - for executing SQL-Statements

Returns:

the entity-graph

Throws:

SQLException

readMarkedEntities

public void readMarkedEntities(Table table,
                      boolean orderByPK)
                        throws SQLException

Reads all entities of a given table which are marked as independent or as roots.

Overrides:

readMarkedEntities in class RemoteEntityGraph

Parameters:

table - the table

orderByPK - not used

Throws:

SQLException

readEntities

public void readEntities(Table table,
                boolean orderByPK)
                  throws SQLException

Reads all entities of a given table.

Overrides:

readEntities in class RemoteEntityGraph

Parameters:

table - the table

orderByPK - not used

Throws:

SQLException

updateEntities

public void updateEntities(Table table,
                  Set<Column> columns,
                  OutputStreamWriter scriptFileWriter,
                  DBMS targetConfiguration)
                    throws SQLException

Updates columns of a table.

Overrides:

updateEntities in class RemoteEntityGraph

Parameters:

table - the table

columns - the columns;

Throws:

SQLException

fillAndWriteMappingTables

public void fillAndWriteMappingTables(JobManager jobManager,
                             OutputStreamWriter receiptWriter,
                             int numberOfEntities,
                             Session targetSession,
                             DBMS targetDBMSConfiguration,
                             DBMS dbmsConfiguration)
                               throws IOException,
                                      SQLException

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

Overrides:

fillAndWriteMappingTables in class EntityGraph

Throws:

IOException

SQLException

dropMappingTables

public void dropMappingTables(OutputStreamWriter result,
                     DBMS targetDBMSConfiguration)
                       throws IOException,
                              SQLException

Creates the DROP-statements for the mapping tables.

Overrides:

dropMappingTables in class EntityGraph

Throws:

IOException

SQLException