fr.ifremer.adagio.synchro.service.data

Class DataSynchroServiceImpl

Object

SynchroBaseService

DataSynchroServiceImpl

All Implemented Interfaces:

DataSynchroService

@Service(value="dataSynchroService")
@Lazy
public class DataSynchroServiceImpl
extends SynchroBaseService
implements DataSynchroService

Created on 1/14/14.

Since:

3.5.2

Author:

Benoit Lavenier

Field Summary

Fields inherited from class SynchroBaseService

batchSize, config, daoInterceptors, dataSource

Constructor Summary

Constructors

Constructor and Description
DataSynchroServiceImpl()
DataSynchroServiceImpl(DataSource dataSource, SynchroConfiguration config)

Method Summary

Methods

Modifier and Type	Method and Description
SynchroContext	createSynchroContext(File sourceDbDirectory) Create a synchro context, from a source database directory (HSQLDB only).
SynchroContext	createSynchroContext(Properties sourceConnectionProperties) Create a synchro context, using configuration properties for target and source properties.
protected Properties	getRemoteProperties(File dbDirectory)
void	prepare(SynchroContext synchroContext) Prepare the synchronize operation from the target data database supported by this service, says just compute nb rows to update for each table and update the result model.
protected void	prepareRootTable(SynchroTableMetadata sourceTable, SynchroTableMetadata targetTable, Connection sourceConnection, Connection targetConnection, SynchroResult result)
void	synchronize(SynchroContext synchroContext) Launch the synchronize operation from the target data database supported by this service.
protected void	synchronizeChildTable(SynchroTableMetadata table, String joinColumnName, Set<Integer> joinColumnIds, Connection sourceConnection, Connection targetConnection, SynchroResult result, SynchroPendingOperationBuffer tableBuffer)
protected void	synchronizeChildTables(SynchroTableMetadata parentTable, Set<Integer> parentRemoteIds, SynchroContext context, Connection sourceConnection, Connection targetConnection, SynchroResult result, boolean enableLogCount)
protected void	synchronizeRootTable(SynchroTableMetadata table, SynchroContext context, Connection sourceConnection, Connection targetConnection, SynchroResult result, SynchroPendingOperationBuffer tableBuffer)
protected void	updateTableNoRemoteId(SynchroTableDao targetDao, ResultSet incomingData, SynchroResult result, SynchroPendingOperationBuffer tableBuffer) To update the content of the given table on the target db, from the given incomingData of the source db.
protected void	updateTableUsingRemoteId(SynchroTableDao targetDao, ResultSet incomingData, SynchroResult result, SynchroPendingOperationBuffer tableBuffer) To update the content of the given table on the target db, from the given incomingData of the source db.

Methods inherited from class SynchroBaseService

getInterceptor, getInterceptors, reportProgress

Methods inherited from class Object

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

Constructor Detail

DataSynchroServiceImpl

public DataSynchroServiceImpl(DataSource dataSource,
                      SynchroConfiguration config)

DataSynchroServiceImpl

public DataSynchroServiceImpl()

Method Detail

createSynchroContext

public SynchroContext createSynchroContext(File sourceDbDirectory)

Description copied from interface: DataSynchroService

Create a synchro context, from a source database directory (HSQLDB only). This use local connection properties as source properties, but change JDBC URL to use the given directory

Specified by:

createSynchroContext in interface DataSynchroService

Parameters:

sourceDbDirectory - a directory with a HSQLDB directory.

Returns:

a new context for synchronization

createSynchroContext

public SynchroContext createSynchroContext(Properties sourceConnectionProperties)

Description copied from interface: DataSynchroService

Create a synchro context, using configuration properties for target and source properties.

Specified by:

createSynchroContext in interface DataSynchroService

Parameters:

sourceConnectionProperties - Properties to use as source connection (could be Oracle, HSQLDB...)

Returns:

a new context for synchronization

prepare

public void prepare(SynchroContext synchroContext)

Description copied from interface: DataSynchroService

Prepare the synchronize operation from the target data database supported by this service, says just compute nb rows to update for each table and update the result model.

Specified by:

prepare in interface DataSynchroService

Parameters:

synchroContext - Context of synchronization

synchronize

public void synchronize(SynchroContext synchroContext)

Description copied from interface: DataSynchroService

Launch the synchronize operation from the target data database supported by this service.

Specified by:

synchronize in interface DataSynchroService

Parameters:

synchroContext - Context of synchronization

prepareRootTable

protected void prepareRootTable(SynchroTableMetadata sourceTable,
                    SynchroTableMetadata targetTable,
                    Connection sourceConnection,
                    Connection targetConnection,
                    SynchroResult result)
                         throws SQLException

Throws:

SQLException

synchronizeRootTable

protected void synchronizeRootTable(SynchroTableMetadata table,
                        SynchroContext context,
                        Connection sourceConnection,
                        Connection targetConnection,
                        SynchroResult result,
                        SynchroPendingOperationBuffer tableBuffer)
                             throws SQLException

Throws:

SQLException

synchronizeChildTable

protected void synchronizeChildTable(SynchroTableMetadata table,
                         String joinColumnName,
                         Set<Integer> joinColumnIds,
                         Connection sourceConnection,
                         Connection targetConnection,
                         SynchroResult result,
                         SynchroPendingOperationBuffer tableBuffer)
                              throws SQLException

Throws:

SQLException

updateTableUsingRemoteId

protected void updateTableUsingRemoteId(SynchroTableDao targetDao,
                            ResultSet incomingData,
                            SynchroResult result,
                            SynchroPendingOperationBuffer tableBuffer)
                                 throws SQLException

To update the content of the given table on the target db, from the given incomingData of the source db.

The algorithm use remote_id : for each row of the incomingData, if exists on target table, then do an update, otherwise do a insert.

Parameters:

synchroContext - Synchronization context

targetDao - connection on the target db

incomingData - data to update from the source db

result - where to store operation results

Throws:

SQLException - if any sql errors

updateTableNoRemoteId

protected void updateTableNoRemoteId(SynchroTableDao targetDao,
                         ResultSet incomingData,
                         SynchroResult result,
                         SynchroPendingOperationBuffer tableBuffer)
                              throws SQLException

To update the content of the given table on the target db, from the given incomingData of the source db. The algorithm use a standard update strategy, using primary key.

Parameters:

synchroContext -

targetDao -

incomingData -

result -

Throws:

SQLException

getRemoteProperties

protected Properties getRemoteProperties(File dbDirectory)

synchronizeChildTables

protected void synchronizeChildTables(SynchroTableMetadata parentTable,
                          Set<Integer> parentRemoteIds,
                          SynchroContext context,
                          Connection sourceConnection,
                          Connection targetConnection,
                          SynchroResult result,
                          boolean enableLogCount)
                               throws SQLException

Throws:

SQLException