fr.ifremer.adagio.synchro.service

Class SynchroContext

Object

SynchroContext

public class SynchroContext
extends Object

A context class, need for referential and data synchronization Created on 5/05/14.

Since:

3.5.3

Author:

Benoit Lavenier

Field Summary

Fields

Modifier and Type	Field and Description
protected SynchroResult	result
protected Properties	sourceConnectionProperties
protected Map<String,SynchroPendingOperationBuffer>	tableContextMap
protected Predicate<String>	tableFilter
protected Set<String>	tableNames
protected Properties	targetConnectionProperties

Constructor Summary

Constructors

Constructor and Description
SynchroContext()

Method Summary

Methods

Modifier and Type	Method and Description
void	addTableContext(String tableName, SynchroPendingOperationBuffer tableContext)
SynchroResult	getResult()
Properties	getSourceConnectionProperties()
SynchroPendingOperationBuffer	getTableContext(String tableName)
Predicate<String>	getTableFilter()
Set<String>	getTableNames()
Properties	getTargetConnectionProperties()
static SynchroContext	newContext(Set<String> tableNames, Predicate<String> tableFilter, Properties sourceConnectionProperties, Properties targetConnectionProperties, SynchroResult result) Create a new synchro context
static SynchroContext	newContext(Set<String> tableNames, Properties sourceConnectionProperties, Properties targetConnectionProperties, SynchroResult result) Create a new synchro context
void	removeTableContext(String tableName)
void	setResult(SynchroResult result)
void	setSourceConnectionProperties(Properties sourceConnectionProperties)
void	setTableFilter(Predicate<String> tableFilter)
void	setTableNames(Set<String> tableNames)
void	setTargetConnectionProperties(Properties targetConnectionProperties)

Methods inherited from class Object

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

Field Detail

sourceConnectionProperties

protected Properties sourceConnectionProperties

targetConnectionProperties

protected Properties targetConnectionProperties

result

protected SynchroResult result

tableFilter

protected Predicate<String> tableFilter

tableNames

protected Set<String> tableNames

tableContextMap

protected Map<String,SynchroPendingOperationBuffer> tableContextMap

Constructor Detail

SynchroContext

public SynchroContext()

Method Detail

newContext

public static SynchroContext newContext(Set<String> tableNames,
                        Predicate<String> tableFilter,
                        Properties sourceConnectionProperties,
                        Properties targetConnectionProperties,
                        SynchroResult result)

Create a new synchro context

Parameters:

tableNames - Table set to includes. If null, all tables will be processed by table filter

tableFilter - Use to filter tables to process. If null, given tables names will be processed. See SynchroMetadataUtils for predicate examples with includes/excludes.

sourceConnectionProperties - Connection properties for source database

targetConnectionProperties - Connection properties for target database

securityContext - A security context (use for data synchronization: see SynchroInterceptor)

result - Store the synchronization result

Returns:

a new synchro context

See Also:

SynchroInterceptor

newContext

public static SynchroContext newContext(Set<String> tableNames,
                        Properties sourceConnectionProperties,
                        Properties targetConnectionProperties,
                        SynchroResult result)

Create a new synchro context

Parameters:

tableNames - Table set to includes. If null, all tables will be retrieve.

sourceConnectionProperties - Connection properties for source database

targetConnectionProperties - Connection properties for target database

securityContext - A security context (use for data synchronisation)

result - Store the synchronization result

Returns:

a new synchro context

getResult

public SynchroResult getResult()

setResult

public void setResult(SynchroResult result)

setSourceConnectionProperties

public void setSourceConnectionProperties(Properties sourceConnectionProperties)

setTargetConnectionProperties

public void setTargetConnectionProperties(Properties targetConnectionProperties)

setTableFilter

public void setTableFilter(Predicate<String> tableFilter)

setTableNames

public void setTableNames(Set<String> tableNames)

getSourceConnectionProperties

public Properties getSourceConnectionProperties()

getTargetConnectionProperties

public Properties getTargetConnectionProperties()

getTableFilter

public Predicate<String> getTableFilter()

getTableNames

public Set<String> getTableNames()

getTableContext

public SynchroPendingOperationBuffer getTableContext(String tableName)

addTableContext

public void addTableContext(String tableName,
                   SynchroPendingOperationBuffer tableContext)

removeTableContext

public void removeTableContext(String tableName)