net.sf.jailer.entitygraph.local

Class LocalEntityGraph

java.lang.Object

net.sf.jailer.entitygraph.EntityGraph

net.sf.jailer.entitygraph.local.LocalEntityGraph

public class LocalEntityGraph
extends EntityGraph

Persistent graph of entities. Persists the graph in a local database.

Author:

Ralf Wisser

Field Summary

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
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.
long	addEntities(Table table, java.lang.String condition, int today) Adds entities to the graph.
long	addEntities(Table table, java.lang.String condition, int today, SubjectLimitDefinition limitDefinition, boolean joinWithEntity) Adds limited number of entities to the graph.
void	close() Closes the graph.
EntityGraph	copy(int newGraphID, Session _unused) Copies an entity-graph.
long	countEntities(Table table) Counts the entities of a given table in this graph.
static LocalEntityGraph	create(DataModel dataModel, int graphID, Session remoteSession, ExecutionContext executionContext) Creates a new entity-graph.
EntityGraph	createNewGraph() Creates a new entity-graph of same type and session.
void	delete(boolean forced) Deletes the graph.
long	deleteEntities(Table table) Deletes all entities from a given table.
void	deleteIndependentEntities(Table table) Deletes all entities which are marked as independent.
int	getAge() Gets the age of the graph.
DataModel	getDatamodel()
java.util.Set<java.lang.Integer>	getDistinctDependencyIDs() Gets distinct association-ids of all edged.
Session	getSession() Gets the session.
long	getSize() Gets the number of entities in the graph.
Session	getTargetSession()
long	getTotalRowcount() Gets total row-count.
PrimaryKey	getUniversalPrimaryKey() Gets the universal primary key.
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.
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.
void	markRoots(Table table) Marks all rows which are not target of a dependency.
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> theTypeCache, java.lang.String selectionSchema, java.lang.String originalPKAliasPrefix) Reads all entities which depends on given entity.
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	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.
void	readNonTraversedDependencies(Table table, Session.ResultSetReader reader) Reads all non-traversed dependencies.
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.
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	removeReflexiveDependencies(Table table) Removes all reflexive dependencies of given table.
long	resolveAssociation(Table table, Association association, EntityGraph otherGraph, EntityGraph universum, boolean forDelete) Resolves an association.
long	resolveAssociation(Table table, Association association, int today) Resolves an association.
void	setAge(int age) Sets the age of the graph.
void	setBirthdayOfSubject(int birthdayOfSubject) Sets birthday of subject rows.
void	shutDown() Shuts down statement-executor.
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.EntityGraph

addExportedCount, checkExist, copy, createUniqueGraphID, delete, deleteRows, dmlTableReference, dropMappingTables, fillAndWriteMappingTables, getExportedCount, getImportFilterManager, getSelectionClause, getSize, 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

close

public void close()
           throws java.sql.SQLException

Closes the graph. Deletes the local database.

Specified by:

close in class EntityGraph

Throws:

java.sql.SQLException

setBirthdayOfSubject

public void setBirthdayOfSubject(int birthdayOfSubject)

Sets birthday of subject rows.

Specified by:

setBirthdayOfSubject in class EntityGraph

Parameters:

birthdayOfSubject - birthday of subject rows

create

public static LocalEntityGraph create(DataModel dataModel,
                                      int graphID,
                                      Session remoteSession,
                                      ExecutionContext executionContext)
                               throws java.io.IOException,
                                      java.sql.SQLException

Creates a new entity-graph.

Parameters:

graphID - the unique ID of the graph

remoteSession - for executing SQL-Statements

Returns:

the newly created entity-graph

Throws:

java.io.IOException

java.sql.SQLException

copy

public EntityGraph copy(int newGraphID,
                        Session _unused)
                 throws java.sql.SQLException

Copies an entity-graph.

Specified by:

copy in class EntityGraph

Parameters:

newGraphID - the unique ID of the new graph

_unused - 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.

Specified by:

createNewGraph in class EntityGraph

Throws:

java.sql.SQLException

getAge

public int getAge()
           throws java.sql.SQLException

Gets the age of the graph.

Specified by:

getAge in class EntityGraph

Returns:

the age of the graph

Throws:

java.sql.SQLException

setAge

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

Sets the age of the graph.

Specified by:

setAge in class EntityGraph

Parameters:

age - the age of the graph

Throws:

