fr.ifremer.adagio.synchro.service.referential

Class ReferentialSynchroServiceImpl

Object

SynchroBaseService

ReferentialSynchroServiceImpl

All Implemented Interfaces:

ReferentialSynchroService

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

Created on 1/14/14.

Since:

3.0

Author:

Tony Chemit

Field Summary

Fields inherited from class SynchroBaseService

batchSize, config, daoInterceptors, dataSource

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
protected void	closeSilently(Connection connection)
protected Connection	createConnection(Properties connectionProperties)
protected Connection	createConnection(String jdbcUrl, String user, String password)
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.
void	prepare(SynchroContext synchroContext) 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	prepareSynch(Connection connection)
protected void	prepareTable(SynchroTableMetadata sourceTable, SynchroTableMetadata targetTable, SynchroContext context, Connection targetConnection, Connection sourceConnection, SynchroResult result)
protected void	releaseSynch(Connection connection)
protected void	reportProgress(SynchroResult result, SynchroTableDao dao, int countR, String tablePrefix)
void	synchronize(SynchroContext synchroContext) Launch the synchronize operation from the local data database supported by this service.
protected void	synchronizeTable(SynchroTableMetadata table, Connection targetConnection, Connection sourceConnection, SynchroResult result)
protected void	updateBigTable(SynchroTableDao targetDao, SynchroTableDao sourceDao, ResultSet incomingData, SynchroResult result) To update the content of the given table (with a lot of rows) on the target db, from the given incomingData of the source db.
protected void	updateTable(SynchroTableDao targetDao, ResultSet incomingData, SynchroResult result) 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

Methods inherited from class Object

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

Constructor Detail

ReferentialSynchroServiceImpl

@Autowired
public ReferentialSynchroServiceImpl(DataSource dataSource,
                                       SynchroConfiguration config)

ReferentialSynchroServiceImpl

public ReferentialSynchroServiceImpl()

Method Detail

createSynchroContext

public SynchroContext createSynchroContext(File sourceDbDirectory)

Description copied from interface: ReferentialSynchroService

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 ReferentialSynchroService

Parameters:

sourceDbDirectory - a directory with a HSQLDB directory.

Returns:

a new context for synchronization

createSynchroContext

public SynchroContext createSynchroContext(Properties sourceConnectionProperties)

Description copied from interface: ReferentialSynchroService

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

Specified by:

createSynchroContext in interface ReferentialSynchroService

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: 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(SynchroContext synchroContext)

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

prepareTable

protected void prepareTable(SynchroTableMetadata sourceTable,
                SynchroTableMetadata targetTable,
                SynchroContext context,
                Connection targetConnection,
                Connection sourceConnection,
                SynchroResult result)
                     throws SQLException

Throws:

SQLException

synchronizeTable

protected void synchronizeTable(SynchroTableMetadata table,
                    Connection targetConnection,
                    Connection sourceConnection,
                    SynchroResult result)
                         throws SQLException

Throws:

SQLException

updateTable

protected void updateTable(SynchroTableDao targetDao,
               ResultSet incomingData,
               SynchroResult result)
                    throws SQLException

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

The algorithm is pretty simple, for each row of the incomingData, if exists on target 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:

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

updateBigTable

protected void updateBigTable(SynchroTableDao targetDao,
                  SynchroTableDao sourceDao,
                  ResultSet incomingData,
                  SynchroResult result)
                       throws SQLException

To update the content of the given table (with a lot of rows) on the target db, from the given incomingData of the source 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 target db the data which are not in source db, keep them
• Delete target table content
• Insert source table in target table
• Insert the saved extra rows from original table

In that way we will only perform some insert queries.

Parameters:

dbMetas -

targetDao - connection on the target db

sourceDao - connection on the target db

incomingData - data to update from the source db

interceptor -

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

Throws:

SQLException

reportProgress

protected void reportProgress(SynchroResult result,
                  SynchroTableDao dao,
                  int countR,
                  String tablePrefix)

Overrides:

reportProgress in class SynchroBaseService

createConnection

protected Connection createConnection(Properties connectionProperties)
                               throws SQLException

Throws:

SQLException

createConnection

protected Connection createConnection(String jdbcUrl,
                          String user,
                          String password)
                               throws SQLException

Throws:

SQLException

closeSilently

protected void closeSilently(Connection connection)

prepareSynch

protected void prepareSynch(Connection connection)
                     throws SQLException

Throws:

SQLException

releaseSynch

protected void releaseSynch(Connection connection)
                     throws SQLException

Throws:

SQLException