fr.ifremer.adagio.synchro.dao

Interface SynchroTableDao

All Superinterfaces:

AutoCloseable, Closeable

All Known Implementing Classes:

SynchroTableDaoImpl

public interface SynchroTableDao
extends Closeable

Method Summary

Methods

Modifier and Type	Method and Description
long	count() Count the number of rows in the table
long	countDataToUpdate(Date fromDate) Count the number of rows updated since the given date
void	deleteAll() Delete all rows of a table
void	executeInsert(Object[] row) Insert into a table the current row of the given incoming data Same as #executeInsert(List,ResultSet), but using a array instead of a ResultSet.
void	executeInsert(ResultSet incomingData) Insert into a table the current row of the given ResultSet
Integer	executeInsertAndReturnId(ResultSet incomingData)
void	executeUpdate(List<Object> pk, Object[] row) Update one table's row, using the current row of the given array of values Same as executeUpdate(List,ResultSet), but using a array instead of a ResultSet.
void	executeUpdate(List<Object> pk, ResultSet incomingData) Update one table's row, using the current row of the given ResultSet
Object[]	findByPk(List<Object> pk) Obtains a row, using values of each PK
void	flush() Flush all pending updates (i.e. pending batch statement)
Connection	getConnection()
ResultSet	getDataByFk(String fkColumnName, Set<Integer> fkValues) Getting all row depending of parent FK values
ResultSet	getDataToUpdate(Date fromDate) Obtains all data updated since the given date (or all data if the given date is null
Set<String>	getExistingPrimaryKeys() Obtains all primary keys of a table.
Map<Integer,Integer>	getExistingRemoteIdsMap() Obtains existing remoteIds
Integer	getIdFromRemoteId(String tableName, Integer remoteId) Retrieve a id by a remote id.
int	getInsertCount() Obtains the number of inserted rows
Timestamp	getLastUpdateDate() Obtains the max update date found in table's rows
SynchroPendingOperationBuffer	getPendingOperationBuffer()
List<Object>	getPk(ResultSet incomingData) Obtains a PK from the current ResultSet's row
SynchroTableMetadata	getTable()
int	getUpdateCount() Obtains the number of updated rows
void	setPendingOperationBuffer(SynchroPendingOperationBuffer pendingChangesBuffer)

Methods inherited from interface Closeable

close

Method Detail

getConnection

Connection getConnection()

getTable

SynchroTableMetadata getTable()

setPendingOperationBuffer

void setPendingOperationBuffer(SynchroPendingOperationBuffer pendingChangesBuffer)

getPendingOperationBuffer

SynchroPendingOperationBuffer getPendingOperationBuffer()

getLastUpdateDate

Timestamp getLastUpdateDate()
                            throws SQLException

Obtains the max update date found in table's rows

Returns:

Throws:

SQLException

count

long count()
           throws SQLException

Count the number of rows in the table

Returns:

Throws:

SQLException

countDataToUpdate

long countDataToUpdate(Date fromDate)
                       throws SQLException

Count the number of rows updated since the given date

Parameters:

fromDate -

Returns:

Throws:

SQLException

getIdFromRemoteId

Integer getIdFromRemoteId(String tableName,
                        Integer remoteId)
                          throws SQLException

Retrieve a id by a remote id. Only used for data synchronization (not used in referential synchronization)

Parameters:

tableName -

remoteId -

Returns:

the local id, or null if remote_id not found

Throws:

SQLException

getExistingRemoteIdsMap

Map<Integer,Integer> getExistingRemoteIdsMap()
                                             throws SQLException

Obtains existing remoteIds

Returns:

Throws:

SQLException

getDataByFk

ResultSet getDataByFk(String fkColumnName,
                    Set<Integer> fkValues)
                      throws SQLException

Getting all row depending of parent FK values

Parameters:

fkColumnName - the FK column name

fkValues - values of the FK columns

Returns:

Throws:

SQLException

getDataToUpdate

ResultSet getDataToUpdate(Date fromDate)
                          throws SQLException

Obtains all data updated since the given date (or all data if the given date is null

Parameters:

fromDate -

Returns:

A Resulset with expected data.

Throws:

SQLException

getExistingPrimaryKeys

Set<String> getExistingPrimaryKeys()
                                   throws SQLException

Obtains all primary keys of a table. If more than one key in tha table, use a serialization SynchroTableMetadata.toPkStr(java.util.List<java.lang.Object>)

Returns:

Throws:

SQLException

findByPk

Object[] findByPk(List<Object> pk)
                  throws SQLException

Obtains a row, using values of each PK

Parameters:

pk - values of PK column

Returns:

the existing row in the table

Throws:

SQLException

getPk

List<Object> getPk(ResultSet incomingData)
                   throws SQLException

Obtains a PK from the current ResultSet's row

Parameters:

incomingData -

tableBuffer -

Returns:

Throws:

SQLException

deleteAll

void deleteAll()
               throws SQLException

Delete all rows of a table

Throws:

SQLException

executeInsert

void executeInsert(ResultSet incomingData)
                   throws SQLException

Insert into a table the current row of the given ResultSet

Parameters:

pk - the PK of the current row (only need for logging)

incomingData - a ResultSet with a row ready to be read (ResultSet.next() should have been call before)

Throws:

SQLException

executeInsert

void executeInsert(Object[] row)
                   throws SQLException

Insert into a table the current row of the given incoming data

Same as #executeInsert(List,ResultSet), but using a array instead of a ResultSet.

Parameters:

incomingData - a array of object

Throws:

SQLException

executeInsertAndReturnId

Integer executeInsertAndReturnId(ResultSet incomingData)
                                 throws SQLException

Throws:

SQLException

executeUpdate

void executeUpdate(List<Object> pk,
                 ResultSet incomingData)
                   throws SQLException

Update one table's row, using the current row of the given ResultSet

Parameters:

pk - the PK of the row to update

incomingData - a ResultSet with a row ready to be read (ResultSet.next() should have been call before)

Throws:

SQLException

executeUpdate

void executeUpdate(List<Object> pk,
                 Object[] row)
                   throws SQLException

Update one table's row, using the current row of the given array of values

Same as executeUpdate(List,ResultSet), but using a array instead of a ResultSet.

Parameters:

pk - the PK of the row to update

row - a array of object

Throws:

SQLException

flush

void flush()
           throws SQLException

Flush all pending updates (i.e. pending batch statement)

Throws:

SQLException

getUpdateCount

int getUpdateCount()

Obtains the number of updated rows

Returns:

the number of updated rows

getInsertCount

int getInsertCount()

Obtains the number of inserted rows

Returns:

the number of inserted rows