net.sf.jailer.entitygraph

Class EntityGraph

java.lang.Object

net.sf.jailer.entitygraph.EntityGraph

Direct Known Subclasses:

LocalEntityGraph, RemoteEntityGraph

public abstract class EntityGraph
extends java.lang.Object

Persistent graph of entities.

Author:

Ralf Wisser

Field Summary

Fields

Modifier and Type	Field and Description
DataModel	dataModel
static java.lang.String	DEPENDENCY Name of the dependency-table.
static java.lang.String	ENTITY Name of the entity-table.
static java.lang.String	ENTITY_GRAPH Name of the graph-table.
static java.lang.String	ENTITY_SET_ELEMENT Name of the (helper) set-table.
protected ExecutionContext	executionContext The execution context.
int	graphID The unique ID of the graph.
protected ImportFilterManager	importFilterManager The ImportFilterManager.
protected boolean	inDeleteMode
protected boolean	isTruncated

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	EntityGraph(int graphID, DataModel dataModel, ExecutionContext executionContext)

Method Summary

Modifier and Type	Method and Description
abstract void	addDependencies(Table from, java.lang.String fromAlias, Table to, java.lang.String toAlias, java.lang.String condition, int aggregationId, int dependencyId, boolean isAssociationReversed) Adds dependencies.
abstract long	addEntities(Table table, java.lang.String condition, int today) Adds entities to the graph.
abstract long	addEntities(Table table, java.lang.String condition, int today, SubjectLimitDefinition limitDefinition, boolean joinWithEntity) Adds limited number of entities to the graph.
protected void	addExportedCount(long count)
void	checkExist(ExecutionContext executionContext) Check if the graph still exists.
abstract void	close() Closes the graph.
abstract EntityGraph	copy(int graphID, Session session) Copies an entity-graph.
EntityGraph	copy(java.util.Set<Table> tables) Copies some tables.
abstract long	countEntities(Table table) Counts the entities of a given table in this graph.
abstract EntityGraph	createNewGraph() Creates a new entity-graph of same type and session.
static int	createUniqueGraphID() Creates a unique ID for a new graph.
void	delete() Deletes the graph.
abstract void	delete(boolean forced) Deletes the graph.
abstract long	deleteEntities(Table table) Deletes all entities from a given table.
abstract void	deleteIndependentEntities(Table table) Deletes all entities which are marked as independent.
protected long	deleteRows(Session session, java.lang.String table, java.lang.String where) Deletes rows from table.
protected java.lang.String	dmlTableReference(java.lang.String tableName, Session session) Gets table reference for DML statements for a given working table.
void	dropMappingTables(java.io.OutputStreamWriter result, DBMS targetDBMSConfiguration) Creates the DROP-statements for the mapping tables.
void	fillAndWriteMappingTables(JobManager jobManager, java.io.OutputStreamWriter dmlResultWriter, int numberOfEntities, Session targetSession, DBMS targetDBMSConfiguration, DBMS dbmsConfiguration) Insert the values of columns with non-derived-import-filters into the local database.
abstract int	getAge() Gets the age of the graph.
abstract DataModel	getDatamodel()
abstract java.util.Set<java.lang.Integer>	getDistinctDependencyIDs() Gets distinct association-ids of all edged.
long	getExportedCount()
ImportFilterManager	getImportFilterManager() Gets the ImportFilterManager
protected java.util.List<Column>	getSelectionClause(Table table) Gets all non-virtual columns of the table in the order in which they are selected.
abstract Session	getSession() Gets the session.
abstract long	getSize() Gets the number of entities in the graph.
long	getSize(java.util.Set<Table> tables) Gets the number of entities from given tables in the graph.
abstract Session	getTargetSession()
abstract long	getTotalRowcount() Gets total row-count.
TransformerFactory	getTransformerFactory() Gets the TransformerFactory.
abstract PrimaryKey	getUniversalPrimaryKey() Gets the universal primary key.
int	incLobCount() Increments lob-counter and returns new value.
abstract void	markDependentEntitiesAsTraversed(Association association, java.sql.ResultSet resultSet, java.sql.ResultSetMetaData resultSetMetaData, java.util.Map<java.lang.String,java.lang.Integer> typeCache) Marks all entities which depends on given entity as traversed.
abstract void	markIndependentEntities(Table table) Marks all entities of a given table which don't dependent on other entities, s.t. they can be read and deleted.
abstract void	markRoots(Table table) Marks all rows which are not target of a dependency.
abstract void	readDependentEntities(Table table, Association association, java.sql.ResultSet resultSet, java.sql.ResultSetMetaData resultSetMetaData, Session.ResultSetReader reader, java.util.Map<java.lang.String,java.lang.Integer> typeCache, java.lang.String selectionSchema, java.lang.String originalPKAliasPrefix) Reads all entities which depends on given entity.
abstract void	readEntities(Table table, boolean orderByPK) Reads all entities of a given table.
abstract void	readMarkedEntities(Table table, boolean orderByPK) Reads all entities of a given table which are marked as independent or as roots.
abstract void	readMarkedEntities(Table table, Session.ResultSetReader reader, java.lang.String selectionSchema, java.lang.String originalPKAliasPrefix, boolean orderByPK) Reads all entities of a given table which are marked as independent or as roots.
abstract void	readNonTraversedDependencies(Table table, Session.ResultSetReader reader) Reads all non-traversed dependencies.
abstract long	readUnfilteredEntityColumns(Table table, java.util.List<Column> columns, Session.ResultSetReader reader) Reads some columns of all entities of a given table without using filters.
abstract long	removeAssociatedDestinations(Association association, boolean deletedEntitiesAreMarked, java.util.Set<Table> allTables) Removes all entities from this graph which are associated with an entity outside the graph.
void	removeDependencies(Association association) Removes all dependencies for a given association.
abstract void	removeReflexiveDependencies(Table table) Removes all reflexive dependencies of given table.
abstract long	resolveAssociation(Table table, Association association, EntityGraph otherGraph, EntityGraph universum, boolean forDelete) Resolves an association.
abstract long	resolveAssociation(Table table, Association association, int today) Resolves an association.
abstract void	setAge(int age) Sets the age of the graph.
abstract void	setBirthdayOfSubject(int birthdayOfSubject) Sets birthday of subject rows.
void	setDeleteMode(boolean deleteMode)
void	setImportFilterManager(ImportFilterManager importFilterManager) Sets the ImportFilterManager
void	setTransformerFactory(TransformerFactory transformerFactory) Sets the TransformerFactory.
abstract void	shutDown() Shuts down statement-executor.
void	truncate(ExecutionContext executionContext, boolean checkExist) Tries to delete this graph using "truncate".
protected int	typeName(Table table)
abstract 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 java.lang.Object

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

