Get Data Object by Primary Key

curl -X GET "https://api.pretectum.io/v1/businessareas/20240115103000123a1b2c3d4e5f6789012345678901234/schemas/20240115103000456d1e2f3a4b5c6789012345678901234/datasets/20240925152201042a1b2c3d4e5f6789012345678901234/dataobjects/by-pk/CUST-000123" \
  -H "Authorization: pre_your_api_key" \
  -H "Accept: application/json"

const apiKey = 'pre_your_api_key';
const businessAreaId = '20240115103000123a1b2c3d4e5f6789012345678901234';
const schemaId = '20240115103000456d1e2f3a4b5c6789012345678901234';
const datasetId = '20240925152201042a1b2c3d4e5f6789012345678901234';

async function getDataObjectByPrimaryKey(businessAreaId, schemaId, datasetId, pkValue) {
  const response = await fetch(
    `https://api.pretectum.io/v1/businessareas/${businessAreaId}/schemas/${schemaId}/datasets/${datasetId}/dataobjects/by-pk/${encodeURIComponent(pkValue)}`,
    {
      headers: {
        'Authorization': apiKey,
        'Accept': 'application/json'
      }
    }
  );

  if (response.status === 404) {
    return null;
  }
  if (!response.ok) {
    throw new Error(`Lookup failed: ${response.status} ${response.statusText}`);
  }

  return response.json();
}

const customer = await getDataObjectByPrimaryKey(businessAreaId, schemaId, datasetId, 'CUST-000123');
if (customer) {
  console.log(`Found ${customer['First Name']} ${customer['Last Name']} (version ${customer._version})`);
} else {
  console.log('No customer with that number');
}

import requests
from urllib.parse import quote

api_key = 'pre_your_api_key'
business_area_id = '20240115103000123a1b2c3d4e5f6789012345678901234'
schema_id = '20240115103000456d1e2f3a4b5c6789012345678901234'
dataset_id = '20240925152201042a1b2c3d4e5f6789012345678901234'

def get_data_object_by_primary_key(business_area_id, schema_id, dataset_id, pk_value):
    response = requests.get(
        f'https://api.pretectum.io/v1/businessareas/{business_area_id}/schemas/{schema_id}/datasets/{dataset_id}/dataobjects/by-pk/{quote(pk_value, safe="")}',
        headers={
            'Authorization': api_key,
            'Accept': 'application/json'
        }
    )

    if response.status_code == 404:
        return None

    response.raise_for_status()
    return response.json()

customer = get_data_object_by_primary_key(business_area_id, schema_id, dataset_id, 'CUST-000123')
if customer:
    print(f"Found {customer['First Name']} {customer['Last Name']} (version {customer['_version']})")
else:
    print('No customer with that number')

async function upsertCustomer(businessAreaId, schemaId, datasetId, customer) {
  const existing = await getDataObjectByPrimaryKey(businessAreaId, schemaId, datasetId, customer['Customer Number']);

  if (!existing) {
    return createDataObject(businessAreaId, schemaId, datasetId, customer);
  }

  return updateDataObject(businessAreaId, schemaId, datasetId, existing._dataObjectId, {
    _version: existing._version,
    ...customer
  });
}

def upsert_customer(business_area_id, schema_id, dataset_id, customer):
    existing = get_data_object_by_primary_key(business_area_id, schema_id, dataset_id, customer['Customer Number'])

    if existing is None:
        return create_data_object(business_area_id, schema_id, dataset_id, customer)

    return update_data_object(
        business_area_id,
        schema_id,
        dataset_id,
        existing['_dataObjectId'],
        {'_version': existing['_version'], **customer}
    )