com.evolveum.midpoint.repo.sql.helpers

Class OrgClosureManager

java.lang.Object

com.evolveum.midpoint.repo.sql.helpers.OrgClosureManager

@Component
@DependsOn(value="repositoryService")
public class OrgClosureManager
extends Object

This class and its subclasses provides org. closure table handling. Data structures used are: (1) Repo object graph G = (V, E) where V is a set of vertices (repo objects) and E is a set of edges (parentRef relations). There is an edge e = (V1, V2) in E [i.e. edge from V1 to V2] if and only if V1.parentRef contains V2 [i.e. V2 is a parent of V1]. (2) OrgClosure table. OrgClosure(D, A, N) iff there are exactly N paths in object graph from D (descendant) to A (ascendant). It is transitive reflexive closure, i.e. OrgClosure(V, V, 1) items are there as well. Algorithms taken from "SQL Design Patterns" book by Vadim Tropashko (http://vadimtropashko.wordpress.com/) namely from Chapter 6 (http://vadimtropashko.files.wordpress.com/2014/01/book_sql_chap6_v1.pdf). SQL queries were then optimized by hand for various database engines.

Author:

lazyman, mederly

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	OrgClosureManager.Context
static class	OrgClosureManager.Edge
static class	OrgClosureManager.Operation
static class	OrgClosureManager.StartupAction

Field Summary

Fields

Modifier and Type	Field and Description
static String	TEMP_DELTA_TABLE_NAME_FOR_ORACLE

Constructor Summary

Constructors

Constructor and Description
OrgClosureManager()

Method Summary

Methods

Modifier and Type	Method and Description
void	checkAndOrRebuild(boolean check, boolean rebuild, boolean stopOnFailure, boolean quickCheckOnly, OperationResult result) Does a consistency check (either quick or thorough one) and rebuilds the closure table if necessary.
void	cleanUpAfterOperation(OrgClosureManager.Context closureContext, org.hibernate.Session session)
long	getLastOperationDuration()
void	initialize()
boolean	isEnabled()
<T extends com.evolveum.midpoint.xml.ns._public.common.common_3.ObjectType> OrgClosureManager.Context	onBeginTransactionAdd(org.hibernate.Session session, PrismObject<T> object, boolean overwrite)
<T extends com.evolveum.midpoint.xml.ns._public.common.common_3.ObjectType> OrgClosureManager.Context	onBeginTransactionDelete(org.hibernate.Session session, Class<T> type, String oid)
<T extends com.evolveum.midpoint.xml.ns._public.common.common_3.ObjectType> OrgClosureManager.Context	onBeginTransactionModify(org.hibernate.Session session, Class<T> type, String oid, Collection<? extends ItemDelta> modifications)
<T extends com.evolveum.midpoint.xml.ns._public.common.common_3.ObjectType> void	updateOrgClosure(PrismObject<? extends com.evolveum.midpoint.xml.ns._public.common.common_3.ObjectType> originalObject, Collection<? extends ItemDelta> modifications, org.hibernate.Session session, String oid, Class<T> type, OrgClosureManager.Operation operation, OrgClosureManager.Context closureContext) Main method called from SQL repository service to update the closure table during an operation.

Methods inherited from class java.lang.Object

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

Field Detail

TEMP_DELTA_TABLE_NAME_FOR_ORACLE

public static final String TEMP_DELTA_TABLE_NAME_FOR_ORACLE

See Also:

Constant Field Values

Constructor Detail

OrgClosureManager

public OrgClosureManager()

Method Detail

updateOrgClosure

public <T extends com.evolveum.midpoint.xml.ns._public.common.common_3.ObjectType> void updateOrgClosure(PrismObject<? extends com.evolveum.midpoint.xml.ns._public.common.common_3.ObjectType> originalObject,
                                                                                                Collection<? extends ItemDelta> modifications,
                                                                                                org.hibernate.Session session,
                                                                                                String oid,
                                                                                                Class<T> type,
                                                                                                OrgClosureManager.Operation operation,
                                                                                                OrgClosureManager.Context closureContext)

Main method called from SQL repository service to update the closure table during an operation.

Parameters:

originalObject - Original state of the object - before applying modification in the repository. It is used only in case of MODIFY (note that "overwriting ADD" is present here as MODIFY!)

modifications - Collection of modifications to be applied to the object.

session - Database session to use.

oid - OID of the object.

type - Type of the object.

operation - Operation that is carried out.

closureContext -

onBeginTransactionAdd

public <T extends com.evolveum.midpoint.xml.ns._public.common.common_3.ObjectType> OrgClosureManager.Context onBeginTransactionAdd(org.hibernate.Session session,
                                                                                                                          PrismObject<T> object,
                                                                                                                          boolean overwrite)

onBeginTransactionModify

public <T extends com.evolveum.midpoint.xml.ns._public.common.common_3.ObjectType> OrgClosureManager.Context onBeginTransactionModify(org.hibernate.Session session,
                                                                                                                             Class<T> type,
                                                                                                                             String oid,
                                                                                                                             Collection<? extends ItemDelta> modifications)

onBeginTransactionDelete

public <T extends com.evolveum.midpoint.xml.ns._public.common.common_3.ObjectType> OrgClosureManager.Context onBeginTransactionDelete(org.hibernate.Session session,
                                                                                                                             Class<T> type,
                                                                                                                             String oid)

cleanUpAfterOperation

public void cleanUpAfterOperation(OrgClosureManager.Context closureContext,
                         org.hibernate.Session session)

initialize

@PostConstruct
public void initialize()

isEnabled

public boolean isEnabled()

checkAndOrRebuild

public void checkAndOrRebuild(boolean check,
                     boolean rebuild,
                     boolean stopOnFailure,
                     boolean quickCheckOnly,
                     OperationResult result)

Does a consistency check (either quick or thorough one) and rebuilds the closure table if necessary. Quick check is conducted by comparing whether are there any orgs without entries in closure (the reverse direction is ensured via foreign keys in m_org_closure). Thorough check is conducted by recomputing the closure table.

getLastOperationDuration

public long getLastOperationDuration()