fr.ifremer.adagio.core.service.technical.synchro

Class ReferentialSynchroServiceImpl

Object

ReferentialSynchroServiceImpl

All Implemented Interfaces:

ReferentialSynchroService

Deprecated.

Use fr.ifremer.adagio.synchro.service.referential.ReferentialSynchroServiceImpl

@Service(value="referentialSynchroService")
@Lazy
public class ReferentialSynchroServiceImpl
extends Object
implements ReferentialSynchroService

Created on 1/14/14.

Since:

3.0

Author:

Tony Chemit

Field Summary

Fields

Modifier and Type	Field and Description
protected DriverManagerDataSource	dataSource Deprecated.
protected Properties	dbconnexionProperties Deprecated.
protected Map<String,ReferentialSynchroSpecificTableTask>	extraTasks Deprecated.
protected Dialect	localDialect Deprecated.
protected SessionFactory	sessionFactory Deprecated.

Constructor Summary

Constructors

Constructor and Description
ReferentialSynchroServiceImpl() Deprecated.

Method Summary

Methods

Modifier and Type	Method and Description
protected void	checkSchemas(ReferentialSynchroDatabaseMetadata schema1, ReferentialSynchroDatabaseMetadata schema2) Deprecated. Check that the tow given datasource shemas are compatible for a synchronize operation (same tables with same columns).
Map<String,ReferentialSynchroSpecificTableTask>	getExtraTasks() Deprecated.
Properties	getLocalConnectionProperties() Deprecated. Get the db connexion informations for the internal data source.
Dialect	getLocalDialect() Deprecated. Gets the dialect used by the local database.
void	prepare(ReferentialSynchroContext synchroContext) Deprecated. Prepare the synchronize operation from the local data database supported by this service, says just compute nb rows to update for each table and update the result model.
protected void	prepareTable(ReferentialSynchroTableMetadata table, Connection localConnection, Connection remoteConnection, ReferentialSynchroResult result) Deprecated.
protected void	reportProgress(ReferentialSynchroResult result, ReferentialSynchroTableTool dao, int countR, String tablePrefix) Deprecated.
void	synchronize(ReferentialSynchroContext synchroContext) Deprecated. Launch the synchronize operation from the local data database supported by this service.
protected void	synchronizeTable(ReferentialSynchroDatabaseMetadata dbMetas, ReferentialSynchroTableMetadata table, Connection localConnection, Connection remoteConnection, ReferentialSynchroSpecificTableTask extraTask, ReferentialSynchroResult result) Deprecated.
protected void	updateBigTable(ReferentialSynchroDatabaseMetadata dbMetas, ReferentialSynchroTableTool localDao, ReferentialSynchroTableTool remoteDao, ResultSet incomingData, ReferentialSynchroSpecificTableTask extraTask, ReferentialSynchroResult result) Deprecated. To update the content of the given table (with a lot of rows) on the local db, from the given incomingData of the remote db.
protected void	updateTable(ReferentialSynchroTableTool localDao, ResultSet incomingData, ReferentialSynchroResult result) Deprecated. To update the content of the given table on the local db, from the given incomingData of the remote db.

Methods inherited from class Object

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

Field Detail

dataSource

@Autowired
protected DriverManagerDataSource dataSource

Deprecated.

sessionFactory

@Autowired
protected SessionFactory sessionFactory

Deprecated.

localDialect

protected Dialect localDialect

Deprecated.

dbconnexionProperties

protected Properties dbconnexionProperties

Deprecated.

extraTasks

protected Map<String,ReferentialSynchroSpecificTableTask> extraTasks

Deprecated.

Constructor Detail

ReferentialSynchroServiceImpl

public ReferentialSynchroServiceImpl()

Deprecated.

Method Detail

getLocalConnectionProperties

public Properties getLocalConnectionProperties()

Deprecated.

Description copied from interface: ReferentialSynchroService

Get the db connexion informations for the internal data source.

