fr.ifremer.adagio.synchro.dao

Class SynchroTableDaoImpl

Object

SynchroTableDaoImpl

All Implemented Interfaces:

SynchroTableDao, Closeable, AutoCloseable

public class SynchroTableDaoImpl
extends Object
implements SynchroTableDao

Field Summary

Fields

Modifier and Type	Field and Description
protected int	batchSize
protected int	columnCount
protected Connection	connection
protected SynchroDatabaseMetadata	dbMeta
protected boolean	debug
protected int	idColumnIndex
protected int	insertCount
protected PreparedStatement	insertQueryParameterStatement
protected PreparedStatement	insertStatement
protected boolean	insertStrategyGenerateIdFirst
protected SynchroPendingOperationBuffer	pendingOperationBuffer
protected SynchroInterceptor	readInterceptor
protected List<PreparedStatement>	selectStatements
protected SynchroTableMetadata	table
static String	TABLE_TEMP_QUERY_PARAMETER
protected String	tableName
protected int	updateCount
protected PreparedStatement	updateStatement
protected SynchroInterceptor	writeInterceptor

Constructor Summary

Constructors

Constructor and Description
SynchroTableDaoImpl(Connection connection, SynchroTableMetadata table, boolean enableWriteStatements)

Method Summary

Methods

Modifier and Type	Method and Description
void	clearCounts()
void	close()
protected void	closePreviousSelectStatements(PreparedStatement newStatement)
protected void	closeSelectStatements()
long	count() Count the number of rows in the table
long	countDataToUpdate(Date fromDate) Count the number of rows updated since the given date
protected String	createTempQueryParameterQuery(SynchroTableMetadata table)
void	deleteAll() Delete all rows of a table
void	executeInsert(Object[] incomingData) 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 SynchroTableDao.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)
Integer	generateNewId()
Connection	getConnection()
ResultSet	getDataByFk(String fkColumnName, Set<Integer> fkValues) Getting all row depending of parent FK values
protected ResultSet	getDataByFkUsingTempParameterTable(String fkColumnName, Set<Integer> fkValues)
protected ResultSet	getDataByFkWithInOperator(String fkColumnName, Set<Integer> fkValues)
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() Gets the last updateDate for the given table using the given datasource.
SynchroPendingOperationBuffer	getPendingOperationBuffer()
List<Object>	getPk(ResultSet incomingData) Obtains a PK from the current ResultSet's row
List<Object>	getPk(ResultSet incomingData, SynchroWriteBuffer transformResult)
SynchroTableMetadata	getTable()
int	getUpdateCount() Obtains the number of updated rows
protected void	insertValuesIntoTempQueryParameter(Set<Integer> parameterValues, String queryParameterName, int queryPersonId)
boolean	isTempQueryParameterEnable()
protected void	setData(PreparedStatement statement, Object[] values, List<Object> debugParams)
protected void	setData(PreparedStatement statement, ResultSet incomingData, List<Object> debugParams)
void	setPendingOperationBuffer(SynchroPendingOperationBuffer pendingChangesBuffer)
protected void	transformAndSetData(PreparedStatement statement, Object[] incomingData, SynchroWriteBuffer transformBuffer, SynchroInterceptor interceptor, List<Object> debugParams)
protected void	transformAndSetData(PreparedStatement statement, ResultSet incomingData, SynchroWriteBuffer transformBuffer, SynchroInterceptor interceptor, List<Object> debugParams)
protected Object[]	transformData(Object[] incomingData, SynchroInterceptor interceptor, SynchroWriteBuffer buffer)
protected Object[]	transformData(ResultSet incomingData, SynchroInterceptor interceptor, SynchroWriteBuffer buffer)

Methods inherited from class Object

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

Field Detail

TABLE_TEMP_QUERY_PARAMETER

public static final String TABLE_TEMP_QUERY_PARAMETER

See Also:

Constant Field Values

connection

protected final Connection connection

dbMeta

protected final SynchroDatabaseMetadata dbMeta

table

protected final SynchroTableMetadata table

insertStatement

protected final PreparedStatement insertStatement

insertQueryParameterStatement

protected final PreparedStatement insertQueryParameterStatement

updateStatement

