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, graphID, importFilterManager, inDeleteMode, isTruncated

Method Summary

Modifier and Type	Method	Description
EntityGraph	copy(int newGraphID, Session session)	Copies an entity-graph.
static IntraDatabaseEntityGraph	create(DataModel dataModel, int graphID, Session session, PrimaryKey universalPrimaryKey, Runnable updateStatistics, ExecutionContext executionContext)	Creates a new entity-graph.
EntityGraph	createNewGraph()	Creates a new entity-graph of same type and session.
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.
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, boolean inSourceSchema, String reason)	Updates columns of a table.

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

addDependencies, addEntities, 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, resolveAssociation, setAge, setBirthdayOfSubject, shutDown

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

addExportedCount, checkExist, copy, createUniqueGraphID, delete, deleteRows, dmlTableReference, getExportedCount, getImportFilterManager, getSelectionClause, getTransformerFactory, incLobCount, removeDependencies, setDeleteMode, setImportFilterManager, setTransformerFactory, truncate, typeName

Methods inherited from class java.lang.Object

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

Method Details

create

public static IntraDatabaseEntityGraph create(DataModel dataModel,
 int graphID,
 Session session,
 PrimaryKey universalPrimaryKey,
 Runnable updateStatistics,
 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

createNewGraph

public EntityGraph createNewGraph()
                           throws SQLException

Creates a new entity-graph of same type and session.

Overrides:

createNewGraph in class RemoteEntityGraph

Returns:

the newly created 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,
 boolean inSourceSchema,
 String reason)
                    throws SQLException

Updates columns of a table.

Overrides:

updateEntities in class RemoteEntityGraph

Parameters:

table - the table

columns - the columns

scriptFileWriter - writer for the SQL script output

targetConfiguration - the target DBMS configuration

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

reason - to be written as comment

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

Parameters:

jobManager - the job manager used to execute jobs in parallel

receiptWriter - writer for the DML result output

numberOfEntities - the number of entities to process

targetSession - the session for the target database

targetDBMSConfiguration - the target DBMS configuration

dbmsConfiguration - the source DBMS configuration

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

Parameters:

result - writer for the DROP-statement output

targetDBMSConfiguration - the target DBMS configuration

Throws:

IOException

SQLException