Specified by:

getLocalConnectionProperties in interface ReferentialSynchroService

Returns:

the db connexion for the internal data source

getLocalDialect

public Dialect getLocalDialect()

Deprecated.

Description copied from interface: ReferentialSynchroService

Gets the dialect used by the local database.

Specified by:

getLocalDialect in interface ReferentialSynchroService

Returns:

the dialect used by the local database.

getExtraTasks

public Map<String,ReferentialSynchroSpecificTableTask> getExtraTasks()

Deprecated.

prepare

public void prepare(ReferentialSynchroContext synchroContext)

Deprecated.

Description copied from interface: ReferentialSynchroService

Prepare the synchronize operation from the local 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 ReferentialSynchroService

Parameters:

synchroContext - context of synchro operation

synchronize

public void synchronize(ReferentialSynchroContext synchroContext)

Deprecated.

Description copied from interface: ReferentialSynchroService

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

Specified by:

synchronize in interface ReferentialSynchroService

Parameters:

synchroContext - context of synchro operation

checkSchemas

protected void checkSchemas(ReferentialSynchroDatabaseMetadata schema1,
                ReferentialSynchroDatabaseMetadata schema2)

Deprecated.

Check that the tow given datasource shemas are compatible for a synchronize operation (same tables with same columns).

If schemas are incompatible, then a DataRetrievalFailureException exception will be thrown.

Parameters:

schema1 - schema 1 to check

schema2 - schema 2 to check

prepareTable

protected void prepareTable(ReferentialSynchroTableMetadata table,
                Connection localConnection,
                Connection remoteConnection,
                ReferentialSynchroResult result)
                     throws SQLException

Deprecated.

Throws:

SQLException

synchronizeTable

protected void synchronizeTable(ReferentialSynchroDatabaseMetadata dbMetas,
                    ReferentialSynchroTableMetadata table,
                    Connection localConnection,
                    Connection remoteConnection,
                    ReferentialSynchroSpecificTableTask extraTask,
                    ReferentialSynchroResult result)
                         throws SQLException

Deprecated.

Throws:

SQLException

updateTable

protected void updateTable(ReferentialSynchroTableTool localDao,
               ResultSet incomingData,
               ReferentialSynchroResult result)
                    throws SQLException

Deprecated.

To update the content of the given table on the local db, from the given incomingData of the remote db.

The algorithm is pretty simple, for each row of the incomingData, if exists on local table, then do an update, otherwise do a insert.

As an update query is more expensive, we won't use this method for table with a lot of rows, we will prefer to use the updateBigTable method instead.

Parameters:

localDao - connection on the local db

incomingData - data to update from the remote db

result - where to store operation results

Throws:

SQLException - if any sql errors

updateBigTable

protected void updateBigTable(ReferentialSynchroDatabaseMetadata dbMetas,
                  ReferentialSynchroTableTool localDao,
                  ReferentialSynchroTableTool remoteDao,
                  ResultSet incomingData,
                  ReferentialSynchroSpecificTableTask extraTask,
                  ReferentialSynchroResult result)
                       throws SQLException

Deprecated.

To update the content of the given table (with a lot of rows) on the local db, from the given incomingData of the remote db.

We can't use the simple algorithm, since update queries cost too much and is not acceptable when talking on huge numbers of rows.

Here is what to do :

• Get form the local db the data which are not in remote db, keep them
• Delete local table content
• Insert remote table in local table
• Insert the saved extra rows from original table

In that way we will only perform some insert queries.

Parameters:

dbMetas -

localDao - connection on the local db

remoteDao - connection on the local db

incomingData - data to update from the remote db

extraTask -

result - where to store operation results @throws SQLException if any sql errors

Throws:

SQLException

reportProgress

protected void reportProgress(ReferentialSynchroResult result,
                  ReferentialSynchroTableTool dao,
                  int countR,
                  String tablePrefix)

Deprecated.