protected final PreparedStatement updateStatement

selectStatements

protected final List<PreparedStatement> selectStatements

insertStrategyGenerateIdFirst

protected final boolean insertStrategyGenerateIdFirst

columnCount

protected final int columnCount

batchSize

protected final int batchSize

tableName

protected final String tableName

debug

protected boolean debug

insertCount

protected int insertCount

updateCount

protected int updateCount

idColumnIndex

protected final int idColumnIndex

readInterceptor

protected final SynchroInterceptor readInterceptor

writeInterceptor

protected final SynchroInterceptor writeInterceptor

pendingOperationBuffer

protected SynchroPendingOperationBuffer pendingOperationBuffer

Constructor Detail

SynchroTableDaoImpl

public SynchroTableDaoImpl(Connection connection,
                   SynchroTableMetadata table,
                   boolean enableWriteStatements)
                    throws SQLException

Throws:

SQLException

Method Detail

getConnection

public Connection getConnection()

Specified by:

getConnection in interface SynchroTableDao

getTable

public SynchroTableMetadata getTable()

Specified by:

getTable in interface SynchroTableDao

setPendingOperationBuffer

public void setPendingOperationBuffer(SynchroPendingOperationBuffer pendingChangesBuffer)

Specified by:

setPendingOperationBuffer in interface SynchroTableDao

getPendingOperationBuffer

public SynchroPendingOperationBuffer getPendingOperationBuffer()

Specified by:

getPendingOperationBuffer in interface SynchroTableDao

getInsertCount

public int getInsertCount()

Description copied from interface: SynchroTableDao

Obtains the number of inserted rows

Specified by:

getInsertCount in interface SynchroTableDao

Returns:

the number of inserted rows

getUpdateCount

public int getUpdateCount()

Description copied from interface: SynchroTableDao

Obtains the number of updated rows

Specified by:

getUpdateCount in interface SynchroTableDao

Returns:

the number of updated rows

flush

public void flush()
           throws SQLException

Description copied from interface: SynchroTableDao

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

Specified by:

flush in interface SynchroTableDao

Throws:

SQLException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

getLastUpdateDate

public Timestamp getLastUpdateDate()
                            throws SQLException

Gets the last updateDate for the given table using the given datasource.

Specified by:

getLastUpdateDate in interface SynchroTableDao

Returns:

the last update date of the given table, or null if table does not use a updateDate columns or if there is no data in table.

Throws:

SQLException

count

public long count()
           throws SQLException

Description copied from interface: SynchroTableDao

Count the number of rows in the table

Specified by:

count in interface SynchroTableDao

Returns:

Throws:

SQLException

countDataToUpdate

public long countDataToUpdate(Date fromDate)
                       throws SQLException

Description copied from interface: SynchroTableDao

Count the number of rows updated since the given date

Specified by:

countDataToUpdate in interface SynchroTableDao

Returns:

Throws:

SQLException

getDataToUpdate

public ResultSet getDataToUpdate(Date fromDate)
                          throws SQLException

Description copied from interface: SynchroTableDao

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

Specified by:

getDataToUpdate in interface SynchroTableDao

Returns:

A Resulset with expected data.

Throws:

SQLException

deleteAll

public void deleteAll()
               throws SQLException

Description copied from interface: SynchroTableDao

Delete all rows of a table

Specified by:

deleteAll in interface SynchroTableDao

Throws:

SQLException

findByPk

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

Description copied from interface: SynchroTableDao

Obtains a row, using values of each PK

Specified by:

findByPk in interface SynchroTableDao

Parameters:

pk - values of PK column

Returns:

the existing row in the table

Throws:

SQLException

getExistingPrimaryKeys

public Set<String> getExistingPrimaryKeys()
                                   throws SQLException

Description copied from interface: SynchroTableDao

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>)

Specified by:

getExistingPrimaryKeys in interface SynchroTableDao

Returns:

Throws:

SQLException

generateNewId

public Integer generateNewId()
                      throws SQLException

Throws:

SQLException

executeInsert

public void executeInsert(ResultSet incomingData)
                   throws SQLException

Description copied from interface: SynchroTableDao

Insert into a table the current row of the given ResultSet

Specified by:

executeInsert in interface SynchroTableDao