Field Detail

ENTITY_GRAPH

public static final java.lang.String ENTITY_GRAPH

Name of the graph-table.

See Also:

Constant Field Values

ENTITY_SET_ELEMENT

public static final java.lang.String ENTITY_SET_ELEMENT

Name of the (helper) set-table.

See Also:

Constant Field Values

ENTITY

public static final java.lang.String ENTITY

Name of the entity-table.

See Also:

Constant Field Values

DEPENDENCY

public static final java.lang.String DEPENDENCY

Name of the dependency-table.

See Also:

Constant Field Values

dataModel

public final DataModel dataModel

isTruncated

protected boolean isTruncated

executionContext

protected final ExecutionContext executionContext

The execution context.

inDeleteMode

protected boolean inDeleteMode

graphID

public final int graphID

The unique ID of the graph.

importFilterManager

protected ImportFilterManager importFilterManager

The ImportFilterManager.

Constructor Detail

EntityGraph

protected EntityGraph(int graphID,
                      DataModel dataModel,
                      ExecutionContext executionContext)

Method Detail

setBirthdayOfSubject

public abstract void setBirthdayOfSubject(int birthdayOfSubject)

Sets birthday of subject rows.

Parameters:

birthdayOfSubject - birthday of subject rows

copy

public abstract EntityGraph copy(int graphID,
                                 Session session)
                          throws java.sql.SQLException

