fr.ifremer.adagio.synchro.intercept

Interface SynchroInterceptor

All Known Subinterfaces:

SynchroInterceptorChain

All Known Implementing Classes:

OracleInterceptor, RemoteIdWriteInterceptor, SynchroInterceptorBase

public interface SynchroInterceptor

Created on 4/10/14.

Since:

3.5.3

Author:

Benoit Lavenier

Method Summary

Methods

Modifier and Type	Method and Description
boolean	apply(SynchroDatabaseMetadata meta, TableMetadata table)
boolean	enableOnRead()
boolean	enableOnWrite()
SynchroInterceptor	getNext()
String	onCreateSelectQuery(SynchroTableMetadata table, String queryName, String selectQuery)
void	onJoinLoad(SynchroTableMetadata table, SynchroJoinMetadata join)
void	onRead(Object[] data, SynchroTableDao dao)
void	onTableLoad(SynchroTableMetadata table)
void	onWrite(Object[] data, SynchroTableDao dao, SynchroWriteBuffer buffer)
void	setContext(SynchroContext context)
void	setNext(SynchroInterceptor next)
Map<List<Object>,Object[]>	transformExtraLocalData(SynchroTableDao targetDao, SynchroTableDao sourceDao, Map<List<Object>,Object[]> extraRows) Given the extra rows of the local db, transform them to reinject them after in the current table.

Method Detail

apply

boolean apply(SynchroDatabaseMetadata meta,
            TableMetadata table)

setNext

void setNext(SynchroInterceptor next)

getNext

SynchroInterceptor getNext()

setContext

void setContext(SynchroContext context)

onRead

void onRead(Object[] data,
          SynchroTableDao dao)
            throws SQLException

Throws:

SQLException

onWrite

void onWrite(Object[] data,
           SynchroTableDao dao,
           SynchroWriteBuffer buffer)
             throws SQLException

Throws:

SQLException

transformExtraLocalData

Map<List<Object>,Object[]> transformExtraLocalData(SynchroTableDao targetDao,
                                                 SynchroTableDao sourceDao,
                                                 Map<List<Object>,Object[]> extraRows)
                                                   throws SQLException

Given the extra rows of the local db, transform them to reinject them after in the current table.

Parameters:

dbMetas -

localDao - dao of the local db

remoteDao - dao of the remote db

extraRows - extra rows of the local db to transform

Returns:

transformed extra rows of the local db

Throws:

SQLException

onTableLoad

void onTableLoad(SynchroTableMetadata table)

onJoinLoad

void onJoinLoad(SynchroTableMetadata table,
              SynchroJoinMetadata join)

onCreateSelectQuery

String onCreateSelectQuery(SynchroTableMetadata table,
                         String queryName,
                         String selectQuery)

enableOnRead

boolean enableOnRead()

enableOnWrite

boolean enableOnWrite()