3.1.8 Data Transfer Job

This topic provides information about the Data Transfer Job process.

All the records processed in the above batches with its status i.e success or failure (with failure reason) will be informed to the source system via this job. Source system can then analyze the records with failed status, correct the same and re-send again for processing.

This Job having two categories such as app configuration and trigger endpoint. Through the App configuration job, source and destination schema tables and column details are mapped. And Trigger endpoint job will transfer data from the source driver tables to destination system.

Table 3-16 Mandatory Headers for Configuration endpoint:

Parameter Name Value Mandatory Description
appld PLATOFDT Yes The application ID of the host service.

Table 3-17 Mandatory Headers for Trigger endpoint:

Parameter Name Value Mandatory Description
userld ADMINUSER1 Yes User Id of the requesting user.
appld CRDATAEXCHNG Yes The application ID of the host service.
branchCode DMO Yes Branch Code of the requesting user.
entityId DEFAULTENTITY Yes Entity ID of the request.
Content-Type application/json Yes Content Type of the request.

Source Schema: CR_ENTITY

Source tables:
  • DM_INBOUND_ENTITY_CREATION_DRIVER
  • DM_ACCOUNT_UPDATE_DRIVER
  • DM_ACCOUNT_PARTY_REL_UPDATE_DRIVER
  • DM_PAYMENT_UPDATE_DRIVER
  • DM_REPAYSCH_UPDATE_DRIVER
  • DM_BILL_DETAIL_UPDATE_DRIVER

Destination Schema: As provided by the host system.

Destination Tables: As provided by the host system.

Specify following parameters while executing this batch:

Table 3-18 Data Transfer sample configuration:

Endpoint Configurations
Host location http://host:port/plato-fast-data-transfer-service/configurations/applications/ObrlDataResponse/ObcrDataAck
Method POST
Header 

appId:PLATOFDT
entityId:DEFAULTENTITY
Content-Type:application/json
branchCode:BCR 
userId:AUTOUSER
Request Body 

{    
   "sourceJNDI": "jdbc/CR_ENTITY", 
   "destinationJNDI": "jdbc/SLPRCORE",
   "continueOnErrorFlag": "N",    
   "ignoreFailedDropsFlag": "N", 
   "readPageSize": "1000",  
   "tablesPerJob": "6",    
   "chunkSize": "100",   
   "jobWriterTypeFlag": "J", 
   "deployScriptWhileCreate": "N",  
   "truncateFlag": "Y",    
   "srcTruncateFlag": "N",    
   "streamsPerTable": "2",    
   "customConfigMasters": [       
        {           
            "srcTable": "DM_INBOUND_ENTITY_CREATION_DRIVER",           
            "destTable": "SLP_TM_IN_COLL_RESPONSE_DATA",           
            "customConfigDatas": [               
                {                 
                   "key": "ACCOUNT_NBR",                 
                   "value": "CONTRACT_REF_NO",                 
                   "configType": "COLUMN_MAPPING"               
                },               
                {                 
                    "key": "BRANCH_CODE",
                    "value": "BRANCH_CODE",                 
                    "configType": "COLUMN_MAPPING"               
                },               
                {                 
                    "key": "RUN_DATE",                 
                    "value": "RUN_DATE",                 
                    "configType": "COLUMN_MAPPING"               
                },               
                {                 
                    "key": "SEQ_NO",                 
                    "value": "SEQ_NO",                 
                    "configType": "COLUMN_MAPPING"               
                },               
                {                 
                    "key": "ERROR_CODE",                 
                    "value": "ERROR_CODE",                 
                    "configType": "COLUMN_MAPPING"               
                },               
                {                 
                    "key": "PROCESS_RESULT",                 
                    "value": "PROCESS_RESULT",                 
                    "configType": "COLUMN_MAPPING" 
                }           
             ]       
          }
       }

Trigger endpoint

Table 3-19 Trigger endpoint

Endpoint Configurations
Host location http:// host:port/obcr-data-exchange-services/transfers/ObrlDataResponse/ObcrDataAck?runDate=02042018&operation=T&branchCode=BCR
Method POST
Header 

appId:PLATOFDT
entityId:DEFAULTENTITY
Content-Type:application/json
branchCode:BCR 
userId:AUTOUSER
Request Body 

[
    {
        "tableName": "SLP_TM_IN_COLL_RESPONSE_DATA",
        "truncateFlag": "N",
        "srcTableName": "DM_INBOUND_ENTITY_CREATION_DRIVER",
        "srcTruncateFlag": "N",
        "srcWhereClause": ""
    }
}

Parent topic: Entity Creation