Sometimes we get a requirement to update the data before it gets inserted into the staging table.
Here I'm using "
postGetStagingData" method to update the data before it gets inserted into the staging table.
[ExtensionOf(tableStr(DemandForecastEntity))]
final public class DemandForecastEntity_Extension
{
public static void postGetStagingData(DMFDefinitionGroupExecution _dmfDefinitionGroupExecution)
{
DemandForecastEntityStaging demandForecastEntityStaging ;
InventDimCombination inventDimCombination;
InventDim inventDim;
while select forupdate demandForecastEntityStaging where demandForecastEntityStaging .DefinitionGroup == _dmfDefinitionGroupExecution.DefinitionGroup
&& demandForecastEntityStaging .ExecutionId == _dmfDefinitionGroupExecution.ExecutionId
&& demandForecastEntityStaging .TransferStatus == DMFTransferStatus::NotStarted
{
inventDimCombination.clear();
inventDim.clear();
select firstonly inventDimCombination
where inventDimCombination.ItemId == demandForecastEntityStaging .ItemNumber
join inventDim
where inventDim.inventDimId == inventDimCombination.InventDimId;
if(inventDimCombination)
{
ttsbegin;
demandForecastEntityStaging .ProductConfigurationId = inventDim.configId;
demandForecastEntityStaging .ProductColorId = inventDim.InventColorId;
demandForecastEntityStaging .ProductSizeId = inventDim.InventSizeId;
demandForecastEntityStaging .ProductStyleId = inventDim.InventStyleId;
demandForecastEntityStaging .doUpdate();
ttscommit;
}
}
}
}
In the same way you can use "PostTargetProcess" method if you want to update the data before it gets inserted into the target tables.
This method is automatically called by the DMFEntityWriter class in the end of processRecords() method when all records are transferred from staging to target. It is not available from override method drop down on Data Entity because it is static and is called via reflection.
Please note that it can be done only in data management scenarios but not via OData because OData updates\inserts records row by row and there is no post event\method to use.
/// <summary
/// Executes the logic once after processing the target data.
/// </summary>
/// <param name= “_dmfDefinitionGroupExecution">
/// The definition group that should be processed.
/// </param>
public static void postTargetProcess(DMFDefinitionGroupExecution _dmfDefinitionGroupExecution)
{
if (_dmfDefinitionGroupExecution.StagingStatus == DMFBatchJobStatus::Finished)
{
MyStaging myStaging;
while select myStaging
where myStaging.DefinitionGroup == _dmfDefinitionGroupExecution.DefinitionGroup
&& myStaging.ExecutionId == _dmfDefinitionGroupExecution.ExecutionId
&& myStaging.TransferStatus == DMFTransferStatus::Completed
{
}
}
}
@Rahul
