net.sf.jailer.entitygraph.remote

Class RemoteEntityGraph

java.lang.Object

net.sf.jailer.entitygraph.EntityGraph

net.sf.jailer.entitygraph.remote.RemoteEntityGraph

Direct Known Subclasses:

IntraDatabaseEntityGraph

public class RemoteEntityGraph
extends EntityGraph

Persistent graph of entities in the remote database.

Author:

Ralf Wisser

Field Summary

Fields

Modifier and Type	Field and Description
protected int	birthdayOfSubject Birthday of subject rows.
protected RowIdSupport	rowIdSupport RowIdSupport.
Session	session For executing SQL-Statements.
protected PrimaryKey	universalPrimaryKey The universal primary key.

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

dataModel, DEPENDENCY, ENTITY, ENTITY_GRAPH, ENTITY_SET_ELEMENT, executionContext, graphID, importFilterManager, inDeleteMode, isTruncated

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	RemoteEntityGraph(DataModel dataModel, int graphID, Session session, PrimaryKey universalPrimaryKey, java.lang.Runnable updateStatistics, ExecutionContext executionContext) Constructor.

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 session) Copies an entity-graph.
long	countEntities(Table table) Counts the entities of a given table in this graph.
static RemoteEntityGraph	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	delete(boolean force) 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.
protected java.lang.String	filteredSelectionClause(Table table, boolean appylImportFilter) Gets select clause for reading rows of given type with respect of the column filters.
protected java.lang.String	filteredSelectionClause(Table table, java.lang.String columnPrefix, Quoting quoting, boolean appylImportFilter) Gets select clause for reading rows of given type with respect of the column filters.
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.
long	getSize(java.util.Set<Table> tables) Gets the number of entities from given tables in the graph.
Session	getTargetSession()
long	getTotalRowcount() Gets total row-count.
PrimaryKey	getUniversalPrimaryKey() Gets the universal primary key.
protected static void	init(int graphID, Session session, ExecutionContext executionContext) Initializes a new entity-graph.
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.
protected java.lang.String	pkEqualsEntityID(Table table, java.lang.String tableAlias, java.lang.String entityAlias) Gets a SQL comparition expression for comparing rows with entities.
protected java.lang.String	prefixColumnName(java.lang.String prefix, Quoting quoting, Column column) Adds a prefix to a column name.
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.
void	readEntities(Table table, boolean orderByPK) Reads all entities of a given table.
protected long	readEntities(Table table, boolean orderByPK, Session.ResultSetReader reader) 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, 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

Field Detail

session

public final Session session

For executing SQL-Statements.

universalPrimaryKey

protected final PrimaryKey universalPrimaryKey

The universal primary key.

birthdayOfSubject

protected int birthdayOfSubject

Birthday of subject rows.

rowIdSupport

protected final RowIdSupport rowIdSupport

RowIdSupport.

Constructor Detail

RemoteEntityGraph

protected RemoteEntityGraph(DataModel dataModel,
                            int graphID,
                            Session session,
                            PrimaryKey universalPrimaryKey,
                            java.lang.Runnable updateStatistics,
                            ExecutionContext executionContext)
                     throws java.sql.SQLException

Constructor.

Parameters:

graphID - the unique ID of the graph

session - for executing SQL-Statements

universalPrimaryKey - the universal primary key

Throws:

java.sql.SQLException

Method Detail

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

init

protected static void init(int graphID,
                           Session session,
                           ExecutionContext executionContext)

Initializes a new entity-graph.

Parameters:

graphID - the unique ID of the graph

session - for executing SQL-Statements

copy

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

Copies an entity-graph.

Specified by:

copy in class EntityGraph

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.

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

getSize

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

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

Overrides:

getSize in class EntityGraph

Returns:

the number of entities in the graph

Throws:

java.sql.SQLException

delete

public void delete(boolean force)

Deletes the graph.

Specified by:

delete in class EntityGraph

Parameters:

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

readEntities

protected long readEntities(Table table,
                            boolean orderByPK,
                            Session.ResultSetReader reader)
                     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 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

filteredSelectionClause

protected java.lang.String filteredSelectionClause(Table table,
                                                   boolean appylImportFilter)

Gets select clause for reading rows of given type with respect of the column filters.

Parameters:

table - the table to read rows from

Returns:

select clause

filteredSelectionClause

protected java.lang.String filteredSelectionClause(Table table,
                                                   java.lang.String columnPrefix,
                                                   Quoting quoting,
                                                   boolean appylImportFilter)

Gets select clause for reading rows of given type with respect of the column filters.

Parameters:

table - the table to read rows from

columnPrefix - optional prefix for aliases

quoting - for unquoting of column names if columnPrefix is given

Returns:

select clause

prefixColumnName

protected java.lang.String prefixColumnName(java.lang.String prefix,
                                            Quoting quoting,
                                            Column column)

Adds a prefix to a column name. Respects quoting.

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:

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

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

association - the association

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> typeCache,
                                  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

pkEqualsEntityID

protected java.lang.String pkEqualsEntityID(Table table,
                                            java.lang.String tableAlias,
                                            java.lang.String entityAlias)

Gets a SQL comparition expression for comparing rows with entities.

Parameters:

table - the table

Returns:

a SQL comparition expression for comparing rows of table with entities

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

close

public void close()
           throws java.sql.SQLException

Description copied from class: EntityGraph

Closes the graph. Deletes the local database.

Specified by:

close in class EntityGraph

Throws:

java.sql.SQLException

getTargetSession

public Session getTargetSession()

Specified by:

getTargetSession in class EntityGraph