java.sql.SQLException

getSize

public long getSize()
             throws java.sql.SQLException

Gets the number of entities in the graph.

Specified by:

getSize in class EntityGraph

Returns:

the number of entities in the graph

Throws:

java.sql.SQLException

delete

public void delete(boolean forced)

Deletes the graph.

Specified by:

delete in class EntityGraph

Parameters:

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

addEntities

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

Adds entities to the graph.

Specified by:

addEntities in class EntityGraph

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

Specified by:

addEntities in class EntityGraph

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

Specified by:

resolveAssociation in class EntityGraph

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

Specified by:

resolveAssociation in class EntityGraph

Parameters:

table - the table

association - the association to resolve

Returns:

row-count

Throws:

java.sql.SQLException

addDependencies

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

Specified by:

addDependencies in class EntityGraph

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 java.util.Set<java.lang.Integer> getDistinctDependencyIDs()
                                                          throws java.sql.SQLException

Gets distinct association-ids of all edged.

Specified by:

getDistinctDependencyIDs in class EntityGraph

Throws:

java.sql.SQLException

markIndependentEntities

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

Specified by:

markIndependentEntities in class EntityGraph

Throws:

java.sql.SQLException

markRoots

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

Marks all rows which are not target of a dependency.

Specified by:

markRoots in class EntityGraph

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.

Specified by:

readMarkedEntities in class EntityGraph

Parameters:

table - the table

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

Throws:

java.sql.SQLException

readMarkedEntities

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

Specified by:

readMarkedEntities in class EntityGraph

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

Reads all entities of a given table.

Specified by:

readEntities in class EntityGraph

Parameters:

table - the table

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

Throws:

java.sql.SQLException

readUnfilteredEntityColumns

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

Specified by:

readUnfilteredEntityColumns in class EntityGraph

Parameters:

table - the table

columns - the columns

reader - to read

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.

Specified by:

updateEntities in class EntityGraph

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

deleteIndependentEntities

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

Deletes all entities which are marked as independent.

Specified by:

deleteIndependentEntities in class EntityGraph

Throws:

java.sql.SQLException

deleteEntities

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

Deletes all entities from a given table.

Specified by:

deleteEntities in class EntityGraph

Throws:

java.sql.SQLException

countEntities

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

Counts the entities of a given table in this graph.

Specified by:

countEntities in class EntityGraph

Parameters:

table - the table

Returns:

the number of entities from table in this graph

Throws:

java.sql.SQLException

removeAssociatedDestinations

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

Specified by:

removeAssociatedDestinations in class EntityGraph

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 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> theTypeCache,
                                  java.lang.String selectionSchema,
                                  java.lang.String originalPKAliasPrefix)
                           throws java.sql.SQLException

Reads all entities which depends on given entity.

Specified by:

readDependentEntities in class EntityGraph

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

Specified by:

markDependentEntitiesAsTraversed in class EntityGraph

Parameters:

association - the dependency

resultSet - current row is given entity

Throws:

java.sql.SQLException

readNonTraversedDependencies

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

Reads all non-traversed dependencies.

Specified by:

readNonTraversedDependencies in class EntityGraph

Parameters:

table - the source of dependencies to look for

reader - reads the entities

Throws:

java.sql.SQLException

removeReflexiveDependencies

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

Removes all reflexive dependencies of given table.

Specified by:

removeReflexiveDependencies in class EntityGraph

Parameters:

table - the table

Throws:

java.sql.SQLException

getTotalRowcount

public long getTotalRowcount()

Gets total row-count.

Specified by:

getTotalRowcount in class EntityGraph

Returns:

total row-count

getUniversalPrimaryKey

public PrimaryKey getUniversalPrimaryKey()

Gets the universal primary key.

Specified by:

getUniversalPrimaryKey in class EntityGraph

Returns:

the universal primary key

shutDown

public void shutDown()
              throws java.sql.SQLException

Shuts down statement-executor.

Specified by:

shutDown in class EntityGraph

Throws:

java.sql.SQLException

getSession

public Session getSession()

Description copied from class: EntityGraph

Gets the session.

Specified by:

getSession in class EntityGraph

Returns:

the session

getDatamodel

public DataModel getDatamodel()

Specified by:

getDatamodel in class EntityGraph

getTargetSession

public Session getTargetSession()

Specified by:

getTargetSession in class EntityGraph