Parameters:

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

Throws:

SQLException

executeInsert

public void executeInsert(Object[] incomingData)
                   throws SQLException

Description copied from interface: SynchroTableDao

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.

Specified by:

executeInsert in interface SynchroTableDao

Throws:

SQLException

executeInsertAndReturnId

public Integer executeInsertAndReturnId(ResultSet incomingData)
                                 throws SQLException

Specified by:

executeInsertAndReturnId in interface SynchroTableDao

Throws:

SQLException

executeUpdate

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

Description copied from interface: SynchroTableDao

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

Specified by:

executeUpdate in interface SynchroTableDao

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

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

Description copied from interface: SynchroTableDao

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

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

Specified by:

executeUpdate in interface SynchroTableDao

Parameters:

pk - the PK of the row to update

row - a array of object

Throws:

SQLException

getDataByFk

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

Description copied from interface: SynchroTableDao

Getting all row depending of parent FK values

Specified by:

getDataByFk in interface SynchroTableDao

Parameters:

fkColumnName - the FK column name

fkValues - values of the FK columns

Returns:

Throws:

SQLException

getIdFromRemoteId

public Integer getIdFromRemoteId(String tableName,
                        Integer remoteId)
                          throws SQLException

Description copied from interface: SynchroTableDao

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

Specified by:

getIdFromRemoteId in interface SynchroTableDao

Returns:

the local id, or null if remote_id not found

Throws:

SQLException

getExistingRemoteIdsMap

public Map<Integer,Integer> getExistingRemoteIdsMap()
                                             throws SQLException

Description copied from interface: SynchroTableDao

Obtains existing remoteIds

Specified by:

getExistingRemoteIdsMap in interface SynchroTableDao

Returns:

Throws:

SQLException

getPk

public List<Object> getPk(ResultSet incomingData,
                 SynchroWriteBuffer transformResult)
                   throws SQLException

Throws:

SQLException

isTempQueryParameterEnable

public boolean isTempQueryParameterEnable()

clearCounts

public void clearCounts()

insertValuesIntoTempQueryParameter

protected void insertValuesIntoTempQueryParameter(Set<Integer> parameterValues,
                                      String queryParameterName,
                                      int queryPersonId)
                                           throws SQLException

Throws:

SQLException

createTempQueryParameterQuery

protected String createTempQueryParameterQuery(SynchroTableMetadata table)

closeSelectStatements

protected void closeSelectStatements()

closePreviousSelectStatements

protected void closePreviousSelectStatements(PreparedStatement newStatement)

setData

protected void setData(PreparedStatement statement,
           Object[] values,
           List<Object> debugParams)
                throws SQLException

Throws:

SQLException

setData

protected void setData(PreparedStatement statement,
           ResultSet incomingData,
           List<Object> debugParams)
                throws SQLException

Throws:

SQLException

transformAndSetData

protected void transformAndSetData(PreparedStatement statement,
                       ResultSet incomingData,
                       SynchroWriteBuffer transformBuffer,
                       SynchroInterceptor interceptor,
                       List<Object> debugParams)
                            throws SQLException

Throws:

SQLException

transformAndSetData

protected void transformAndSetData(PreparedStatement statement,
                       Object[] incomingData,
                       SynchroWriteBuffer transformBuffer,
                       SynchroInterceptor interceptor,
                       List<Object> debugParams)
                            throws SQLException

Throws:

SQLException

transformData

protected Object[] transformData(ResultSet incomingData,
                     SynchroInterceptor interceptor,
                     SynchroWriteBuffer buffer)
                          throws SQLException

Throws:

SQLException

transformData

protected Object[] transformData(Object[] incomingData,
                     SynchroInterceptor interceptor,
                     SynchroWriteBuffer buffer)
                          throws SQLException

Throws:

SQLException

getDataByFkWithInOperator

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

Throws:

SQLException

getDataByFkUsingTempParameterTable

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

Throws:

SQLException

getPk

public List<Object> getPk(ResultSet incomingData)
                   throws SQLException

Description copied from interface: SynchroTableDao

Obtains a PK from the current ResultSet's row

Specified by:

getPk in interface SynchroTableDao

Returns:

Throws:

SQLException