Copies an entity-graph.

Parameters:

graphID - the unique ID of the graph

session - for executing SQL-Statements

Returns:

the newly created entity-graph

Throws:

java.sql.SQLException

createNewGraph

public abstract EntityGraph createNewGraph()
                                    throws java.sql.SQLException

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

Throws:

java.sql.SQLException

copy

public EntityGraph copy(java.util.Set<Table> tables)
                 throws java.sql.SQLException

Copies some tables.

Parameters:

tables - tables to copy

Throws:

java.sql.SQLException

getAge

public abstract int getAge()
                    throws java.sql.SQLException

Gets the age of the graph.

Returns:

the age of the graph

Throws:

java.sql.SQLException

setAge

public abstract void setAge(int age)
                     throws java.sql.SQLException

Sets the age of the graph.

Parameters:

age - the age of the graph

Throws:

java.sql.SQLException

getSize

public abstract long getSize()
                      throws java.sql.SQLException

Gets the number of entities in the graph.

Returns:

the number of entities in the graph

Throws:

java.sql.SQLException

getSize

public long getSize(java.util.Set<Table> tables)
             throws java.sql.SQLException

Gets the number of entities from given tables in the graph.

Returns:

the number of entities in the graph

Throws:

java.sql.SQLException

delete

public final void delete()
                  throws java.sql.SQLException

Deletes the graph.

Throws:

java.sql.SQLException

delete

public abstract void delete(boolean forced)

Deletes the graph.

Parameters:

forced - force deletion. if true, don't allow optimization.

addEntities

public abstract long addEntities(Table table,
                                 java.lang.String condition,
                                 int today)
                          throws java.sql.SQLException

Adds entities to the graph.

Parameters:

table - the table

condition - the condition in SQL that the entities must fulfill

today - the birthday of the new entities

Returns:

row-count

Throws:

java.sql.SQLException

addEntities

public abstract long addEntities(Table table,
                                 java.lang.String condition,
                                 int today,
                                 SubjectLimitDefinition limitDefinition,
                                 boolean joinWithEntity)
                          throws java.sql.SQLException

Adds limited number of entities to the graph.

Parameters:

table - the table

condition - the condition in SQL that the entities must fulfill

today - the birthday of the new entities

limitDefinition - limit

Returns:

row-count

Throws:

java.sql.SQLException

resolveAssociation

public abstract long resolveAssociation(Table table,
                                        Association association,
                                        int today)
                                 throws java.sql.SQLException

Resolves an association. Retrieves and adds all entities associated with an entity born yesterday in the graph and adds the dependencies.

Parameters:

table - the table

association - the association to resolve

today - the birthday of the new entities

Returns:

row-count or -1, if association is ignored

Throws:

java.sql.SQLException

resolveAssociation

public abstract long resolveAssociation(Table table,
                                        Association association,
                                        EntityGraph otherGraph,
                                        EntityGraph universum,
                                        boolean forDelete)
                                 throws java.sql.SQLException

Resolves an association. Retrieves and adds all entities associated with an entity into a given entity-graph. Restrictions are ignored.

Parameters:

table - the table

association - the association to resolve

Returns:

row-count

Throws:

java.sql.SQLException

addDependencies

public abstract void addDependencies(Table from,
                                     java.lang.String fromAlias,
                                     Table to,
                                     java.lang.String toAlias,
                                     java.lang.String condition,
                                     int aggregationId,
                                     int dependencyId,
                                     boolean isAssociationReversed)
                              throws java.sql.SQLException

Adds dependencies.

Parameters:

from - source of dependency

fromAlias - alias for from-table

to - destination of dependency

toAlias - alias for to-table

condition - condition of dependency

aggregationId - id of aggregation association (for XML export), 0 if not applicable

dependencyId - id of dependency

Throws:

java.sql.SQLException

getDistinctDependencyIDs

