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

Method Summary

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, java.lang.Runnable updateStatistics, ExecutionContext executionContext) Creates a new entity-graph.
EntityGraph	createNewGraph() Creates a new entity-graph of same type and session.
void	dropMappingTables(java.io.OutputStreamWriter result, DBMS targetDBMSConfiguration) Creates the DROP-statements for the mapping tables.
void	fillAndWriteMappingTables(JobManager jobManager, java.io.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, java.util.Set<Column> columns, java.io.OutputStreamWriter scriptFileWriter, DBMS targetConfiguration, boolean inSourceSchema, java.lang.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 Detail

create

public static IntraDatabaseEntityGraph create(DataModel dataModel,
                                              int graphID,
                                              Session session,
                                              PrimaryKey universalPrimaryKey,
                                              java.lang.Runnable updateStatistics,
                                              ExecutionContext executionContext)
                                       throws java.sql.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:

java.sql.SQLException

copy

public EntityGraph copy(int newGraphID,
                        Session session)
                 throws java.sql.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:

java.sql.SQLException

createNewGraph

public EntityGraph createNewGraph()
                           throws java.sql.SQLException

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

Overrides:

createNewGraph in class RemoteEntityGraph

Throws:

java.sql.SQLException

readMarkedEntities

public void readMarkedEntities(Table table,
                               boolean orderByPK)
                        throws java.sql.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:

java.sql.SQLException

readEntities

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

Reads all entities of a given table.

Overrides:

readEntities in class RemoteEntityGraph

Parameters:

table - the table

orderByPK - not used

Throws:

java.sql.SQLException

updateEntities

public void updateEntities(Table table,
                           java.util.Set<Column> columns,
                           java.io.OutputStreamWriter scriptFileWriter,
                           DBMS targetConfiguration,
                           boolean inSourceSchema,
                           java.lang.String reason)
                    throws java.sql.SQLException

Updates columns of a table.

Overrides:

updateEntities in class RemoteEntityGraph

Parameters:

table - the table

columns - the columns;

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

reason - to be written as comment

Throws:

java.sql.SQLException

fillAndWriteMappingTables

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

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

Overrides:

fillAndWriteMappingTables in class EntityGraph

Throws:

java.io.IOException

java.sql.SQLException

dropMappingTables

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

Creates the DROP-statements for the mapping tables.

Overrides:

dropMappingTables in class EntityGraph

Throws:

java.io.IOException

java.sql.SQLException