Connect a Database and Issue a Query

This section provides an example of a process that connects to the Acme Corporation customer database and issues a query every night at midnight.

1. The following query is issued:

   SELECT CUSTID, FNAME, MNAME, LNAME FROM CUSTOMER;

2. This data is loaded into the Customer ramp table in the production Omni-HealthData environment, as follows:

   This example includes two source systems, Acme and Omni. There is one integration point, the scheduled ETL job. There is one source mapping, from the ETL job to the Customer subject, and five mapping items, one for each of the Customer elements affected. Many of the examples below will relate to this scenario.

   Model

   Source Entity

   {
     "description": "string",
     "id": "string",
     "internalIndicator": true,
     "name": "string",
     "owningBusinessUnitId": "string",
     "owningBusinessUnitName": "string",
     "sensitivity": "string",
     "thirdPartyIntegratorId": "string",
     "thirdPartyIntegratorName": "string",
     "virtualIndicator": true
   }

   Source Metadata Entity

   {
     "category": "string",
     "codeReference": "string",
     "endDate": {
       "day": 0,
       "month": 0,
       "year": 0
     },
     "id": "string",
     "omniSourceId": "string",
     "specVersion": "string",
     "startDate": {
       "day": 0,
       "month": 0,
       "year": 0
     },
     "subCategory": "string"
   }

   Integration Point Entity

   {
     "earliestStartTime": {
       "hour": 0,
       "minute": 0
     },
     "expectedDuration": "string",
     "expectedSize": "string",
     "id": "string",
     "integrationDaysOfMonth": "string",
     "integrationDaysOfWeek": "string",
     "integrationDirection": "string",
     "integrationFrequency": "string",
     "integrationScope": "string",
     "latestEndTime": {
       "hour": 0,
       "minute": 0
     },
     "omniProcessingPolicy": "string",
     "sourceId": "string",
     "sourceLocation": {
       "domain": "string",
       "hostName": "string",
       "password": "string",
       "port": "string",
       "protocol": "string",
       "resourceLocation": "string",
       "resourceName": "string",
       "userName": "string"
     },
     

   "sourceLocationType": "string",
     "sourceResourceType": "string",
     "targetId": "string",
     "targetLocation": {
       "domain": "string",
       "hostName": "string",
       "password": "string",
       "port": "string",
       "protocol": "string",
       "resourceLocation": "string",
       "resourceName": "string",
       "userName": "string"
     },
     "targetLocationType": "string",
     "targetResourceType": "string"
   }

   Mapping Entity

   {
     "description": "string",
     "id": "string",
     "integrationPointId": "string",
     "name": "string",
     "targetIdsId": "string",
     "version": "string"
   }

   Mapping Item Entity

   {
     "codeSet": "string",
     "codeSourceName": "string",
     "codeValue": "string",
     "id": "string",
     "idsDocElementId": "string",
     "linkSourceId": "string",
     "linkSourceName": "string",
     "mappedItem": "string",
     "mappingId": "string",
     "serviceLevelAgreement": "string"
   }