public abstract java.util.Set<java.lang.Integer> getDistinctDependencyIDs()
                                                                   throws java.sql.SQLException

Gets distinct association-ids of all edged.

Throws:

java.sql.SQLException

markIndependentEntities

public abstract void markIndependentEntities(Table table)
                                      throws java.sql.SQLException

Marks all entities of a given table which don't dependent on other entities, s.t. they can be read and deleted.

Throws:

java.sql.SQLException

markRoots

public abstract void markRoots(Table table)
                        throws java.sql.SQLException

Marks all rows which are not target of a dependency.

Throws:

java.sql.SQLException

readMarkedEntities

public abstract 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.

Parameters:

table - the table

orderByPK - if true, result will be ordered by primary keys

Throws:

java.sql.SQLException

readMarkedEntities

public abstract void readMarkedEntities(Table table,
                                        Session.ResultSetReader reader,
                                        java.lang.String selectionSchema,
                                        java.lang.String originalPKAliasPrefix,
                                        boolean orderByPK)
                                 throws java.sql.SQLException

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

Parameters:

reader - for reading the result-set

table - the table

orderByPK - if true, result will be ordered by primary keys

Throws:

java.sql.SQLException

readEntities

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

Reads all entities of a given table.

Parameters:

table - the table

orderByPK - if true, result will be ordered by primary keys

Throws:

java.sql.SQLException

updateEntities

public abstract 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.

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

readUnfilteredEntityColumns

public abstract long readUnfilteredEntityColumns(Table table,
                                                 java.util.List<Column> columns,
                                                 Session.ResultSetReader reader)
                                          throws java.sql.SQLException

Reads some columns of all entities of a given table without using filters.

Parameters:

table - the table

columns - the columns

reader - to read

Throws:

java.sql.SQLException

deleteIndependentEntities

public abstract void deleteIndependentEntities(Table table)
                                        throws java.sql.SQLException

Deletes all entities which are marked as independent.

Throws:

java.sql.SQLException

deleteEntities

public abstract long deleteEntities(Table table)
                             throws java.sql.SQLException

Deletes all entities from a given table.

Throws:

java.sql.SQLException

countEntities

public abstract long countEntities(Table table)
                            throws java.sql.SQLException

Counts the entities of a given table in this graph.

Parameters:

table - the table

Returns:

the number of entities from table in this graph

Throws:

java.sql.SQLException

removeAssociatedDestinations

public abstract long removeAssociatedDestinations(Association association,
                                                  boolean deletedEntitiesAreMarked,
                                                  java.util.Set<Table> allTables)
                                           throws java.sql.SQLException

Removes all entities from this graph which are associated with an entity outside the graph.

Parameters:

association - the association

deletedEntitiesAreMarked - if true, consider entity as deleted if its birthday is negative

allTables - set of tables from which there are entities in E

Returns:

number of removed entities

Throws:

java.sql.SQLException

readDependentEntities

public abstract void readDependentEntities(Table table,
                                           Association association,
                                           java.sql.ResultSet resultSet,
                                           java.sql.ResultSetMetaData resultSetMetaData,
                                           Session.ResultSetReader reader,
                                           java.util.Map<java.lang.String,java.lang.Integer> typeCache,
                                           java.lang.String selectionSchema,
                                           java.lang.String originalPKAliasPrefix)
                                    throws java.sql.SQLException

Reads all entities which depends on given entity.

Parameters:

table - the table from which to read entities

association - the dependency

resultSet - current row is given entity

reader - reads the entities

selectionSchema - the selection schema

Throws:

java.sql.SQLException

markDependentEntitiesAsTraversed

public abstract void markDependentEntitiesAsTraversed(Association association,
                                                      java.sql.ResultSet resultSet,
                                                      java.sql.ResultSetMetaData resultSetMetaData,
                                                      java.util.Map<java.lang.String,java.lang.Integer> typeCache)
                                               throws java.sql.SQLException

Marks all entities which depends on given entity as traversed.

Parameters:

association - the dependency

resultSet - current row is given entity

Throws:

java.sql.SQLException

readNonTraversedDependencies

public abstract void readNonTraversedDependencies(Table table,
                                                  Session.ResultSetReader reader)
                                           throws java.sql.SQLException

Reads all non-traversed dependencies.

Parameters:

table - the source of dependencies to look for

reader - reads the entities

Throws:

java.sql.SQLException

removeReflexiveDependencies

public abstract void removeReflexiveDependencies(Table table)
                                          throws java.sql.SQLException

Removes all reflexive dependencies of given table.

Parameters:

table - the table

Throws:

java.sql.SQLException

getTotalRowcount

public abstract long getTotalRowcount()

Gets total row-count.

Returns:

total row-count

getUniversalPrimaryKey

public abstract PrimaryKey getUniversalPrimaryKey()

Gets the universal primary key.

Returns:

the universal primary key

shutDown

public abstract void shutDown()
                       throws java.sql.SQLException

Shuts down statement-executor.

Throws:

java.sql.SQLException

getSession

public abstract Session getSession()

Gets the session.

Returns:

the session

createUniqueGraphID

public static int createUniqueGraphID()

Creates a unique ID for a new graph.

Returns:

a unique ID

incLobCount

public int incLobCount()

Increments lob-counter and returns new value.

getDatamodel

public abstract DataModel getDatamodel()

close

public abstract void close()
                    throws java.sql.SQLException

Closes the graph. Deletes the local database.

Throws:

java.sql.SQLException

removeDependencies

public void removeDependencies(Association association)
                        throws java.sql.SQLException

Removes all dependencies for a given association.

Parameters:

association - the asociation

Throws:

java.sql.SQLException

getTargetSession

public abstract Session getTargetSession()

setDeleteMode

public void setDeleteMode(boolean deleteMode)

typeName

protected int typeName(Table table)

setTransformerFactory

public void setTransformerFactory(TransformerFactory transformerFactory)

Sets the TransformerFactory.

Parameters:

transformerFactory - the factory

getTransformerFactory

public TransformerFactory getTransformerFactory()

Gets the TransformerFactory.

Returns:

the factory

setImportFilterManager

public void setImportFilterManager(ImportFilterManager importFilterManager)

Sets the ImportFilterManager

Parameters:

importFilterManager - the ImportFilterManager

getImportFilterManager

public ImportFilterManager getImportFilterManager()

Gets the ImportFilterManager

Returns:

the ImportFilterManager

fillAndWriteMappingTables

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

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

Throws:

java.sql.SQLException

java.io.IOException

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.

Throws:

java.io.IOException

java.sql.SQLException

dmlTableReference

protected java.lang.String dmlTableReference(java.lang.String tableName,
                                             Session session)
                                      throws java.sql.SQLException

Gets table reference for DML statements for a given working table.

Parameters:

tableName - the working table

session - holds connection to DBMS

Returns:

table reference for the working table

Throws:

java.sql.SQLException

deleteRows

protected long deleteRows(Session session,
                          java.lang.String table,
                          java.lang.String where)
                   throws java.sql.SQLException

Deletes rows from table. Applies DBMS-specific deletion strategies, if available.

Parameters:

session - the session

table - the table

where - the "where" condition

Returns:

row count

Throws:

java.sql.SQLException

truncate

public void truncate(ExecutionContext executionContext,
                     boolean checkExist)
              throws java.sql.SQLException

Tries to delete this graph using "truncate".

Parameters:

checkExist - if true, checks existence of each graph

Throws:

java.sql.SQLException

checkExist

public void checkExist(ExecutionContext executionContext)
                throws java.sql.SQLException

Check if the graph still exists.

Throws:

java.sql.SQLException

addExportedCount

protected void addExportedCount(long count)

getExportedCount

public long getExportedCount()

getSelectionClause

protected java.util.List<Column> getSelectionClause(Table table)

Gets all non-virtual columns of the table in the order in which they are selected.

Returns:

all non-virtual columns of the table in the order in which they are selected

Throws:

java.lang.Exception - if selection clause is empty