Package | Description |
---|---|
fr.ifremer.adagio.synchro.service | |
fr.ifremer.adagio.synchro.service.data | |
fr.ifremer.adagio.synchro.service.referential |
Modifier and Type | Field and Description |
---|---|
protected SynchroResult |
SynchroContext.result |
Modifier and Type | Method and Description |
---|---|
SynchroResult |
SynchroContext.getResult() |
Modifier and Type | Method and Description |
---|---|
static void |
SynchroServiceUtils.checkSchemas(SynchroDatabaseMetadata sourceSchema,
SynchroDatabaseMetadata targetSchema,
boolean allowMissingOptionalColumn,
boolean allowAdditionalMandatoryColumnInSourceSchema,
SynchroResult result)
Check that the tow given shemas are compatible for a
synchronize operation (same tables with same columns).
|
protected static void |
SynchroServiceUtils.checkSchemasAllowMissingOptionalColumn(SynchroDatabaseMetadata sourceSchema,
SynchroDatabaseMetadata targetSchema,
boolean allowAdditionalMandatoryColumnInSourceSchema,
SynchroResult result)
Check that the tow given shemas are compatible for a synchronize operation (same tables with same columns). *
This method allow missing columns (if define as nullable in the target schema)
If schemas are incompatible, then a
SynchroTechnicalException exception will be thrown. |
static SynchroContext |
SynchroContext.newContext(Set<String> tableNames,
Predicate<String> tableFilter,
Properties sourceConnectionProperties,
Properties targetConnectionProperties,
SynchroResult result)
Create a new synchro context
|
static SynchroContext |
SynchroContext.newContext(Set<String> tableNames,
Properties sourceConnectionProperties,
Properties targetConnectionProperties,
SynchroResult result)
Create a new synchro context
|
protected void |
SynchroBaseService.reportProgress(SynchroResult result,
SynchroTableDao dao,
int countR,
String tablePrefix) |
void |
SynchroContext.setResult(SynchroResult result) |
Modifier and Type | Method and Description |
---|---|
protected void |
DataSynchroServiceImpl.prepareRootTable(SynchroTableMetadata sourceTable,
SynchroTableMetadata targetTable,
Connection sourceConnection,
Connection targetConnection,
SynchroResult result) |
protected void |
DataSynchroServiceImpl.synchronizeChildTable(SynchroTableMetadata table,
String joinColumnName,
Set<Integer> joinColumnIds,
Connection sourceConnection,
Connection targetConnection,
SynchroResult result,
SynchroPendingOperationBuffer tableBuffer) |
protected void |
DataSynchroServiceImpl.synchronizeChildTables(SynchroTableMetadata parentTable,
Set<Integer> parentRemoteIds,
SynchroContext context,
Connection sourceConnection,
Connection targetConnection,
SynchroResult result,
boolean enableLogCount) |
protected void |
DataSynchroServiceImpl.synchronizeRootTable(SynchroTableMetadata table,
SynchroContext context,
Connection sourceConnection,
Connection targetConnection,
SynchroResult result,
SynchroPendingOperationBuffer tableBuffer) |
protected void |
DataSynchroServiceImpl.updateTableNoRemoteId(SynchroTableDao targetDao,
ResultSet incomingData,
SynchroResult result,
SynchroPendingOperationBuffer tableBuffer)
To update the content of the given
table on the target db,
from the given incomingData of the source db. |
protected void |
DataSynchroServiceImpl.updateTableUsingRemoteId(SynchroTableDao targetDao,
ResultSet incomingData,
SynchroResult result,
SynchroPendingOperationBuffer tableBuffer)
To update the content of the given
table on the target db,
from the given incomingData of the source db. |
Modifier and Type | Method and Description |
---|---|
protected void |
ReferentialSynchroServiceImpl.prepareTable(SynchroTableMetadata sourceTable,
SynchroTableMetadata targetTable,
SynchroContext context,
Connection targetConnection,
Connection sourceConnection,
SynchroResult result) |
protected void |
ReferentialSynchroServiceImpl.reportProgress(SynchroResult result,
SynchroTableDao dao,
int countR,
String tablePrefix) |
protected void |
ReferentialSynchroServiceImpl.synchronizeTable(SynchroTableMetadata table,
Connection targetConnection,
Connection sourceConnection,
SynchroResult result) |
protected void |
ReferentialSynchroServiceImpl.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 |
ReferentialSynchroServiceImpl.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. |
Copyright © 2012–2014 IFREMER. All rights reserved.