fr.ifremer.adagio.synchro.intercept

Class SynchroInterceptorBase

Object

SynchroInterceptorBase

All Implemented Interfaces:

SynchroInterceptor, SynchroInterceptorChain

Direct Known Subclasses:

OracleInterceptor, RemoteIdWriteInterceptor

public class SynchroInterceptorBase
extends Object
implements SynchroInterceptorChain

Constructor Summary

Constructors

Constructor and Description
SynchroInterceptorBase()
SynchroInterceptorBase(SynchroInterceptor next)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	apply(SynchroDatabaseMetadata meta, TableMetadata table)
protected String	doCreateSelectQuery(SynchroTableMetadata table, String queryName, String sql)
protected String	doCreateSelectQuery(SynchroTableMetadata table, String selectClause, String fromClause, String whereClause, String queryName) Default implementation, that return the same SQL query.
protected void	doJoinLoad(SynchroTableMetadata table, SynchroJoinMetadata join)
protected void	doOnRead(Object[] data, SynchroTableDao dao)
protected void	doOnWrite(Object[] data, SynchroTableDao dao, SynchroWriteBuffer buffer)
protected void	doTableLoad(SynchroTableMetadata table)
protected Map<List<Object>,Object[]>	doTransformExtraLocalData(SynchroTableDao localDao, SynchroTableDao remoteDao, Map<List<Object>,Object[]> extraRows)
boolean	enableOnRead()
boolean	enableOnWrite()
protected SynchroContext	getContext()
SynchroInterceptor	getNext()
String	onCreateSelectQuery(SynchroTableMetadata table, String queryName, String sql)
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 localDao, SynchroTableDao remoteDao, Map<List<Object>,Object[]> extraRows) Given the extra rows of the local db, transform them to reinject them after in the current table.

Methods inherited from class Object

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

Constructor Detail

SynchroInterceptorBase

public SynchroInterceptorBase()

SynchroInterceptorBase

public SynchroInterceptorBase(SynchroInterceptor next)

Method Detail

apply

public boolean apply(SynchroDatabaseMetadata meta,
            TableMetadata table)

Specified by:

apply in interface SynchroInterceptor

setNext

public void setNext(SynchroInterceptor next)

Specified by:

setNext in interface SynchroInterceptor

Specified by:

setNext in interface SynchroInterceptorChain

getNext

public SynchroInterceptor getNext()

Specified by:

getNext in interface SynchroInterceptor

Specified by:

getNext in interface SynchroInterceptorChain

onRead

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

Specified by:

onRead in interface SynchroInterceptor

Throws:

SQLException

onWrite

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

Specified by:

onWrite in interface SynchroInterceptor

Throws:

SQLException

transformExtraLocalData

public Map<List<Object>,Object[]> transformExtraLocalData(SynchroTableDao localDao,
                                                 SynchroTableDao remoteDao,
                                                 Map<List<Object>,Object[]> extraRows)
                                                   throws SQLException

Description copied from interface: SynchroInterceptor

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

Specified by:

transformExtraLocalData in interface SynchroInterceptor

extraRows - extra rows of the local db to transform

Returns:

transformed extra rows of the local db

Throws:

SQLException

onCreateSelectQuery

public final String onCreateSelectQuery(SynchroTableMetadata table,
                         String queryName,
                         String sql)

Specified by:

onCreateSelectQuery in interface SynchroInterceptor

onTableLoad

public final void onTableLoad(SynchroTableMetadata table)

Specified by:

onTableLoad in interface SynchroInterceptor

onJoinLoad

public final void onJoinLoad(SynchroTableMetadata table,
              SynchroJoinMetadata join)

Specified by:

onJoinLoad in interface SynchroInterceptor

enableOnRead

public boolean enableOnRead()

Specified by:

enableOnRead in interface SynchroInterceptor

enableOnWrite

public boolean enableOnWrite()

Specified by:

enableOnWrite in interface SynchroInterceptor

setContext

public void setContext(SynchroContext context)

Specified by:

setContext in interface SynchroInterceptor

getContext

protected SynchroContext getContext()

doTableLoad

protected void doTableLoad(SynchroTableMetadata table)

doJoinLoad

protected void doJoinLoad(SynchroTableMetadata table,
              SynchroJoinMetadata join)

doCreateSelectQuery

protected String doCreateSelectQuery(SynchroTableMetadata table,
                         String queryName,
                         String sql)

doCreateSelectQuery

protected String doCreateSelectQuery(SynchroTableMetadata table,
                         String selectClause,
                         String fromClause,
                         String whereClause,
                         String queryName)

Default implementation, that return the same SQL query. This method should be override by subclasses

Parameters:

table -

selectClause -

fromClause -

whereClause -

queryName -

Returns:

doOnRead

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

Throws:

SQLException

doOnWrite

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

Throws:

SQLException

doTransformExtraLocalData

protected Map<List<Object>,Object[]> doTransformExtraLocalData(SynchroTableDao localDao,
                                                   SynchroTableDao remoteDao,
                                                   Map<List<Object>,Object[]> extraRows)
                                                        throws SQLException

Throws:

SQLException