Agentic Marketing: Databricks, Virtuoso, and Both Together

The consolidated copy-paste script for running the whole CustomerKG demonstration on your own Virtuoso. Its purpose is execution, not exposition: the same statements as the cards above in the order a fresh database needs them. The table and row statements are standard SQL; the IRI class, quad map and rewrite-rule statements are Virtuoso-specific and are the part most likely to need adjustment on another version.

-- customerkg-agentic-marketing.sql
-- CustomerKG: a synthetic quick-service-restaurant estate that holds customer, business, decision and control context,
-- projected as an RDF View. All rows are invented for illustration. Standard SQL up to Part 2; Parts 3 to 6 are Virtuoso extensions.
-- Run:  isql <host>:1111 dba <password> < customerkg-agentic-marketing.sql      (or paste into Conductor's Interactive SQL page)
-- Change CustomerKG.kidehen if you want another qualifier or owner; keep it identical everywhere in the file.

-- Part 1: tables, parents before children
CREATE TABLE CustomerKG.kidehen.channel (channel_id INTEGER NOT NULL PRIMARY KEY, channel_name VARCHAR(40) NOT NULL, channel_kind VARCHAR(8) NOT NULL);
CREATE TABLE CustomerKG.kidehen.product (product_id INTEGER NOT NULL PRIMARY KEY, product_name VARCHAR(48) NOT NULL, category VARCHAR(16) NOT NULL, margin_pct INTEGER NOT NULL);
CREATE TABLE CustomerKG.kidehen.customer (customer_id INTEGER NOT NULL PRIMARY KEY, full_name VARCHAR(48) NOT NULL, lifecycle_stage VARCHAR(12) NOT NULL, loyalty_tier VARCHAR(8) NOT NULL, home_city VARCHAR(24) NOT NULL, usual_order_day VARCHAR(10) NOT NULL);
CREATE TABLE CustomerKG.kidehen.identity_signal (signal_id INTEGER NOT NULL PRIMARY KEY, customer_id INTEGER, signal_kind VARCHAR(16) NOT NULL, signal_value VARCHAR(24) NOT NULL, match_method VARCHAR(16) NOT NULL, confidence INTEGER NOT NULL, seen_date DATE NOT NULL, FOREIGN KEY (customer_id) REFERENCES CustomerKG.kidehen.customer (customer_id));
CREATE TABLE CustomerKG.kidehen.consent (consent_id INTEGER NOT NULL PRIMARY KEY, customer_id INTEGER NOT NULL, channel_id INTEGER NOT NULL, status VARCHAR(10) NOT NULL, updated_date DATE NOT NULL, FOREIGN KEY (customer_id) REFERENCES CustomerKG.kidehen.customer (customer_id), FOREIGN KEY (channel_id) REFERENCES CustomerKG.kidehen.channel (channel_id));
CREATE TABLE CustomerKG.kidehen.offer (offer_id INTEGER NOT NULL PRIMARY KEY, offer_name VARCHAR(40) NOT NULL, offer_kind VARCHAR(16) NOT NULL, discount_pct INTEGER NOT NULL, product_id INTEGER, FOREIGN KEY (product_id) REFERENCES CustomerKG.kidehen.product (product_id));
CREATE TABLE CustomerKG.kidehen.guardrail (guardrail_id INTEGER NOT NULL PRIMARY KEY, rule_name VARCHAR(48) NOT NULL, rule_kind VARCHAR(20) NOT NULL, limit_value INTEGER NOT NULL, offer_id INTEGER, FOREIGN KEY (offer_id) REFERENCES CustomerKG.kidehen.offer (offer_id));
CREATE TABLE CustomerKG.kidehen.campaign (campaign_id INTEGER NOT NULL PRIMARY KEY, campaign_name VARCHAR(48) NOT NULL, goal VARCHAR(80) NOT NULL, start_date DATE NOT NULL);
CREATE TABLE CustomerKG.kidehen.decision (decision_id INTEGER NOT NULL PRIMARY KEY, customer_id INTEGER NOT NULL, campaign_id INTEGER NOT NULL, arm VARCHAR(10) NOT NULL, action_kind VARCHAR(16) NOT NULL, offer_id INTEGER, channel_id INTEGER, decided_date DATE NOT NULL, rationale VARCHAR(160) NOT NULL, approved_by_human INTEGER NOT NULL, FOREIGN KEY (customer_id) REFERENCES CustomerKG.kidehen.customer (customer_id), FOREIGN KEY (campaign_id) REFERENCES CustomerKG.kidehen.campaign (campaign_id), FOREIGN KEY (offer_id) REFERENCES CustomerKG.kidehen.offer (offer_id), FOREIGN KEY (channel_id) REFERENCES CustomerKG.kidehen.channel (channel_id));
CREATE TABLE CustomerKG.kidehen.decision_guardrail (decision_id INTEGER NOT NULL, guardrail_id INTEGER NOT NULL, PRIMARY KEY (decision_id, guardrail_id), FOREIGN KEY (decision_id) REFERENCES CustomerKG.kidehen.decision (decision_id), FOREIGN KEY (guardrail_id) REFERENCES CustomerKG.kidehen.guardrail (guardrail_id));
CREATE TABLE CustomerKG.kidehen.context_item (item_id INTEGER NOT NULL PRIMARY KEY, decision_id INTEGER NOT NULL, context_type VARCHAR(10) NOT NULL, context_key VARCHAR(24) NOT NULL, context_value VARCHAR(120) NOT NULL, FOREIGN KEY (decision_id) REFERENCES CustomerKG.kidehen.decision (decision_id));
CREATE TABLE CustomerKG.kidehen.outcome (outcome_id INTEGER NOT NULL PRIMARY KEY, decision_id INTEGER NOT NULL, ordered INTEGER NOT NULL, revenue_usd INTEGER NOT NULL, margin_usd INTEGER NOT NULL, media_cost_usd INTEGER NOT NULL, discount_cost_usd INTEGER NOT NULL, repeat_visit_30d INTEGER NOT NULL, window_end DATE NOT NULL, FOREIGN KEY (decision_id) REFERENCES CustomerKG.kidehen.decision (decision_id));

-- Part 2: rows, one INSERT each (Virtuoso has no multi-row VALUES)
INSERT INTO CustomerKG.kidehen.channel VALUES (1, 'App push', 'owned');
INSERT INTO CustomerKG.kidehen.channel VALUES (2, 'Email', 'owned');
INSERT INTO CustomerKG.kidehen.channel VALUES (3, 'SMS', 'owned');
INSERT INTO CustomerKG.kidehen.channel VALUES (4, 'Paid social', 'paid');
INSERT INTO CustomerKG.kidehen.channel VALUES (5, 'Display retargeting', 'paid');
INSERT INTO CustomerKG.kidehen.product VALUES (1, 'Classic Burger Meal', 'meal', 38);
INSERT INTO CustomerKG.kidehen.product VALUES (2, 'Family Meal Bundle', 'bundle', 31);
INSERT INTO CustomerKG.kidehen.product VALUES (3, 'Side of Fries', 'side', 62);
INSERT INTO CustomerKG.kidehen.product VALUES (4, 'Weekly Friday Combo', 'meal', 35);
INSERT INTO CustomerKG.kidehen.product VALUES (5, 'Dessert Treat', 'dessert', 58);
INSERT INTO CustomerKG.kidehen.customer VALUES (1, 'Avery Quinn', 'lapsing', 'gold', 'Austin', 'Friday');
INSERT INTO CustomerKG.kidehen.customer VALUES (2, 'Blake Moreno', 'lapsing', 'silver', 'Denver', 'Friday');
INSERT INTO CustomerKG.kidehen.customer VALUES (3, 'Casey Lindholm', 'lapsed', 'gold', 'Seattle', 'Saturday');
INSERT INTO CustomerKG.kidehen.customer VALUES (4, 'Devon Okafor', 'lapsed', 'bronze', 'Atlanta', 'Thursday');
INSERT INTO CustomerKG.kidehen.customer VALUES (5, 'Emery Castillo', 'lapsing', 'silver', 'Phoenix', 'Friday');
INSERT INTO CustomerKG.kidehen.customer VALUES (6, 'Frankie Novak', 'lapsed', 'bronze', 'Chicago', 'Sunday');
INSERT INTO CustomerKG.kidehen.customer VALUES (7, 'Gray Whitfield', 'lapsing', 'silver', 'Boston', 'Friday');
INSERT INTO CustomerKG.kidehen.customer VALUES (8, 'Harper Doyle', 'lapsed', 'bronze', 'Portland', 'Saturday');
INSERT INTO CustomerKG.kidehen.customer VALUES (9, 'Indigo Raman', 'lapsed', 'gold', 'Dallas', 'Friday');
INSERT INTO CustomerKG.kidehen.customer VALUES (10, 'Jules Barrow', 'lapsing', 'silver', 'Miami', 'Friday');
INSERT INTO CustomerKG.kidehen.customer VALUES (11, 'Kendall Osei', 'lapsed', 'bronze', 'Tampa', 'Saturday');
INSERT INTO CustomerKG.kidehen.customer VALUES (12, 'Lennox Pryce', 'lapsed', 'bronze', 'Raleigh', 'Sunday');
INSERT INTO CustomerKG.kidehen.customer VALUES (13, 'Marlowe Tran', 'lapsing', 'gold', 'San Jose', 'Friday');
INSERT INTO CustomerKG.kidehen.customer VALUES (14, 'Noel Ferreira', 'lapsed', 'bronze', 'Newark', 'Thursday');
INSERT INTO CustomerKG.kidehen.customer VALUES (15, 'Oakley Brandt', 'active', 'silver', 'Omaha', 'Friday');
INSERT INTO CustomerKG.kidehen.customer VALUES (16, 'Parker Zielinski', 'active', 'gold', 'Madison', 'Saturday');
INSERT INTO CustomerKG.kidehen.customer VALUES (17, 'Quincy Abara', 'active', 'silver', 'Memphis', 'Friday');
INSERT INTO CustomerKG.kidehen.customer VALUES (18, 'Rowan Eklund', 'active', 'bronze', 'Boise', 'Sunday');
INSERT INTO CustomerKG.kidehen.customer VALUES (19, 'Sage Whitlock', 'active', 'gold', 'Tulsa', 'Friday');
INSERT INTO CustomerKG.kidehen.customer VALUES (20, 'Tatum Reyes', 'active', 'silver', 'Reno', 'Friday');
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (1, 1, 'email', 'hem:a1f3', 'deterministic', 100, stringdate('2026-08-02'));
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (2, 1, 'loyalty_id', 'LY-10001', 'deterministic', 100, stringdate('2026-08-02'));
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (3, 1, 'app_session', 'sess:77a1', 'probabilistic', 86, stringdate('2026-09-24'));
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (4, 2, 'email', 'hem:b2c4', 'deterministic', 100, stringdate('2026-08-05'));
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (5, 2, 'device', 'dev:ios-31c', 'probabilistic', 82, stringdate('2026-09-20'));
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (6, 3, 'email', 'hem:c3d5', 'deterministic', 100, stringdate('2026-07-30'));
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (7, 3, 'app_session', 'sess:5e90', 'agentic', 91, stringdate('2026-09-27'));
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (8, 3, 'ad_exposure', 'imp:vid-204', 'probabilistic', 74, stringdate('2026-09-25'));
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (9, 4, 'email', 'hem:d4e6', 'deterministic', 100, stringdate('2026-07-15'));
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (10, 4, 'device', 'dev:and-8b2', 'probabilistic', 79, stringdate('2026-09-18'));
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (11, 5, 'email', 'hem:e5f7', 'deterministic', 100, stringdate('2026-08-11'));
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (12, 5, 'app_session', 'sess:a310', 'agentic', 88, stringdate('2026-09-26'));
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (13, 6, 'loyalty_id', 'LY-10006', 'deterministic', 100, stringdate('2026-06-21'));
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (14, 6, 'ad_exposure', 'imp:soc-118', 'probabilistic', 71, stringdate('2026-09-23'));
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (15, 7, 'email', 'hem:f708', 'deterministic', 100, stringdate('2026-08-19'));
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (16, 7, 'device', 'dev:ios-99d', 'deterministic', 100, stringdate('2026-09-21'));
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (17, 8, 'email', 'hem:0819', 'deterministic', 100, stringdate('2026-07-02'));
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (18, 8, 'app_session', 'sess:c442', 'probabilistic', 77, stringdate('2026-09-19'));
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (19, 9, 'email', 'hem:192a', 'deterministic', 100, stringdate('2026-08-08'));
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (20, 9, 'app_session', 'sess:1d6b', 'agentic', 93, stringdate('2026-09-27'));
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (21, 10, 'email', 'hem:2a3b', 'deterministic', 100, stringdate('2026-08-14'));
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (22, 11, 'loyalty_id', 'LY-10011', 'deterministic', 100, stringdate('2026-05-30'));
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (23, 12, 'email', 'hem:3b4c', 'deterministic', 100, stringdate('2026-06-12'));
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (24, 13, 'email', 'hem:4c5d', 'deterministic', 100, stringdate('2026-08-22'));
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (25, 13, 'app_session', 'sess:e8f2', 'probabilistic', 84, stringdate('2026-09-24'));
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (26, 14, 'email', 'hem:5d6e', 'deterministic', 100, stringdate('2026-06-03'));
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (27, NULL, 'app_session', 'sess:9b13', 'unmatched', 0, stringdate('2026-09-28'));
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (28, NULL, 'ad_exposure', 'imp:soc-402', 'unmatched', 0, stringdate('2026-09-28'));
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (29, NULL, 'device', 'dev:and-c10', 'unmatched', 0, stringdate('2026-09-29'));
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (30, NULL, 'app_session', 'sess:2f77', 'unmatched', 0, stringdate('2026-09-29'));
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (31, 15, 'email', 'hem:6e7f', 'deterministic', 100, stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (32, 16, 'email', 'hem:7f80', 'deterministic', 100, stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (33, 17, 'email', 'hem:8091', 'deterministic', 100, stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (34, 18, 'email', 'hem:91a2', 'deterministic', 100, stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (35, 19, 'email', 'hem:a2b3', 'deterministic', 100, stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (36, 20, 'email', 'hem:b3c4', 'deterministic', 100, stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (1, 1, 2, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (2, 2, 2, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (3, 3, 2, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (4, 4, 2, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (5, 5, 2, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (6, 6, 2, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (7, 7, 2, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (8, 8, 2, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (9, 9, 2, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (10, 10, 2, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (11, 11, 2, 'withdrawn', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (12, 12, 2, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (13, 13, 2, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (14, 14, 2, 'withdrawn', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (15, 15, 2, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (16, 16, 2, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (17, 17, 2, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (18, 18, 2, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (19, 19, 2, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (20, 20, 2, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (21, 1, 1, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (22, 3, 1, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (23, 5, 1, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (24, 9, 1, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (25, 13, 1, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (26, 15, 1, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (27, 16, 1, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (28, 19, 1, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (29, 8, 1, 'withdrawn', stringdate('2026-09-10'));
INSERT INTO CustomerKG.kidehen.consent VALUES (30, 4, 3, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (31, 6, 3, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (32, 12, 3, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (33, 17, 3, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (34, 3, 4, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (35, 6, 4, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (36, 11, 4, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (37, 4, 5, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.consent VALUES (38, 12, 5, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.offer VALUES (1, 'Friday reminder', 'reminder', 0, 4);
INSERT INTO CustomerKG.kidehen.offer VALUES (2, 'Free side with any meal', 'incentive', 15, 3);
INSERT INTO CustomerKG.kidehen.offer VALUES (3, 'Family bundle, 20 percent off', 'bundle-incentive', 20, 2);
INSERT INTO CustomerKG.kidehen.offer VALUES (4, '10 percent off next order', 'incentive', 10, NULL);
INSERT INTO CustomerKG.kidehen.offer VALUES (5, 'Dessert on us', 'incentive', 12, 5);
INSERT INTO CustomerKG.kidehen.guardrail VALUES (1, 'Maximum discount depth 20 percent', 'discount-cap', 20, NULL);
INSERT INTO CustomerKG.kidehen.guardrail VALUES (2, 'At most 3 contacts per 14 days', 'contact-frequency', 3, NULL);
INSERT INTO CustomerKG.kidehen.guardrail VALUES (3, 'Contact only on a consented channel', 'consent-required', 1, NULL);
INSERT INTO CustomerKG.kidehen.guardrail VALUES (4, 'Human approval above 15 percent discount', 'human-approval', 15, NULL);
INSERT INTO CustomerKG.kidehen.guardrail VALUES (5, 'Bundle offers need human approval', 'human-approval', 1, 3);
INSERT INTO CustomerKG.kidehen.campaign VALUES (1, 'Reactivate lapsed customers', 'reactivate lapsed customers', stringdate('2026-09-22'));
INSERT INTO CustomerKG.kidehen.campaign VALUES (2, 'Test whether blanket discounts subsidise orders', 'avoid subsidising purchases that would have happened anyway', stringdate('2026-09-22'));
INSERT INTO CustomerKG.kidehen.decision VALUES (1, 1, 1, 'treatment', 'send-reminder', 1, 1, stringdate('2026-09-22'), 'Usual Friday order missed once, usual order browsed on Thursday: a reminder is enough', 0);
INSERT INTO CustomerKG.kidehen.decision VALUES (2, 2, 1, 'treatment', 'send-reminder', 1, 2, stringdate('2026-09-22'), 'Missed one Friday; email consent granted, push not offered', 0);
INSERT INTO CustomerKG.kidehen.decision VALUES (3, 3, 1, 'treatment', 'send-incentive', 3, 1, stringdate('2026-09-22'), 'Six weeks lapsed, browsing a family meal without checkout: bundle incentive', 1);
INSERT INTO CustomerKG.kidehen.decision VALUES (4, 4, 1, 'treatment', 'switch-channel', NULL, 5, stringdate('2026-09-22'), 'Ignored email twice: move to display retargeting with no offer', 0);
INSERT INTO CustomerKG.kidehen.decision VALUES (5, 5, 1, 'treatment', 'send-incentive', 2, 1, stringdate('2026-09-22'), 'Lapsing and price sensitive: free side', 0);
INSERT INTO CustomerKG.kidehen.decision VALUES (6, 6, 1, 'treatment', 'switch-channel', NULL, 4, stringdate('2026-09-22'), 'Repeated push without response: move to paid social with no offer', 0);
INSERT INTO CustomerKG.kidehen.decision VALUES (7, 7, 1, 'treatment', 'send-incentive', 4, 2, stringdate('2026-09-22'), 'Lapsing: ten percent off by email', 0);
INSERT INTO CustomerKG.kidehen.decision VALUES (8, 8, 1, 'treatment', 'suppress', NULL, NULL, stringdate('2026-09-22'), 'Four messages without response and push consent withdrawn: stop spend for now', 0);
INSERT INTO CustomerKG.kidehen.decision VALUES (9, 9, 1, 'treatment', 'send-incentive', 3, 1, stringdate('2026-09-22'), 'Lapsed gold member browsing a family meal: bundle incentive', 1);
INSERT INTO CustomerKG.kidehen.decision VALUES (10, 10, 1, 'holdout', 'no-action', NULL, NULL, stringdate('2026-09-22'), 'Randomised holdout: no contact', 0);
INSERT INTO CustomerKG.kidehen.decision VALUES (11, 11, 1, 'holdout', 'no-action', NULL, NULL, stringdate('2026-09-22'), 'Randomised holdout: no contact', 0);
INSERT INTO CustomerKG.kidehen.decision VALUES (12, 12, 1, 'holdout', 'no-action', NULL, NULL, stringdate('2026-09-22'), 'Randomised holdout: no contact', 0);
INSERT INTO CustomerKG.kidehen.decision VALUES (13, 13, 1, 'holdout', 'no-action', NULL, NULL, stringdate('2026-09-22'), 'Randomised holdout: no contact', 0);
INSERT INTO CustomerKG.kidehen.decision VALUES (14, 14, 1, 'holdout', 'no-action', NULL, NULL, stringdate('2026-09-22'), 'Randomised holdout: no contact', 0);
INSERT INTO CustomerKG.kidehen.decision VALUES (15, 15, 2, 'treatment', 'send-incentive', 4, 1, stringdate('2026-09-22'), 'Habitual Friday customer given the standard discount to test subsidy', 0);
INSERT INTO CustomerKG.kidehen.decision VALUES (16, 16, 2, 'treatment', 'send-incentive', 4, 1, stringdate('2026-09-22'), 'Habitual Saturday customer given the standard discount to test subsidy', 0);
INSERT INTO CustomerKG.kidehen.decision VALUES (17, 17, 2, 'treatment', 'send-incentive', 5, 3, stringdate('2026-09-22'), 'Habitual Friday customer given a dessert offer by SMS', 0);
INSERT INTO CustomerKG.kidehen.decision VALUES (18, 18, 2, 'treatment', 'send-incentive', 4, 2, stringdate('2026-09-22'), 'Habitual Sunday customer given the standard discount by email', 0);
INSERT INTO CustomerKG.kidehen.decision VALUES (19, 19, 2, 'holdout', 'no-action', NULL, NULL, stringdate('2026-09-22'), 'Randomised holdout: no contact', 0);
INSERT INTO CustomerKG.kidehen.decision VALUES (20, 20, 2, 'holdout', 'no-action', NULL, NULL, stringdate('2026-09-22'), 'Randomised holdout: no contact', 0);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (1, 2);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (1, 3);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (2, 2);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (2, 3);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (3, 1);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (3, 2);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (3, 3);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (3, 4);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (3, 5);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (4, 2);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (4, 3);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (5, 1);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (5, 2);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (5, 3);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (6, 2);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (6, 3);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (7, 1);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (7, 2);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (7, 3);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (8, 2);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (8, 3);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (9, 1);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (9, 2);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (9, 3);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (9, 4);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (9, 5);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (10, 2);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (10, 3);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (11, 2);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (11, 3);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (12, 2);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (12, 3);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (13, 2);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (13, 3);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (14, 2);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (14, 3);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (15, 1);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (15, 2);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (15, 3);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (16, 1);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (16, 2);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (16, 3);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (17, 1);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (17, 2);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (17, 3);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (18, 1);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (18, 2);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (18, 3);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (19, 2);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (19, 3);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (20, 2);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (20, 3);
INSERT INTO CustomerKG.kidehen.context_item VALUES (1, 1, 'customer', 'usual_order_day', 'Friday; skipped last week');
INSERT INTO CustomerKG.kidehen.context_item VALUES (2, 1, 'business', 'inventory', 'Weekly Friday Combo in stock');
INSERT INTO CustomerKG.kidehen.context_item VALUES (3, 1, 'decision', 'prior_offer', 'None in the last 30 days');
INSERT INTO CustomerKG.kidehen.context_item VALUES (4, 1, 'control', 'contact_frequency', '0 of 3 contacts used in 14 days');
INSERT INTO CustomerKG.kidehen.context_item VALUES (5, 3, 'customer', 'behaviour', 'Browsed a family meal six times without checkout');
INSERT INTO CustomerKG.kidehen.context_item VALUES (6, 3, 'business', 'margin', 'Family Meal Bundle margin is 31 percent');
INSERT INTO CustomerKG.kidehen.context_item VALUES (7, 3, 'decision', 'prior_offer', '10 percent off ignored five weeks ago');
INSERT INTO CustomerKG.kidehen.context_item VALUES (8, 3, 'control', 'approval', 'Discount of 20 percent needs human approval: granted');
INSERT INTO CustomerKG.kidehen.context_item VALUES (9, 8, 'customer', 'consent', 'Push consent withdrawn on 2026-09-10');
INSERT INTO CustomerKG.kidehen.context_item VALUES (10, 8, 'business', 'channel_constraint', 'Email contacts are capped at 3 per 14 days');
INSERT INTO CustomerKG.kidehen.context_item VALUES (11, 8, 'decision', 'prior_response', 'Four messages, no response');
INSERT INTO CustomerKG.kidehen.context_item VALUES (12, 8, 'control', 'action', 'Suppress and revisit after 30 days');
INSERT INTO CustomerKG.kidehen.context_item VALUES (13, 15, 'customer', 'lifecycle', 'Active, orders every Friday');
INSERT INTO CustomerKG.kidehen.context_item VALUES (14, 15, 'business', 'objective', 'Avoid subsidising habitual orders');
INSERT INTO CustomerKG.kidehen.context_item VALUES (15, 15, 'decision', 'prior_offer', '10 percent off redeemed three times');
INSERT INTO CustomerKG.kidehen.context_item VALUES (16, 15, 'control', 'discount_cap', '10 percent sits inside the 20 percent cap');
INSERT INTO CustomerKG.kidehen.context_item VALUES (17, 19, 'customer', 'lifecycle', 'Active, orders every Friday');
INSERT INTO CustomerKG.kidehen.context_item VALUES (18, 19, 'business', 'objective', 'Measure what happens with no offer');
INSERT INTO CustomerKG.kidehen.context_item VALUES (19, 19, 'decision', 'prior_offer', 'None');
INSERT INTO CustomerKG.kidehen.context_item VALUES (20, 19, 'control', 'holdout', 'Randomised no-contact arm');
INSERT INTO CustomerKG.kidehen.outcome VALUES (1, 1, 1, 24, 9, 0, 0, 1, stringdate('2026-10-06'));
INSERT INTO CustomerKG.kidehen.outcome VALUES (2, 2, 1, 22, 8, 0, 0, 1, stringdate('2026-10-06'));
INSERT INTO CustomerKG.kidehen.outcome VALUES (3, 3, 1, 48, 15, 0, 10, 1, stringdate('2026-10-06'));
INSERT INTO CustomerKG.kidehen.outcome VALUES (4, 4, 0, 0, 0, 2, 0, 0, stringdate('2026-10-06'));
INSERT INTO CustomerKG.kidehen.outcome VALUES (5, 5, 1, 19, 7, 0, 3, 0, stringdate('2026-10-06'));
INSERT INTO CustomerKG.kidehen.outcome VALUES (6, 6, 0, 0, 0, 2, 0, 0, stringdate('2026-10-06'));
INSERT INTO CustomerKG.kidehen.outcome VALUES (7, 7, 1, 26, 10, 0, 3, 1, stringdate('2026-10-06'));
INSERT INTO CustomerKG.kidehen.outcome VALUES (8, 8, 0, 0, 0, 0, 0, 0, stringdate('2026-10-06'));
INSERT INTO CustomerKG.kidehen.outcome VALUES (9, 9, 1, 52, 16, 0, 10, 1, stringdate('2026-10-06'));
INSERT INTO CustomerKG.kidehen.outcome VALUES (10, 10, 1, 25, 9, 0, 0, 1, stringdate('2026-10-06'));
INSERT INTO CustomerKG.kidehen.outcome VALUES (11, 11, 0, 0, 0, 0, 0, 0, stringdate('2026-10-06'));
INSERT INTO CustomerKG.kidehen.outcome VALUES (12, 12, 0, 0, 0, 0, 0, 0, stringdate('2026-10-06'));
INSERT INTO CustomerKG.kidehen.outcome VALUES (13, 13, 1, 21, 8, 0, 0, 0, stringdate('2026-10-06'));
INSERT INTO CustomerKG.kidehen.outcome VALUES (14, 14, 0, 0, 0, 0, 0, 0, stringdate('2026-10-06'));
INSERT INTO CustomerKG.kidehen.outcome VALUES (15, 15, 1, 23, 9, 0, 2, 1, stringdate('2026-10-06'));
INSERT INTO CustomerKG.kidehen.outcome VALUES (16, 16, 1, 21, 8, 0, 2, 0, stringdate('2026-10-06'));
INSERT INTO CustomerKG.kidehen.outcome VALUES (17, 17, 1, 25, 10, 1, 3, 1, stringdate('2026-10-06'));
INSERT INTO CustomerKG.kidehen.outcome VALUES (18, 18, 0, 0, 0, 0, 0, 0, stringdate('2026-10-06'));
INSERT INTO CustomerKG.kidehen.outcome VALUES (19, 19, 1, 24, 9, 0, 0, 1, stringdate('2026-10-06'));
INSERT INTO CustomerKG.kidehen.outcome VALUES (20, 20, 1, 22, 8, 0, 0, 1, stringdate('2026-10-06'));

-- Part 3: IRI classes (the SPARQL keyword and angle-bracket class names are required through isql)
SPARQL CREATE IRI CLASS <http://demo.openlinksw.com/schemas/CustomerKG/channel_iri> "http://demo.openlinksw.com/CustomerKG/channel/%d#this" (in channel_id integer not null);
SPARQL CREATE IRI CLASS <http://demo.openlinksw.com/schemas/CustomerKG/product_iri> "http://demo.openlinksw.com/CustomerKG/product/%d#this" (in product_id integer not null);
SPARQL CREATE IRI CLASS <http://demo.openlinksw.com/schemas/CustomerKG/customer_iri> "http://demo.openlinksw.com/CustomerKG/customer/%d#this" (in customer_id integer not null);
SPARQL CREATE IRI CLASS <http://demo.openlinksw.com/schemas/CustomerKG/signal_iri> "http://demo.openlinksw.com/CustomerKG/signal/%d#this" (in signal_id integer not null);
SPARQL CREATE IRI CLASS <http://demo.openlinksw.com/schemas/CustomerKG/consent_iri> "http://demo.openlinksw.com/CustomerKG/consent/%d#this" (in consent_id integer not null);
SPARQL CREATE IRI CLASS <http://demo.openlinksw.com/schemas/CustomerKG/offer_iri> "http://demo.openlinksw.com/CustomerKG/offer/%d#this" (in offer_id integer not null);
SPARQL CREATE IRI CLASS <http://demo.openlinksw.com/schemas/CustomerKG/guardrail_iri> "http://demo.openlinksw.com/CustomerKG/guardrail/%d#this" (in guardrail_id integer not null);
SPARQL CREATE IRI CLASS <http://demo.openlinksw.com/schemas/CustomerKG/campaign_iri> "http://demo.openlinksw.com/CustomerKG/campaign/%d#this" (in campaign_id integer not null);
SPARQL CREATE IRI CLASS <http://demo.openlinksw.com/schemas/CustomerKG/decision_iri> "http://demo.openlinksw.com/CustomerKG/decision/%d#this" (in decision_id integer not null);
SPARQL CREATE IRI CLASS <http://demo.openlinksw.com/schemas/CustomerKG/context_iri> "http://demo.openlinksw.com/CustomerKG/context/%d#this" (in item_id integer not null);
SPARQL CREATE IRI CLASS <http://demo.openlinksw.com/schemas/CustomerKG/outcome_iri> "http://demo.openlinksw.com/CustomerKG/outcome/%d#this" (in outcome_id integer not null);

-- Part 4: ontology and entailment rule set
-- Load customerkg-ontology-claude_sonnet_5_5-1.ttl into the graph below before you rely on entailment:
--   DB.DBA.TTLP(file_to_string_output('customerkg-ontology-claude_sonnet_5_5-1.ttl'), '', 'http://demo.openlinksw.com/schemas/CustomerKG/');
--   DB.DBA.rdfs_rule_set('urn:customerkg:inference', 'http://demo.openlinksw.com/schemas/CustomerKG/');

-- Part 5: the RDF View. Keep every mapping for the graph in one statement; a second statement replaces the first.
SPARQL
ALTER QUAD STORAGE virtrdf:DefaultQuadStorage
  FROM CustomerKG.kidehen.channel AS ch
  FROM CustomerKG.kidehen.product AS pr
  FROM CustomerKG.kidehen.customer AS cu
  FROM CustomerKG.kidehen.identity_signal AS sg
  FROM CustomerKG.kidehen.consent AS co
  FROM CustomerKG.kidehen.offer AS ofr
  FROM CustomerKG.kidehen.guardrail AS gr
  FROM CustomerKG.kidehen.campaign AS ca
  FROM CustomerKG.kidehen.decision AS de
  FROM CustomerKG.kidehen.decision_guardrail AS dg
  FROM CustomerKG.kidehen.context_item AS ci
  FROM CustomerKG.kidehen.outcome AS ou
{
  GRAPH <http://demo.openlinksw.com/CustomerKG#>
  {
    <http://demo.openlinksw.com/schemas/CustomerKG/channel_iri>(ch.channel_id) <http://www.w3.org/1999/02/22-rdf-syntax-ns#type> <http://demo.openlinksw.com/schemas/CustomerKG/Channel> as virtrdf:CustomerKG-channel-type .
    <http://demo.openlinksw.com/schemas/CustomerKG/channel_iri>(ch.channel_id) <http://schema.org/name> ch.channel_name as virtrdf:CustomerKG-channel-name .
    <http://demo.openlinksw.com/schemas/CustomerKG/channel_iri>(ch.channel_id) <http://demo.openlinksw.com/schemas/CustomerKG/channelKind> ch.channel_kind as virtrdf:CustomerKG-channel-kind .
    <http://demo.openlinksw.com/schemas/CustomerKG/product_iri>(pr.product_id) <http://www.w3.org/1999/02/22-rdf-syntax-ns#type> <http://demo.openlinksw.com/schemas/CustomerKG/Product> as virtrdf:CustomerKG-product-type .
    <http://demo.openlinksw.com/schemas/CustomerKG/product_iri>(pr.product_id) <http://schema.org/name> pr.product_name as virtrdf:CustomerKG-product-name .
    <http://demo.openlinksw.com/schemas/CustomerKG/product_iri>(pr.product_id) <http://demo.openlinksw.com/schemas/CustomerKG/category> pr.category as virtrdf:CustomerKG-product-category .
    <http://demo.openlinksw.com/schemas/CustomerKG/product_iri>(pr.product_id) <http://demo.openlinksw.com/schemas/CustomerKG/marginPct> pr.margin_pct as virtrdf:CustomerKG-product-margin .
    <http://demo.openlinksw.com/schemas/CustomerKG/customer_iri>(cu.customer_id) <http://www.w3.org/1999/02/22-rdf-syntax-ns#type> <http://demo.openlinksw.com/schemas/CustomerKG/Customer> as virtrdf:CustomerKG-customer-type .
    <http://demo.openlinksw.com/schemas/CustomerKG/customer_iri>(cu.customer_id) <http://schema.org/name> cu.full_name as virtrdf:CustomerKG-customer-name .
    <http://demo.openlinksw.com/schemas/CustomerKG/customer_iri>(cu.customer_id) <http://demo.openlinksw.com/schemas/CustomerKG/lifecycleStage> cu.lifecycle_stage as virtrdf:CustomerKG-customer-lifecycle .
    <http://demo.openlinksw.com/schemas/CustomerKG/customer_iri>(cu.customer_id) <http://demo.openlinksw.com/schemas/CustomerKG/loyaltyTier> cu.loyalty_tier as virtrdf:CustomerKG-customer-tier .
    <http://demo.openlinksw.com/schemas/CustomerKG/customer_iri>(cu.customer_id) <http://demo.openlinksw.com/schemas/CustomerKG/homeCity> cu.home_city as virtrdf:CustomerKG-customer-city .
    <http://demo.openlinksw.com/schemas/CustomerKG/customer_iri>(cu.customer_id) <http://demo.openlinksw.com/schemas/CustomerKG/usualOrderDay> cu.usual_order_day as virtrdf:CustomerKG-customer-day .
    <http://demo.openlinksw.com/schemas/CustomerKG/signal_iri>(sg.signal_id) <http://www.w3.org/1999/02/22-rdf-syntax-ns#type> <http://demo.openlinksw.com/schemas/CustomerKG/IdentitySignal> as virtrdf:CustomerKG-signal-type .
    <http://demo.openlinksw.com/schemas/CustomerKG/signal_iri>(sg.signal_id) <http://demo.openlinksw.com/schemas/CustomerKG/signalKind> sg.signal_kind as virtrdf:CustomerKG-signal-kind .
    <http://demo.openlinksw.com/schemas/CustomerKG/signal_iri>(sg.signal_id) <http://demo.openlinksw.com/schemas/CustomerKG/signalValue> sg.signal_value as virtrdf:CustomerKG-signal-value .
    <http://demo.openlinksw.com/schemas/CustomerKG/signal_iri>(sg.signal_id) <http://demo.openlinksw.com/schemas/CustomerKG/matchMethod> sg.match_method as virtrdf:CustomerKG-signal-method .
    <http://demo.openlinksw.com/schemas/CustomerKG/signal_iri>(sg.signal_id) <http://demo.openlinksw.com/schemas/CustomerKG/confidence> sg.confidence as virtrdf:CustomerKG-signal-confidence .
    <http://demo.openlinksw.com/schemas/CustomerKG/signal_iri>(sg.signal_id) <http://demo.openlinksw.com/schemas/CustomerKG/seenDate> sg.seen_date as virtrdf:CustomerKG-signal-seen .
    <http://demo.openlinksw.com/schemas/CustomerKG/signal_iri>(sg.signal_id) <http://demo.openlinksw.com/schemas/CustomerKG/resolvesTo> <http://demo.openlinksw.com/schemas/CustomerKG/customer_iri>(sg.customer_id) where (^{sg.}^.customer_id is not null) as virtrdf:CustomerKG-signal-customer .
    <http://demo.openlinksw.com/schemas/CustomerKG/consent_iri>(co.consent_id) <http://www.w3.org/1999/02/22-rdf-syntax-ns#type> <http://demo.openlinksw.com/schemas/CustomerKG/ConsentRecord> as virtrdf:CustomerKG-consent-type .
    <http://demo.openlinksw.com/schemas/CustomerKG/consent_iri>(co.consent_id) <http://demo.openlinksw.com/schemas/CustomerKG/consentStatus> co.status as virtrdf:CustomerKG-consent-status .
    <http://demo.openlinksw.com/schemas/CustomerKG/consent_iri>(co.consent_id) <http://demo.openlinksw.com/schemas/CustomerKG/updatedDate> co.updated_date as virtrdf:CustomerKG-consent-updated .
    <http://demo.openlinksw.com/schemas/CustomerKG/consent_iri>(co.consent_id) <http://demo.openlinksw.com/schemas/CustomerKG/forCustomer> <http://demo.openlinksw.com/schemas/CustomerKG/customer_iri>(co.customer_id) as virtrdf:CustomerKG-consent-customer .
    <http://demo.openlinksw.com/schemas/CustomerKG/consent_iri>(co.consent_id) <http://demo.openlinksw.com/schemas/CustomerKG/forChannel> <http://demo.openlinksw.com/schemas/CustomerKG/channel_iri>(co.channel_id) as virtrdf:CustomerKG-consent-channel .
    <http://demo.openlinksw.com/schemas/CustomerKG/offer_iri>(ofr.offer_id) <http://www.w3.org/1999/02/22-rdf-syntax-ns#type> <http://demo.openlinksw.com/schemas/CustomerKG/Offer> as virtrdf:CustomerKG-offer-type .
    <http://demo.openlinksw.com/schemas/CustomerKG/offer_iri>(ofr.offer_id) <http://schema.org/name> ofr.offer_name as virtrdf:CustomerKG-offer-name .
    <http://demo.openlinksw.com/schemas/CustomerKG/offer_iri>(ofr.offer_id) <http://demo.openlinksw.com/schemas/CustomerKG/offerKind> ofr.offer_kind as virtrdf:CustomerKG-offer-kind .
    <http://demo.openlinksw.com/schemas/CustomerKG/offer_iri>(ofr.offer_id) <http://demo.openlinksw.com/schemas/CustomerKG/discountPct> ofr.discount_pct as virtrdf:CustomerKG-offer-discount .
    <http://demo.openlinksw.com/schemas/CustomerKG/offer_iri>(ofr.offer_id) <http://demo.openlinksw.com/schemas/CustomerKG/promotes> <http://demo.openlinksw.com/schemas/CustomerKG/product_iri>(ofr.product_id) where (^{ofr.}^.product_id is not null) as virtrdf:CustomerKG-offer-product .
    <http://demo.openlinksw.com/schemas/CustomerKG/guardrail_iri>(gr.guardrail_id) <http://www.w3.org/1999/02/22-rdf-syntax-ns#type> <http://demo.openlinksw.com/schemas/CustomerKG/Guardrail> as virtrdf:CustomerKG-guardrail-type .
    <http://demo.openlinksw.com/schemas/CustomerKG/guardrail_iri>(gr.guardrail_id) <http://schema.org/name> gr.rule_name as virtrdf:CustomerKG-guardrail-name .
    <http://demo.openlinksw.com/schemas/CustomerKG/guardrail_iri>(gr.guardrail_id) <http://demo.openlinksw.com/schemas/CustomerKG/ruleKind> gr.rule_kind as virtrdf:CustomerKG-guardrail-kind .
    <http://demo.openlinksw.com/schemas/CustomerKG/guardrail_iri>(gr.guardrail_id) <http://demo.openlinksw.com/schemas/CustomerKG/limitValue> gr.limit_value as virtrdf:CustomerKG-guardrail-limit .
    <http://demo.openlinksw.com/schemas/CustomerKG/guardrail_iri>(gr.guardrail_id) <http://demo.openlinksw.com/schemas/CustomerKG/appliesToOffer> <http://demo.openlinksw.com/schemas/CustomerKG/offer_iri>(gr.offer_id) where (^{gr.}^.offer_id is not null) as virtrdf:CustomerKG-guardrail-offer .
    <http://demo.openlinksw.com/schemas/CustomerKG/campaign_iri>(ca.campaign_id) <http://www.w3.org/1999/02/22-rdf-syntax-ns#type> <http://demo.openlinksw.com/schemas/CustomerKG/Campaign> as virtrdf:CustomerKG-campaign-type .
    <http://demo.openlinksw.com/schemas/CustomerKG/campaign_iri>(ca.campaign_id) <http://schema.org/name> ca.campaign_name as virtrdf:CustomerKG-campaign-name .
    <http://demo.openlinksw.com/schemas/CustomerKG/campaign_iri>(ca.campaign_id) <http://demo.openlinksw.com/schemas/CustomerKG/goal> ca.goal as virtrdf:CustomerKG-campaign-goal .
    <http://demo.openlinksw.com/schemas/CustomerKG/campaign_iri>(ca.campaign_id) <http://demo.openlinksw.com/schemas/CustomerKG/startDate> ca.start_date as virtrdf:CustomerKG-campaign-start .
    <http://demo.openlinksw.com/schemas/CustomerKG/decision_iri>(de.decision_id) <http://www.w3.org/1999/02/22-rdf-syntax-ns#type> <http://demo.openlinksw.com/schemas/CustomerKG/Decision> as virtrdf:CustomerKG-decision-type .
    <http://demo.openlinksw.com/schemas/CustomerKG/decision_iri>(de.decision_id) <http://demo.openlinksw.com/schemas/CustomerKG/arm> de.arm as virtrdf:CustomerKG-decision-arm .
    <http://demo.openlinksw.com/schemas/CustomerKG/decision_iri>(de.decision_id) <http://demo.openlinksw.com/schemas/CustomerKG/actionKind> de.action_kind as virtrdf:CustomerKG-decision-action .
    <http://demo.openlinksw.com/schemas/CustomerKG/decision_iri>(de.decision_id) <http://demo.openlinksw.com/schemas/CustomerKG/decidedDate> de.decided_date as virtrdf:CustomerKG-decision-date .
    <http://demo.openlinksw.com/schemas/CustomerKG/decision_iri>(de.decision_id) <http://demo.openlinksw.com/schemas/CustomerKG/rationale> de.rationale as virtrdf:CustomerKG-decision-rationale .
    <http://demo.openlinksw.com/schemas/CustomerKG/decision_iri>(de.decision_id) <http://demo.openlinksw.com/schemas/CustomerKG/approvedByHuman> de.approved_by_human as virtrdf:CustomerKG-decision-approved .
    <http://demo.openlinksw.com/schemas/CustomerKG/decision_iri>(de.decision_id) <http://demo.openlinksw.com/schemas/CustomerKG/forCustomer> <http://demo.openlinksw.com/schemas/CustomerKG/customer_iri>(de.customer_id) as virtrdf:CustomerKG-decision-customer .
    <http://demo.openlinksw.com/schemas/CustomerKG/decision_iri>(de.decision_id) <http://demo.openlinksw.com/schemas/CustomerKG/inCampaign> <http://demo.openlinksw.com/schemas/CustomerKG/campaign_iri>(de.campaign_id) as virtrdf:CustomerKG-decision-campaign .
    <http://demo.openlinksw.com/schemas/CustomerKG/decision_iri>(de.decision_id) <http://demo.openlinksw.com/schemas/CustomerKG/usesOffer> <http://demo.openlinksw.com/schemas/CustomerKG/offer_iri>(de.offer_id) where (^{de.}^.offer_id is not null) as virtrdf:CustomerKG-decision-offer .
    <http://demo.openlinksw.com/schemas/CustomerKG/decision_iri>(de.decision_id) <http://demo.openlinksw.com/schemas/CustomerKG/viaChannel> <http://demo.openlinksw.com/schemas/CustomerKG/channel_iri>(de.channel_id) where (^{de.}^.channel_id is not null) as virtrdf:CustomerKG-decision-channel .
    <http://demo.openlinksw.com/schemas/CustomerKG/decision_iri>(dg.decision_id) <http://demo.openlinksw.com/schemas/CustomerKG/constrainedBy> <http://demo.openlinksw.com/schemas/CustomerKG/guardrail_iri>(dg.guardrail_id) as virtrdf:CustomerKG-decision-guardrail .
    <http://demo.openlinksw.com/schemas/CustomerKG/context_iri>(ci.item_id) <http://www.w3.org/1999/02/22-rdf-syntax-ns#type> <http://demo.openlinksw.com/schemas/CustomerKG/ContextItem> as virtrdf:CustomerKG-context-type .
    <http://demo.openlinksw.com/schemas/CustomerKG/context_iri>(ci.item_id) <http://demo.openlinksw.com/schemas/CustomerKG/contextType> ci.context_type as virtrdf:CustomerKG-context-kind .
    <http://demo.openlinksw.com/schemas/CustomerKG/context_iri>(ci.item_id) <http://demo.openlinksw.com/schemas/CustomerKG/contextKey> ci.context_key as virtrdf:CustomerKG-context-key .
    <http://demo.openlinksw.com/schemas/CustomerKG/context_iri>(ci.item_id) <http://demo.openlinksw.com/schemas/CustomerKG/contextValue> ci.context_value as virtrdf:CustomerKG-context-value .
    <http://demo.openlinksw.com/schemas/CustomerKG/context_iri>(ci.item_id) <http://demo.openlinksw.com/schemas/CustomerKG/informs> <http://demo.openlinksw.com/schemas/CustomerKG/decision_iri>(ci.decision_id) as virtrdf:CustomerKG-context-decision .
    <http://demo.openlinksw.com/schemas/CustomerKG/outcome_iri>(ou.outcome_id) <http://www.w3.org/1999/02/22-rdf-syntax-ns#type> <http://demo.openlinksw.com/schemas/CustomerKG/Outcome> as virtrdf:CustomerKG-outcome-type .
    <http://demo.openlinksw.com/schemas/CustomerKG/outcome_iri>(ou.outcome_id) <http://demo.openlinksw.com/schemas/CustomerKG/ordered> ou.ordered as virtrdf:CustomerKG-outcome-ordered .
    <http://demo.openlinksw.com/schemas/CustomerKG/outcome_iri>(ou.outcome_id) <http://demo.openlinksw.com/schemas/CustomerKG/revenueUsd> ou.revenue_usd as virtrdf:CustomerKG-outcome-revenue .
    <http://demo.openlinksw.com/schemas/CustomerKG/outcome_iri>(ou.outcome_id) <http://demo.openlinksw.com/schemas/CustomerKG/marginUsd> ou.margin_usd as virtrdf:CustomerKG-outcome-margin .
    <http://demo.openlinksw.com/schemas/CustomerKG/outcome_iri>(ou.outcome_id) <http://demo.openlinksw.com/schemas/CustomerKG/mediaCostUsd> ou.media_cost_usd as virtrdf:CustomerKG-outcome-media .
    <http://demo.openlinksw.com/schemas/CustomerKG/outcome_iri>(ou.outcome_id) <http://demo.openlinksw.com/schemas/CustomerKG/discountCostUsd> ou.discount_cost_usd as virtrdf:CustomerKG-outcome-discount .
    <http://demo.openlinksw.com/schemas/CustomerKG/outcome_iri>(ou.outcome_id) <http://demo.openlinksw.com/schemas/CustomerKG/repeatVisit30d> ou.repeat_visit_30d as virtrdf:CustomerKG-outcome-repeat .
    <http://demo.openlinksw.com/schemas/CustomerKG/outcome_iri>(ou.outcome_id) <http://demo.openlinksw.com/schemas/CustomerKG/windowEnd> ou.window_end as virtrdf:CustomerKG-outcome-window .
    <http://demo.openlinksw.com/schemas/CustomerKG/outcome_iri>(ou.outcome_id) <http://demo.openlinksw.com/schemas/CustomerKG/ofDecision> <http://demo.openlinksw.com/schemas/CustomerKG/decision_iri>(ou.decision_id) as virtrdf:CustomerKG-outcome-decision .
  }
} ;

-- Part 6: access. The view inherits the SQL privileges of its tables.
GRANT SELECT ON CustomerKG.kidehen.channel TO "SPARQL";
GRANT SELECT ON CustomerKG.kidehen.channel TO PUBLIC;
GRANT SELECT ON CustomerKG.kidehen.channel TO "demo";
GRANT SELECT ON CustomerKG.kidehen.channel TO "vdb";
GRANT SELECT ON CustomerKG.kidehen.product TO "SPARQL";
GRANT SELECT ON CustomerKG.kidehen.product TO PUBLIC;
GRANT SELECT ON CustomerKG.kidehen.product TO "demo";
GRANT SELECT ON CustomerKG.kidehen.product TO "vdb";
GRANT SELECT ON CustomerKG.kidehen.customer TO "SPARQL";
GRANT SELECT ON CustomerKG.kidehen.customer TO PUBLIC;
GRANT SELECT ON CustomerKG.kidehen.customer TO "demo";
GRANT SELECT ON CustomerKG.kidehen.customer TO "vdb";
GRANT SELECT ON CustomerKG.kidehen.identity_signal TO "SPARQL";
GRANT SELECT ON CustomerKG.kidehen.identity_signal TO PUBLIC;
GRANT SELECT ON CustomerKG.kidehen.identity_signal TO "demo";
GRANT SELECT ON CustomerKG.kidehen.identity_signal TO "vdb";
GRANT SELECT ON CustomerKG.kidehen.consent TO "SPARQL";
GRANT SELECT ON CustomerKG.kidehen.consent TO PUBLIC;
GRANT SELECT ON CustomerKG.kidehen.consent TO "demo";
GRANT SELECT ON CustomerKG.kidehen.consent TO "vdb";
GRANT SELECT ON CustomerKG.kidehen.offer TO "SPARQL";
GRANT SELECT ON CustomerKG.kidehen.offer TO PUBLIC;
GRANT SELECT ON CustomerKG.kidehen.offer TO "demo";
GRANT SELECT ON CustomerKG.kidehen.offer TO "vdb";
GRANT SELECT ON CustomerKG.kidehen.guardrail TO "SPARQL";
GRANT SELECT ON CustomerKG.kidehen.guardrail TO PUBLIC;
GRANT SELECT ON CustomerKG.kidehen.guardrail TO "demo";
GRANT SELECT ON CustomerKG.kidehen.guardrail TO "vdb";
GRANT SELECT ON CustomerKG.kidehen.campaign TO "SPARQL";
GRANT SELECT ON CustomerKG.kidehen.campaign TO PUBLIC;
GRANT SELECT ON CustomerKG.kidehen.campaign TO "demo";
GRANT SELECT ON CustomerKG.kidehen.campaign TO "vdb";
GRANT SELECT ON CustomerKG.kidehen.decision TO "SPARQL";
GRANT SELECT ON CustomerKG.kidehen.decision TO PUBLIC;
GRANT SELECT ON CustomerKG.kidehen.decision TO "demo";
GRANT SELECT ON CustomerKG.kidehen.decision TO "vdb";
GRANT SELECT ON CustomerKG.kidehen.decision_guardrail TO "SPARQL";
GRANT SELECT ON CustomerKG.kidehen.decision_guardrail TO PUBLIC;
GRANT SELECT ON CustomerKG.kidehen.decision_guardrail TO "demo";
GRANT SELECT ON CustomerKG.kidehen.decision_guardrail TO "vdb";
GRANT SELECT ON CustomerKG.kidehen.context_item TO "SPARQL";
GRANT SELECT ON CustomerKG.kidehen.context_item TO PUBLIC;
GRANT SELECT ON CustomerKG.kidehen.context_item TO "demo";
GRANT SELECT ON CustomerKG.kidehen.context_item TO "vdb";
GRANT SELECT ON CustomerKG.kidehen.outcome TO "SPARQL";
GRANT SELECT ON CustomerKG.kidehen.outcome TO PUBLIC;
GRANT SELECT ON CustomerKG.kidehen.outcome TO "demo";
GRANT SELECT ON CustomerKG.kidehen.outcome TO "vdb";

-- Part 7: URL rewrite rules, generated by RDFVIEW_GENERATE_DATA_RULES with iri_path_segment=CustomerKG and include_ontology_rules=1.
-- Without them the entity IRIs return 404. Run through isql or SELECT exec() one statement at a time.
DB.DBA.URLREWRITE_CREATE_REGEX_RULE (
'customerkg_rule2',
1,
'(/[^#]*)',
vector('path'),
1,
'/sparql?query=DESCRIBE+%%3Chttp%%3A//^{URIQADefaultHost}^%U%%23this%%3E+FROM+%%3Chttp%%3A//^{URIQADefaultHost}^/CustomerKG%%23%%3E&format=%U',
vector('path', '*accept*'),
null,
'(text/rdf.n3)|(application/rdf.xml)|(text/n3)|(application/json)|(text/turtle)',
2,
null
);
DB.DBA.URLREWRITE_CREATE_REGEX_RULE (
'customerkg_rule4',
1,
'/CustomerKG/stat([^#]*)',
vector('path'),
1,
'/sparql?query=DESCRIBE+%%3Chttp%%3A//^{URIQADefaultHost}^/CustomerKG/stat%%23%%3E+%%3Fo+FROM+%%3Chttp%%3A//^{URIQADefaultHost}^/CustomerKG%%23%%3E+WHERE+{+%%3Chttp%%3A//^{URIQADefaultHost}^/CustomerKG/stat%%23%%3E+%%3Fp+%%3Fo+}&format=%U',
vector('*accept*'),
null,
'(text/rdf.n3)|(application/rdf.xml)|(text/n3)|(application/json)|(text/turtle)',
2,
null
);
DB.DBA.URLREWRITE_CREATE_REGEX_RULE (
'customerkg_rule6',
1,
'/CustomerKG/objects/([^#]*)',
vector('path'),
1,
'/sparql?query=DESCRIBE+%%3Chttp%%3A//^{URIQADefaultHost}^/CustomerKG/objects/%U%%3E+FROM+%%3Chttp%%3A//^{URIQADefaultHost}^/CustomerKG%%23%%3E&format=%U',
vector('path', '*accept*'),
null,
'(text/rdf.n3)|(application/rdf.xml)|(text/n3)|(application/json)|(text/turtle)',
2,
null
);
DB.DBA.URLREWRITE_CREATE_REGEX_RULE (
'customerkg_rule1',
1,
'([^#]*)',
vector('path'),
1,
'/describe/?url=http%%3A//^{URIQADefaultHost}^%U%%23this&graph=http%%3A//^{URIQADefaultHost}^/CustomerKG%%23&distinct=0',
vector('path'),
null,
null,
2,
303
);
DB.DBA.URLREWRITE_CREATE_REGEX_RULE (
'customerkg_rule7',
1,
'/CustomerKG/stat([^#]*)',
vector('path'),
1,
'/describe/?url=http%%3A//^{URIQADefaultHost}^/CustomerKG/stat%%23&graph=http%%3A//^{URIQADefaultHost}^/CustomerKG%%23',
vector('path'),
null,
null,
2,
303
);
DB.DBA.URLREWRITE_CREATE_REGEX_RULE (
'customerkg_rule5',
1,
'/CustomerKG/objects/(.*)',
vector('path'),
1,
'/services/rdf/object.binary?path=%%2FCustomerKG%%2Fobjects%%2F%U&accept=%U',
vector('path', '*accept*'),
null,
null,
2,
null
);
DB.DBA.URLREWRITE_CREATE_RULELIST ( 'customerkg_rule_list1', 1, vector ( 'customerkg_rule1', 'customerkg_rule7', 'customerkg_rule5', 'customerkg_rule2', 'customerkg_rule4', 'customerkg_rule6'));
DB.DBA.VHOST_REMOVE (lpath=>'/CustomerKG');
DB.DBA.VHOST_DEFINE (lpath=>'/CustomerKG', ppath=>'/', vsp_user=>'dba', is_dav=>0,
is_brws=>0, opts=>vector ('url_rewrite', 'customerkg_rule_list1')
);
DB.DBA.URLREWRITE_CREATE_REGEX_RULE (
'customerkg_owl_rule2',
1,
'(/[^#]*)',
vector('path'),
1,
'/sparql?query=DESCRIBE+%%3Chttp%%3A//^{URIQADefaultHost}^%U%%3E+FROM+%%3Chttp%%3A//^{URIQADefaultHost}^/schemas/CustomerKG%%23%%3E&format=%U',
vector('path', '*accept*'),
null,
'(text/rdf.n3)|(application/rdf.xml)|(text/n3)|(application/json)|(text/turtle)',
2,
null
);
DB.DBA.URLREWRITE_CREATE_REGEX_RULE (
'customerkg_owl_rule1',
1,
'([^#]*)',
vector('path'),
1,
'/describe/?url=http://^{URIQADefaultHost}^%U',
vector('path'),
null,
null,
2,
303
);
DB.DBA.URLREWRITE_CREATE_RULELIST ( 'customerkg_owl_rule_list1', 1, vector ( 'customerkg_owl_rule1', 'customerkg_owl_rule2'));
DB.DBA.VHOST_REMOVE (lpath=>'/schemas/CustomerKG');
DB.DBA.VHOST_DEFINE (lpath=>'/schemas/CustomerKG', ppath=>'/', vsp_user=>'dba', is_dav=>0,
is_brws=>0, opts=>vector ('url_rewrite', 'customerkg_owl_rule_list1')
);

-- Part 8: identity reconciliation graph. Inverse-functional-property and owl:sameAs reasoning over a physical graph that
-- carries facts derived from the view plus records from other systems. Query it with the pragmas shown in the page.
-- 1. Vocabulary: declare the identifying property inverse functional, in its own graph
DB.DBA.TTLP(file_to_string_output('customerkg-identity-vocabulary-claude_sonnet_5_5-1.ttl'), '', 'http://demo.openlinksw.com/schemas/CustomerKG/identity/');
-- The Turtle loaded by that call:
@prefix ckg: <http://demo.openlinksw.com/schemas/CustomerKG/> .
@prefix owl: <http://www.w3.org/2002/07/owl#> .
@prefix rdfs: <http://www.w3.org/2000/01/rdf-schema#> .
@prefix schema: <http://schema.org/> .
@prefix xsd: <http://www.w3.org/2001/XMLSchema#> .

<http://demo.openlinksw.com/schemas/CustomerKG/identity/> a owl:Ontology ;
    rdfs:label "CustomerKG identity reconciliation vocabulary"@en .

ckg:emailHash a owl:InverseFunctionalProperty, owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/identity/> ;
    rdfs:label "email hash"@en ;
    rdfs:comment "A pseudonymous hash of an email address. Two records that carry the same hash describe the same person, so the property is declared inverse functional and a reasoner derives owl:sameAs between them."@en ;
    rdfs:domain schema:Person ;
    rdfs:range xsd:string .

-- 2. Rule set: derive reasoning rules from that vocabulary
DB.DBA.rdfs_rule_set('urn:customerkg:identity-inference', 'http://demo.openlinksw.com/schemas/CustomerKG/identity/');

-- 3. Identity graph, part one: facts derived from the live RDF View (nothing is retyped)
SPARQL PREFIX ckg: <http://demo.openlinksw.com/schemas/CustomerKG/> PREFIX schema: <http://schema.org/>
INSERT INTO GRAPH <http://demo.openlinksw.com/CustomerKG/identity#> { ?c ckg:emailHash ?v }
WHERE { GRAPH <http://demo.openlinksw.com/CustomerKG#> { ?s a ckg:IdentitySignal ; ckg:signalKind "email" ; ckg:signalValue ?v ; ckg:resolvesTo ?c } };

SPARQL PREFIX ckg: <http://demo.openlinksw.com/schemas/CustomerKG/> PREFIX schema: <http://schema.org/>
INSERT INTO GRAPH <http://demo.openlinksw.com/CustomerKG/identity#> { ?c a schema:Person ; schema:name ?n }
WHERE { GRAPH <http://demo.openlinksw.com/CustomerKG#> { ?c a ckg:Customer ; schema:name ?n } };

-- 4. Identity graph, part two: records from other systems, one explicit owl:sameAs, one record that matches nobody
SPARQL PREFIX ckg: <http://demo.openlinksw.com/schemas/CustomerKG/> PREFIX schema: <http://schema.org/> PREFIX owl: <http://www.w3.org/2002/07/owl#>
INSERT DATA INTO GRAPH <http://demo.openlinksw.com/CustomerKG/identity#> {
  <http://demo.openlinksw.com/CustomerKG/external/crm/501#this> a schema:Person ; schema:name "A. Quinn (CRM export)" ; ckg:emailHash "hem:a1f3" .
  <http://demo.openlinksw.com/CustomerKG/external/app/77#this> a schema:Person ; schema:name "Avery Q. (app profile)" ; ckg:emailHash "hem:a1f3" .
  <http://demo.openlinksw.com/CustomerKG/external/crm/502#this> a schema:Person ; schema:name "B. Moreno (CRM export)" ; ckg:emailHash "hem:b2c4" .
  <http://demo.openlinksw.com/CustomerKG/external/crm/599#this> a schema:Person ; schema:name "Unmatched (CRM export)" ; ckg:emailHash "hem:ffff" .
  <http://demo.openlinksw.com/CustomerKG/external/loyalty/LY-10001#this> a schema:Person ; schema:name "Loyalty member LY-10001" ; owl:sameAs <http://demo.openlinksw.com/CustomerKG/customer/1#this> .
};

The relational estate: channels, products, customers, identity signals, consent, offers, guardrails, campaigns, decisions, the decision-to-guardrail link table, context items and outcomes. Standard SQL; nullable foreign keys are deliberate, for unmatched signals and for actions without an offer or channel.

CREATE TABLE CustomerKG.kidehen.channel (channel_id INTEGER NOT NULL PRIMARY KEY, channel_name VARCHAR(40) NOT NULL, channel_kind VARCHAR(8) NOT NULL);

CREATE TABLE CustomerKG.kidehen.product (product_id INTEGER NOT NULL PRIMARY KEY, product_name VARCHAR(48) NOT NULL, category VARCHAR(16) NOT NULL, margin_pct INTEGER NOT NULL);

CREATE TABLE CustomerKG.kidehen.customer (customer_id INTEGER NOT NULL PRIMARY KEY, full_name VARCHAR(48) NOT NULL, lifecycle_stage VARCHAR(12) NOT NULL, loyalty_tier VARCHAR(8) NOT NULL, home_city VARCHAR(24) NOT NULL, usual_order_day VARCHAR(10) NOT NULL);

CREATE TABLE CustomerKG.kidehen.identity_signal (signal_id INTEGER NOT NULL PRIMARY KEY, customer_id INTEGER, signal_kind VARCHAR(16) NOT NULL, signal_value VARCHAR(24) NOT NULL, match_method VARCHAR(16) NOT NULL, confidence INTEGER NOT NULL, seen_date DATE NOT NULL, FOREIGN KEY (customer_id) REFERENCES CustomerKG.kidehen.customer (customer_id));

CREATE TABLE CustomerKG.kidehen.consent (consent_id INTEGER NOT NULL PRIMARY KEY, customer_id INTEGER NOT NULL, channel_id INTEGER NOT NULL, status VARCHAR(10) NOT NULL, updated_date DATE NOT NULL, FOREIGN KEY (customer_id) REFERENCES CustomerKG.kidehen.customer (customer_id), FOREIGN KEY (channel_id) REFERENCES CustomerKG.kidehen.channel (channel_id));

CREATE TABLE CustomerKG.kidehen.offer (offer_id INTEGER NOT NULL PRIMARY KEY, offer_name VARCHAR(40) NOT NULL, offer_kind VARCHAR(16) NOT NULL, discount_pct INTEGER NOT NULL, product_id INTEGER, FOREIGN KEY (product_id) REFERENCES CustomerKG.kidehen.product (product_id));

CREATE TABLE CustomerKG.kidehen.guardrail (guardrail_id INTEGER NOT NULL PRIMARY KEY, rule_name VARCHAR(48) NOT NULL, rule_kind VARCHAR(20) NOT NULL, limit_value INTEGER NOT NULL, offer_id INTEGER, FOREIGN KEY (offer_id) REFERENCES CustomerKG.kidehen.offer (offer_id));

CREATE TABLE CustomerKG.kidehen.campaign (campaign_id INTEGER NOT NULL PRIMARY KEY, campaign_name VARCHAR(48) NOT NULL, goal VARCHAR(80) NOT NULL, start_date DATE NOT NULL);

CREATE TABLE CustomerKG.kidehen.decision (decision_id INTEGER NOT NULL PRIMARY KEY, customer_id INTEGER NOT NULL, campaign_id INTEGER NOT NULL, arm VARCHAR(10) NOT NULL, action_kind VARCHAR(16) NOT NULL, offer_id INTEGER, channel_id INTEGER, decided_date DATE NOT NULL, rationale VARCHAR(160) NOT NULL, approved_by_human INTEGER NOT NULL, FOREIGN KEY (customer_id) REFERENCES CustomerKG.kidehen.customer (customer_id), FOREIGN KEY (campaign_id) REFERENCES CustomerKG.kidehen.campaign (campaign_id), FOREIGN KEY (offer_id) REFERENCES CustomerKG.kidehen.offer (offer_id), FOREIGN KEY (channel_id) REFERENCES CustomerKG.kidehen.channel (channel_id));

CREATE TABLE CustomerKG.kidehen.decision_guardrail (decision_id INTEGER NOT NULL, guardrail_id INTEGER NOT NULL, PRIMARY KEY (decision_id, guardrail_id), FOREIGN KEY (decision_id) REFERENCES CustomerKG.kidehen.decision (decision_id), FOREIGN KEY (guardrail_id) REFERENCES CustomerKG.kidehen.guardrail (guardrail_id));

CREATE TABLE CustomerKG.kidehen.context_item (item_id INTEGER NOT NULL PRIMARY KEY, decision_id INTEGER NOT NULL, context_type VARCHAR(10) NOT NULL, context_key VARCHAR(24) NOT NULL, context_value VARCHAR(120) NOT NULL, FOREIGN KEY (decision_id) REFERENCES CustomerKG.kidehen.decision (decision_id));

CREATE TABLE CustomerKG.kidehen.outcome (outcome_id INTEGER NOT NULL PRIMARY KEY, decision_id INTEGER NOT NULL, ordered INTEGER NOT NULL, revenue_usd INTEGER NOT NULL, margin_usd INTEGER NOT NULL, media_cost_usd INTEGER NOT NULL, discount_cost_usd INTEGER NOT NULL, repeat_visit_30d INTEGER NOT NULL, window_end DATE NOT NULL, FOREIGN KEY (decision_id) REFERENCES CustomerKG.kidehen.decision (decision_id));

Two hundred and twenty-eight rows in all. The data is synthetic and illustrative: it models the article's quick-service-restaurant scenario and is not Databricks data; every customer name is invented.

-- One representative row per table; the batch script carries all 228.
INSERT INTO CustomerKG.kidehen.channel VALUES (1, 'App push', 'owned');
INSERT INTO CustomerKG.kidehen.product VALUES (1, 'Classic Burger Meal', 'meal', 38);
INSERT INTO CustomerKG.kidehen.customer VALUES (1, 'Avery Quinn', 'lapsing', 'gold', 'Austin', 'Friday');
INSERT INTO CustomerKG.kidehen.identity_signal VALUES (1, 1, 'email', 'hem:a1f3', 'deterministic', 100, stringdate('2026-08-02'));
INSERT INTO CustomerKG.kidehen.consent VALUES (1, 1, 2, 'granted', stringdate('2026-08-01'));
INSERT INTO CustomerKG.kidehen.offer VALUES (1, 'Friday reminder', 'reminder', 0, 4);
INSERT INTO CustomerKG.kidehen.guardrail VALUES (1, 'Maximum discount depth 20 percent', 'discount-cap', 20, NULL);
INSERT INTO CustomerKG.kidehen.campaign VALUES (1, 'Reactivate lapsed customers', 'reactivate lapsed customers', stringdate('2026-09-22'));
INSERT INTO CustomerKG.kidehen.decision VALUES (1, 1, 1, 'treatment', 'send-reminder', 1, 1, stringdate('2026-09-22'), 'Usual Friday order missed once, usual order browsed on Thursday: a reminder is enough', 0);
INSERT INTO CustomerKG.kidehen.decision_guardrail VALUES (1, 2);
INSERT INTO CustomerKG.kidehen.context_item VALUES (1, 1, 'customer', 'usual_order_day', 'Friday; skipped last week');
INSERT INTO CustomerKG.kidehen.outcome VALUES (1, 1, 1, 24, 9, 0, 0, 1, stringdate('2026-10-06'));

An RDF View has no access rules of its own; it inherits the SQL privileges of its source tables. SPARQL serves the anonymous endpoint, PUBLIC the rest, and demo and vdb the Query Builder and XMLA routes.

GRANT SELECT ON CustomerKG.kidehen.channel TO "SPARQL";
GRANT SELECT ON CustomerKG.kidehen.channel TO PUBLIC;
GRANT SELECT ON CustomerKG.kidehen.channel TO "demo";
GRANT SELECT ON CustomerKG.kidehen.channel TO "vdb";
-- ...repeated for each of the 12 tables (48 statements in the batch script)

Each IRI class turns a key column into a dereferenceable IRI. Through isql the statement needs the SPARQL keyword in front and the class name as an angle-bracket IRI. On the shared demo server the eleven statements together took several minutes.

SPARQL CREATE IRI CLASS <http://demo.openlinksw.com/schemas/CustomerKG/channel_iri> "http://demo.openlinksw.com/CustomerKG/channel/%d#this" (in channel_id integer not null);
SPARQL CREATE IRI CLASS <http://demo.openlinksw.com/schemas/CustomerKG/product_iri> "http://demo.openlinksw.com/CustomerKG/product/%d#this" (in product_id integer not null);
SPARQL CREATE IRI CLASS <http://demo.openlinksw.com/schemas/CustomerKG/customer_iri> "http://demo.openlinksw.com/CustomerKG/customer/%d#this" (in customer_id integer not null);
SPARQL CREATE IRI CLASS <http://demo.openlinksw.com/schemas/CustomerKG/signal_iri> "http://demo.openlinksw.com/CustomerKG/signal/%d#this" (in signal_id integer not null);
SPARQL CREATE IRI CLASS <http://demo.openlinksw.com/schemas/CustomerKG/consent_iri> "http://demo.openlinksw.com/CustomerKG/consent/%d#this" (in consent_id integer not null);
SPARQL CREATE IRI CLASS <http://demo.openlinksw.com/schemas/CustomerKG/offer_iri> "http://demo.openlinksw.com/CustomerKG/offer/%d#this" (in offer_id integer not null);
SPARQL CREATE IRI CLASS <http://demo.openlinksw.com/schemas/CustomerKG/guardrail_iri> "http://demo.openlinksw.com/CustomerKG/guardrail/%d#this" (in guardrail_id integer not null);
SPARQL CREATE IRI CLASS <http://demo.openlinksw.com/schemas/CustomerKG/campaign_iri> "http://demo.openlinksw.com/CustomerKG/campaign/%d#this" (in campaign_id integer not null);
SPARQL CREATE IRI CLASS <http://demo.openlinksw.com/schemas/CustomerKG/decision_iri> "http://demo.openlinksw.com/CustomerKG/decision/%d#this" (in decision_id integer not null);
SPARQL CREATE IRI CLASS <http://demo.openlinksw.com/schemas/CustomerKG/context_iri> "http://demo.openlinksw.com/CustomerKG/context/%d#this" (in item_id integer not null);
SPARQL CREATE IRI CLASS <http://demo.openlinksw.com/schemas/CustomerKG/outcome_iri> "http://demo.openlinksw.com/CustomerKG/outcome/%d#this" (in outcome_id integer not null);

The vocabulary for the view's graph: 16 classes and 47 properties with labels, comments, domains and ranges, cross-referenced to schema.org supertypes and close matches, and the four-group context hierarchy and groundedIn property hierarchy the entailment queries use.

@prefix :       <http://demo.openlinksw.com/schemas/CustomerKG/> .
@prefix ckg:    <http://demo.openlinksw.com/schemas/CustomerKG/> .
@prefix schema: <http://schema.org/> .
@prefix xsd:    <http://www.w3.org/2001/XMLSchema#> .
@prefix rdf:    <http://www.w3.org/1999/02/22-rdf-syntax-ns#> .
@prefix rdfs:   <http://www.w3.org/2000/01/rdf-schema#> .
@prefix owl:    <http://www.w3.org/2002/07/owl#> .
@prefix skos:   <http://www.w3.org/2004/02/skos/core#> .

# TBox for the CustomerKG RDF View on demo.openlinksw.com. The ontology is the entity
# <http://demo.openlinksw.com/schemas/CustomerKG/>; this document is a separate CreativeWork.

<http://demo.openlinksw.com/schemas/CustomerKG/ontology-document> a schema:CreativeWork ;
    schema:name "CustomerKG ontology (TBox)"@en ;
    schema:description "RDFS/OWL vocabulary for the CustomerKG demonstration: customers, identity signals, consent, channels, products, offers, guardrails, campaigns, decisions, context items and outcomes, grouped under the four kinds of context the Databricks agentic-marketing article names. Loaded into the named graph http://demo.openlinksw.com/schemas/CustomerKG/."@en ;
    schema:dateCreated "2026-10-02T00:00:00Z"^^xsd:dateTime ;
    schema:dateModified "2026-10-02T00:00:00Z"^^xsd:dateTime ;
    schema:author <https://www.linkedin.com/in/kidehen#this> ;
    schema:about <http://demo.openlinksw.com/schemas/CustomerKG/> .

<http://demo.openlinksw.com/schemas/CustomerKG/> a owl:Ontology ;
    rdfs:label "CustomerKG ontology"@en ;
    rdfs:comment "Vocabulary for describing the customer, business, decision and control context an agent reads before choosing a marketing action, and the measured outcome that follows."@en ;
    owl:versionInfo "1.0"@en .

# ── Classes ────────────────────────────────────────────────────────────────

ckg:ContextElement a owl:Class ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "Context element"@en ;
    rdfs:comment "Anything an agent may read before deciding what to do for a customer. The four groups below follow the four kinds of context the Databricks article names: customer, business, decision and control."@en ;
    rdfs:subClassOf schema:Thing .

ckg:CustomerContextElement a owl:Class ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "Customer context element"@en ;
    rdfs:comment "Identity, behaviour, preference, consent and lifecycle facts about a customer."@en ;
    rdfs:subClassOf ckg:ContextElement .

ckg:BusinessContextElement a owl:Class ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "Business context element"@en ;
    rdfs:comment "Growth objectives, margin, brand rules, inventory and channel constraints."@en ;
    rdfs:subClassOf ckg:ContextElement .

ckg:DecisionContextElement a owl:Class ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "Decision context element"@en ;
    rdfs:comment "The actions already taken, how customers responded and why earlier decisions were made."@en ;
    rdfs:subClassOf ckg:ContextElement .

ckg:ControlElement a owl:Class ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "Control element"@en ;
    rdfs:comment "The intent, guardrails, permissions and approval points that people define and agents must respect."@en ;
    rdfs:subClassOf ckg:ContextElement .

ckg:Customer a owl:Class ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "Customer"@en ;
    rdfs:comment "A person who buys from the brand, with a lifecycle stage and a loyalty tier."@en ;
    rdfs:subClassOf schema:Person, ckg:CustomerContextElement .

ckg:IdentitySignal a owl:Class ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "Identity signal"@en ;
    rdfs:comment "One observation that may identify a customer: an email hash, device, app session, ad exposure or loyalty id, with the method that matched it and the confidence. Unmatched pseudonymous signals have no customer."@en ;
    rdfs:subClassOf schema:Observation, ckg:CustomerContextElement .

ckg:ConsentRecord a owl:Class ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "Consent record"@en ;
    rdfs:comment "Whether a customer allows contact on one channel. It is both a customer fact and a control, so it sits under both groups."@en ;
    rdfs:subClassOf schema:Permit, ckg:CustomerContextElement, ckg:ControlElement .

ckg:Channel a owl:Class ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "Channel"@en ;
    rdfs:comment "A way to reach a customer, owned or paid."@en ;
    rdfs:subClassOf schema:Thing, ckg:BusinessContextElement .

ckg:Product a owl:Class ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "Product"@en ;
    rdfs:comment "A menu item with a category and a margin percentage."@en ;
    rdfs:subClassOf schema:Product, ckg:BusinessContextElement .

ckg:Offer a owl:Class ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "Offer"@en ;
    rdfs:comment "A reminder or incentive the brand may extend, with a discount depth and an optional promoted product."@en ;
    rdfs:subClassOf schema:Offer, ckg:BusinessContextElement .

ckg:Campaign a owl:Class ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "Campaign"@en ;
    rdfs:comment "A goal-driven effort such as reactivating lapsed customers, within which decisions are made."@en ;
    rdfs:subClassOf schema:Action, ckg:BusinessContextElement .

ckg:Guardrail a owl:Class ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "Guardrail"@en ;
    rdfs:comment "A rule the agent must respect: a discount cap, a contact-frequency limit, a consent requirement or a human-approval threshold."@en ;
    rdfs:subClassOf schema:Rule, ckg:ControlElement .

ckg:Decision a owl:Class ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "Decision"@en ;
    rdfs:comment "One choice about one customer: act or not, with which offer and channel, in which experiment arm, and why."@en ;
    rdfs:subClassOf schema:Action, ckg:DecisionContextElement .

ckg:ContextItem a owl:Class ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "Context item"@en ;
    rdfs:comment "A single labelled fact an agent read when making a decision, tagged with the kind of context it belongs to."@en ;
    rdfs:subClassOf schema:PropertyValue, ckg:ContextElement .

ckg:Outcome a owl:Class ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "Outcome"@en ;
    rdfs:comment "What happened after a decision: whether the customer ordered and the revenue, margin and costs involved."@en ;
    rdfs:subClassOf schema:Event, ckg:DecisionContextElement .

# ── Properties ─────────────────────────────────────────────────────────────

ckg:channelKind a owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "channel kind"@en ;
    rdfs:comment "Whether a channel is owned (the brand controls it) or paid (media is bought)."@en ;
    rdfs:domain ckg:Channel ;
    rdfs:range xsd:string ;
    skos:closeMatch schema:category .

ckg:category a owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "category"@en ;
    rdfs:comment "Menu category such as meal, bundle, side or dessert."@en ;
    rdfs:domain ckg:Product ;
    rdfs:range xsd:string ;
    skos:closeMatch schema:category .

ckg:marginPct a owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "margin percentage"@en ;
    rdfs:comment "Gross margin of the product, in percent of price."@en ;
    rdfs:domain ckg:Product ;
    rdfs:range xsd:integer .

ckg:lifecycleStage a owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "lifecycle stage"@en ;
    rdfs:comment "Where the customer sits in the relationship: active, lapsing or lapsed."@en ;
    rdfs:domain ckg:Customer ;
    rdfs:range xsd:string .

ckg:loyaltyTier a owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "loyalty tier"@en ;
    rdfs:comment "Loyalty programme tier: bronze, silver or gold."@en ;
    rdfs:domain ckg:Customer ;
    rdfs:range xsd:string ;
    skos:closeMatch schema:memberOf .

ckg:homeCity a owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "home city"@en ;
    rdfs:comment "The city the customer usually orders in. Residence, never birthplace."@en ;
    rdfs:domain ckg:Customer ;
    rdfs:range xsd:string ;
    skos:closeMatch schema:homeLocation .

ckg:usualOrderDay a owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "usual order day"@en ;
    rdfs:comment "The weekday on which the customer usually orders."@en ;
    rdfs:domain ckg:Customer ;
    rdfs:range xsd:string .

ckg:signalKind a owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "signal kind"@en ;
    rdfs:comment "The kind of signal: email, loyalty_id, device, app_session or ad_exposure."@en ;
    rdfs:domain ckg:IdentitySignal ;
    rdfs:range xsd:string ;
    skos:closeMatch schema:additionalType .

ckg:signalValue a owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "signal value"@en ;
    rdfs:comment "A pseudonymous token for the signal, never a raw identifier."@en ;
    rdfs:domain ckg:IdentitySignal ;
    rdfs:range xsd:string ;
    skos:closeMatch schema:value .

ckg:matchMethod a owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "match method"@en ;
    rdfs:comment "How the signal was tied to a customer: deterministic, probabilistic, agentic, or unmatched."@en ;
    rdfs:domain ckg:IdentitySignal ;
    rdfs:range xsd:string .

ckg:confidence a owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "confidence"@en ;
    rdfs:comment "Match confidence in percent; zero for an unmatched signal."@en ;
    rdfs:domain ckg:IdentitySignal ;
    rdfs:range xsd:integer .

ckg:seenDate a owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "seen date"@en ;
    rdfs:comment "The date the signal was last observed."@en ;
    rdfs:domain ckg:IdentitySignal ;
    rdfs:range xsd:date ;
    skos:closeMatch schema:observationDate .

ckg:resolvesTo a owl:ObjectProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "resolves to"@en ;
    rdfs:comment "The customer a signal has been resolved to. Absent for unmatched signals."@en ;
    rdfs:domain ckg:IdentitySignal ;
    rdfs:range ckg:Customer ;
    skos:closeMatch schema:about .

ckg:consentStatus a owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "consent status"@en ;
    rdfs:comment "granted or withdrawn."@en ;
    rdfs:domain ckg:ConsentRecord ;
    rdfs:range xsd:string ;
    skos:closeMatch schema:status .

ckg:updatedDate a owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "updated date"@en ;
    rdfs:comment "The date the consent status last changed."@en ;
    rdfs:domain ckg:ConsentRecord ;
    rdfs:range xsd:date ;
    skos:closeMatch schema:dateModified .

ckg:forChannel a owl:ObjectProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "for channel"@en ;
    rdfs:comment "The channel the consent applies to."@en ;
    rdfs:domain ckg:ConsentRecord ;
    rdfs:range ckg:Channel .

ckg:offerKind a owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "offer kind"@en ;
    rdfs:comment "reminder, incentive or bundle-incentive."@en ;
    rdfs:domain ckg:Offer ;
    rdfs:range xsd:string ;
    skos:closeMatch schema:category .

ckg:discountPct a owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "discount percentage"@en ;
    rdfs:comment "Discount depth in percent of price."@en ;
    rdfs:domain ckg:Offer ;
    rdfs:range xsd:integer ;
    skos:closeMatch schema:discount .

ckg:promotes a owl:ObjectProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "promotes"@en ;
    rdfs:comment "The product an offer promotes, when it promotes one."@en ;
    rdfs:domain ckg:Offer ;
    rdfs:range ckg:Product ;
    skos:closeMatch schema:itemOffered .

ckg:ruleKind a owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "rule kind"@en ;
    rdfs:comment "discount-cap, contact-frequency, consent-required or human-approval."@en ;
    rdfs:domain ckg:Guardrail ;
    rdfs:range xsd:string ;
    skos:closeMatch schema:category .

ckg:limitValue a owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "limit value"@en ;
    rdfs:comment "The threshold the rule enforces."@en ;
    rdfs:domain ckg:Guardrail ;
    rdfs:range xsd:integer ;
    skos:closeMatch schema:value .

ckg:appliesToOffer a owl:ObjectProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "applies to offer"@en ;
    rdfs:comment "Narrows a guardrail to one offer; absent means the rule is global."@en ;
    rdfs:domain ckg:Guardrail ;
    rdfs:range ckg:Offer .

ckg:goal a owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "goal"@en ;
    rdfs:comment "The business outcome the campaign is meant to move."@en ;
    rdfs:domain ckg:Campaign ;
    rdfs:range xsd:string ;
    skos:closeMatch schema:description .

ckg:startDate a owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "start date"@en ;
    rdfs:comment "When the campaign started."@en ;
    rdfs:domain ckg:Campaign ;
    rdfs:range xsd:date ;
    skos:closeMatch schema:startDate .

ckg:arm a owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "experiment arm"@en ;
    rdfs:comment "treatment, or holdout for the randomised group that is deliberately left alone."@en ;
    rdfs:domain ckg:Decision ;
    rdfs:range xsd:string .

ckg:actionKind a owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "action kind"@en ;
    rdfs:comment "send-reminder, send-incentive, switch-channel, suppress or no-action."@en ;
    rdfs:domain ckg:Decision ;
    rdfs:range xsd:string ;
    skos:closeMatch schema:additionalType .

ckg:decidedDate a owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "decided date"@en ;
    rdfs:comment "When the decision was taken."@en ;
    rdfs:domain ckg:Decision ;
    rdfs:range xsd:date ;
    skos:closeMatch schema:startTime .

ckg:rationale a owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "rationale"@en ;
    rdfs:comment "Why the agent chose this action, in words a marketer can audit."@en ;
    rdfs:domain ckg:Decision ;
    rdfs:range xsd:string ;
    skos:closeMatch schema:description .

ckg:approvedByHuman a owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "approved by human"@en ;
    rdfs:comment "1 when a person approved the action, 0 otherwise."@en ;
    rdfs:domain ckg:Decision ;
    rdfs:range xsd:integer .

ckg:groundedIn a owl:ObjectProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "grounded in"@en ;
    rdfs:comment "Super-property of every link from a decision to a thing it was grounded in: its customer, campaign, offer, channel and guardrails."@en ;
    rdfs:domain ckg:Decision ;
    rdfs:range ckg:ContextElement .

ckg:forCustomer a owl:ObjectProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "for customer"@en ;
    rdfs:comment "The customer a decision or consent record concerns."@en ;
    rdfs:domain ckg:ContextElement ;
    rdfs:range ckg:Customer ;
    rdfs:subPropertyOf ckg:groundedIn ;
    skos:closeMatch schema:about .

ckg:inCampaign a owl:ObjectProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "in campaign"@en ;
    rdfs:comment "The campaign a decision belongs to."@en ;
    rdfs:domain ckg:Decision ;
    rdfs:range ckg:Campaign ;
    rdfs:subPropertyOf ckg:groundedIn ;
    skos:closeMatch schema:isPartOf .

ckg:usesOffer a owl:ObjectProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "uses offer"@en ;
    rdfs:comment "The offer a decision extends. Absent for reminders without an offer, suppressions and holdouts."@en ;
    rdfs:domain ckg:Decision ;
    rdfs:range ckg:Offer ;
    rdfs:subPropertyOf ckg:groundedIn ;
    skos:closeMatch schema:object .

ckg:viaChannel a owl:ObjectProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "via channel"@en ;
    rdfs:comment "The channel a decision acts through. Absent for a suppression or a holdout."@en ;
    rdfs:domain ckg:Decision ;
    rdfs:range ckg:Channel ;
    rdfs:subPropertyOf ckg:groundedIn ;
    skos:closeMatch schema:instrument .

ckg:constrainedBy a owl:ObjectProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "constrained by"@en ;
    rdfs:comment "A guardrail that applied to the decision."@en ;
    rdfs:domain ckg:Decision ;
    rdfs:range ckg:Guardrail ;
    rdfs:subPropertyOf ckg:groundedIn .

ckg:contextType a owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "context type"@en ;
    rdfs:comment "customer, business, decision or control: which of the four kinds of context the item is."@en ;
    rdfs:domain ckg:ContextItem ;
    rdfs:range xsd:string ;
    skos:closeMatch schema:additionalType .

ckg:contextKey a owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "context key"@en ;
    rdfs:comment "A short label for the fact."@en ;
    rdfs:domain ckg:ContextItem ;
    rdfs:range xsd:string ;
    skos:closeMatch schema:name .

ckg:contextValue a owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "context value"@en ;
    rdfs:comment "The fact itself."@en ;
    rdfs:domain ckg:ContextItem ;
    rdfs:range xsd:string ;
    skos:closeMatch schema:value .

ckg:informs a owl:ObjectProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "informs"@en ;
    rdfs:comment "The decision the item was read for."@en ;
    rdfs:domain ckg:ContextItem ;
    rdfs:range ckg:Decision .

ckg:ordered a owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "ordered"@en ;
    rdfs:comment "1 when the customer ordered inside the measurement window, 0 otherwise."@en ;
    rdfs:domain ckg:Outcome ;
    rdfs:range xsd:integer .

ckg:revenueUsd a owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "revenue (USD)"@en ;
    rdfs:comment "Revenue from the order, in whole US dollars."@en ;
    rdfs:domain ckg:Outcome ;
    rdfs:range xsd:integer ;
    skos:closeMatch schema:price .

ckg:marginUsd a owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "margin (USD)"@en ;
    rdfs:comment "Gross margin on the order before discount and media costs."@en ;
    rdfs:domain ckg:Outcome ;
    rdfs:range xsd:integer .

ckg:mediaCostUsd a owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "media cost (USD)"@en ;
    rdfs:comment "Paid-media cost attributed to the decision."@en ;
    rdfs:domain ckg:Outcome ;
    rdfs:range xsd:integer .

ckg:discountCostUsd a owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "discount cost (USD)"@en ;
    rdfs:comment "Discount given on the order."@en ;
    rdfs:domain ckg:Outcome ;
    rdfs:range xsd:integer .

ckg:repeatVisit30d a owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "repeat visit within 30 days"@en ;
    rdfs:comment "1 when the customer returned within 30 days of the order."@en ;
    rdfs:domain ckg:Outcome ;
    rdfs:range xsd:integer .

ckg:windowEnd a owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "window end"@en ;
    rdfs:comment "The last day of the measurement window."@en ;
    rdfs:domain ckg:Outcome ;
    rdfs:range xsd:date ;
    skos:closeMatch schema:endTime .

ckg:ofDecision a owl:ObjectProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/> ;
    rdfs:label "of decision"@en ;
    rdfs:comment "The decision whose result this is."@en ;
    rdfs:domain ckg:Outcome ;
    rdfs:range ckg:Decision .

One statement maps all twelve tables to 1,160 triples at query time in the named graph http://demo.openlinksw.com/CustomerKG#. Every table in the FROM list is aliased, five nullable foreign keys carry an IS NOT NULL guard, and the link table maps the constrainedBy predicate.

SPARQL
ALTER QUAD STORAGE virtrdf:DefaultQuadStorage
  FROM CustomerKG.kidehen.channel AS ch
  FROM CustomerKG.kidehen.product AS pr
  FROM CustomerKG.kidehen.customer AS cu
  FROM CustomerKG.kidehen.identity_signal AS sg
  FROM CustomerKG.kidehen.consent AS co
  FROM CustomerKG.kidehen.offer AS ofr
  FROM CustomerKG.kidehen.guardrail AS gr
  FROM CustomerKG.kidehen.campaign AS ca
  FROM CustomerKG.kidehen.decision AS de
  FROM CustomerKG.kidehen.decision_guardrail AS dg
  FROM CustomerKG.kidehen.context_item AS ci
  FROM CustomerKG.kidehen.outcome AS ou
{
  GRAPH <http://demo.openlinksw.com/CustomerKG#>
  {
    <http://demo.openlinksw.com/schemas/CustomerKG/channel_iri>(ch.channel_id) <http://www.w3.org/1999/02/22-rdf-syntax-ns#type> <http://demo.openlinksw.com/schemas/CustomerKG/Channel> as virtrdf:CustomerKG-channel-type .
    <http://demo.openlinksw.com/schemas/CustomerKG/channel_iri>(ch.channel_id) <http://schema.org/name> ch.channel_name as virtrdf:CustomerKG-channel-name .
    <http://demo.openlinksw.com/schemas/CustomerKG/channel_iri>(ch.channel_id) <http://demo.openlinksw.com/schemas/CustomerKG/channelKind> ch.channel_kind as virtrdf:CustomerKG-channel-kind .
    <http://demo.openlinksw.com/schemas/CustomerKG/product_iri>(pr.product_id) <http://www.w3.org/1999/02/22-rdf-syntax-ns#type> <http://demo.openlinksw.com/schemas/CustomerKG/Product> as virtrdf:CustomerKG-product-type .
    <http://demo.openlinksw.com/schemas/CustomerKG/product_iri>(pr.product_id) <http://schema.org/name> pr.product_name as virtrdf:CustomerKG-product-name .
    <http://demo.openlinksw.com/schemas/CustomerKG/product_iri>(pr.product_id) <http://demo.openlinksw.com/schemas/CustomerKG/category> pr.category as virtrdf:CustomerKG-product-category .
    <http://demo.openlinksw.com/schemas/CustomerKG/product_iri>(pr.product_id) <http://demo.openlinksw.com/schemas/CustomerKG/marginPct> pr.margin_pct as virtrdf:CustomerKG-product-margin .
    <http://demo.openlinksw.com/schemas/CustomerKG/customer_iri>(cu.customer_id) <http://www.w3.org/1999/02/22-rdf-syntax-ns#type> <http://demo.openlinksw.com/schemas/CustomerKG/Customer> as virtrdf:CustomerKG-customer-type .
    <http://demo.openlinksw.com/schemas/CustomerKG/customer_iri>(cu.customer_id) <http://schema.org/name> cu.full_name as virtrdf:CustomerKG-customer-name .
    <http://demo.openlinksw.com/schemas/CustomerKG/customer_iri>(cu.customer_id) <http://demo.openlinksw.com/schemas/CustomerKG/lifecycleStage> cu.lifecycle_stage as virtrdf:CustomerKG-customer-lifecycle .
    <http://demo.openlinksw.com/schemas/CustomerKG/customer_iri>(cu.customer_id) <http://demo.openlinksw.com/schemas/CustomerKG/loyaltyTier> cu.loyalty_tier as virtrdf:CustomerKG-customer-tier .
    <http://demo.openlinksw.com/schemas/CustomerKG/customer_iri>(cu.customer_id) <http://demo.openlinksw.com/schemas/CustomerKG/homeCity> cu.home_city as virtrdf:CustomerKG-customer-city .
    <http://demo.openlinksw.com/schemas/CustomerKG/customer_iri>(cu.customer_id) <http://demo.openlinksw.com/schemas/CustomerKG/usualOrderDay> cu.usual_order_day as virtrdf:CustomerKG-customer-day .
    <http://demo.openlinksw.com/schemas/CustomerKG/signal_iri>(sg.signal_id) <http://www.w3.org/1999/02/22-rdf-syntax-ns#type> <http://demo.openlinksw.com/schemas/CustomerKG/IdentitySignal> as virtrdf:CustomerKG-signal-type .
    <http://demo.openlinksw.com/schemas/CustomerKG/signal_iri>(sg.signal_id) <http://demo.openlinksw.com/schemas/CustomerKG/signalKind> sg.signal_kind as virtrdf:CustomerKG-signal-kind .
    <http://demo.openlinksw.com/schemas/CustomerKG/signal_iri>(sg.signal_id) <http://demo.openlinksw.com/schemas/CustomerKG/signalValue> sg.signal_value as virtrdf:CustomerKG-signal-value .
    <http://demo.openlinksw.com/schemas/CustomerKG/signal_iri>(sg.signal_id) <http://demo.openlinksw.com/schemas/CustomerKG/matchMethod> sg.match_method as virtrdf:CustomerKG-signal-method .
    <http://demo.openlinksw.com/schemas/CustomerKG/signal_iri>(sg.signal_id) <http://demo.openlinksw.com/schemas/CustomerKG/confidence> sg.confidence as virtrdf:CustomerKG-signal-confidence .
    <http://demo.openlinksw.com/schemas/CustomerKG/signal_iri>(sg.signal_id) <http://demo.openlinksw.com/schemas/CustomerKG/seenDate> sg.seen_date as virtrdf:CustomerKG-signal-seen .
    <http://demo.openlinksw.com/schemas/CustomerKG/signal_iri>(sg.signal_id) <http://demo.openlinksw.com/schemas/CustomerKG/resolvesTo> <http://demo.openlinksw.com/schemas/CustomerKG/customer_iri>(sg.customer_id) where (^{sg.}^.customer_id is not null) as virtrdf:CustomerKG-signal-customer .
    <http://demo.openlinksw.com/schemas/CustomerKG/consent_iri>(co.consent_id) <http://www.w3.org/1999/02/22-rdf-syntax-ns#type> <http://demo.openlinksw.com/schemas/CustomerKG/ConsentRecord> as virtrdf:CustomerKG-consent-type .
    <http://demo.openlinksw.com/schemas/CustomerKG/consent_iri>(co.consent_id) <http://demo.openlinksw.com/schemas/CustomerKG/consentStatus> co.status as virtrdf:CustomerKG-consent-status .
    <http://demo.openlinksw.com/schemas/CustomerKG/consent_iri>(co.consent_id) <http://demo.openlinksw.com/schemas/CustomerKG/updatedDate> co.updated_date as virtrdf:CustomerKG-consent-updated .
    <http://demo.openlinksw.com/schemas/CustomerKG/consent_iri>(co.consent_id) <http://demo.openlinksw.com/schemas/CustomerKG/forCustomer> <http://demo.openlinksw.com/schemas/CustomerKG/customer_iri>(co.customer_id) as virtrdf:CustomerKG-consent-customer .
    <http://demo.openlinksw.com/schemas/CustomerKG/consent_iri>(co.consent_id) <http://demo.openlinksw.com/schemas/CustomerKG/forChannel> <http://demo.openlinksw.com/schemas/CustomerKG/channel_iri>(co.channel_id) as virtrdf:CustomerKG-consent-channel .
    <http://demo.openlinksw.com/schemas/CustomerKG/offer_iri>(ofr.offer_id) <http://www.w3.org/1999/02/22-rdf-syntax-ns#type> <http://demo.openlinksw.com/schemas/CustomerKG/Offer> as virtrdf:CustomerKG-offer-type .
    <http://demo.openlinksw.com/schemas/CustomerKG/offer_iri>(ofr.offer_id) <http://schema.org/name> ofr.offer_name as virtrdf:CustomerKG-offer-name .
    <http://demo.openlinksw.com/schemas/CustomerKG/offer_iri>(ofr.offer_id) <http://demo.openlinksw.com/schemas/CustomerKG/offerKind> ofr.offer_kind as virtrdf:CustomerKG-offer-kind .
    <http://demo.openlinksw.com/schemas/CustomerKG/offer_iri>(ofr.offer_id) <http://demo.openlinksw.com/schemas/CustomerKG/discountPct> ofr.discount_pct as virtrdf:CustomerKG-offer-discount .
    <http://demo.openlinksw.com/schemas/CustomerKG/offer_iri>(ofr.offer_id) <http://demo.openlinksw.com/schemas/CustomerKG/promotes> <http://demo.openlinksw.com/schemas/CustomerKG/product_iri>(ofr.product_id) where (^{ofr.}^.product_id is not null) as virtrdf:CustomerKG-offer-product .
    <http://demo.openlinksw.com/schemas/CustomerKG/guardrail_iri>(gr.guardrail_id) <http://www.w3.org/1999/02/22-rdf-syntax-ns#type> <http://demo.openlinksw.com/schemas/CustomerKG/Guardrail> as virtrdf:CustomerKG-guardrail-type .
    <http://demo.openlinksw.com/schemas/CustomerKG/guardrail_iri>(gr.guardrail_id) <http://schema.org/name> gr.rule_name as virtrdf:CustomerKG-guardrail-name .
    <http://demo.openlinksw.com/schemas/CustomerKG/guardrail_iri>(gr.guardrail_id) <http://demo.openlinksw.com/schemas/CustomerKG/ruleKind> gr.rule_kind as virtrdf:CustomerKG-guardrail-kind .
    <http://demo.openlinksw.com/schemas/CustomerKG/guardrail_iri>(gr.guardrail_id) <http://demo.openlinksw.com/schemas/CustomerKG/limitValue> gr.limit_value as virtrdf:CustomerKG-guardrail-limit .
    <http://demo.openlinksw.com/schemas/CustomerKG/guardrail_iri>(gr.guardrail_id) <http://demo.openlinksw.com/schemas/CustomerKG/appliesToOffer> <http://demo.openlinksw.com/schemas/CustomerKG/offer_iri>(gr.offer_id) where (^{gr.}^.offer_id is not null) as virtrdf:CustomerKG-guardrail-offer .
    <http://demo.openlinksw.com/schemas/CustomerKG/campaign_iri>(ca.campaign_id) <http://www.w3.org/1999/02/22-rdf-syntax-ns#type> <http://demo.openlinksw.com/schemas/CustomerKG/Campaign> as virtrdf:CustomerKG-campaign-type .
    <http://demo.openlinksw.com/schemas/CustomerKG/campaign_iri>(ca.campaign_id) <http://schema.org/name> ca.campaign_name as virtrdf:CustomerKG-campaign-name .
    <http://demo.openlinksw.com/schemas/CustomerKG/campaign_iri>(ca.campaign_id) <http://demo.openlinksw.com/schemas/CustomerKG/goal> ca.goal as virtrdf:CustomerKG-campaign-goal .
    <http://demo.openlinksw.com/schemas/CustomerKG/campaign_iri>(ca.campaign_id) <http://demo.openlinksw.com/schemas/CustomerKG/startDate> ca.start_date as virtrdf:CustomerKG-campaign-start .
    <http://demo.openlinksw.com/schemas/CustomerKG/decision_iri>(de.decision_id) <http://www.w3.org/1999/02/22-rdf-syntax-ns#type> <http://demo.openlinksw.com/schemas/CustomerKG/Decision> as virtrdf:CustomerKG-decision-type .
    <http://demo.openlinksw.com/schemas/CustomerKG/decision_iri>(de.decision_id) <http://demo.openlinksw.com/schemas/CustomerKG/arm> de.arm as virtrdf:CustomerKG-decision-arm .
    <http://demo.openlinksw.com/schemas/CustomerKG/decision_iri>(de.decision_id) <http://demo.openlinksw.com/schemas/CustomerKG/actionKind> de.action_kind as virtrdf:CustomerKG-decision-action .
    <http://demo.openlinksw.com/schemas/CustomerKG/decision_iri>(de.decision_id) <http://demo.openlinksw.com/schemas/CustomerKG/decidedDate> de.decided_date as virtrdf:CustomerKG-decision-date .
    <http://demo.openlinksw.com/schemas/CustomerKG/decision_iri>(de.decision_id) <http://demo.openlinksw.com/schemas/CustomerKG/rationale> de.rationale as virtrdf:CustomerKG-decision-rationale .
    <http://demo.openlinksw.com/schemas/CustomerKG/decision_iri>(de.decision_id) <http://demo.openlinksw.com/schemas/CustomerKG/approvedByHuman> de.approved_by_human as virtrdf:CustomerKG-decision-approved .
    <http://demo.openlinksw.com/schemas/CustomerKG/decision_iri>(de.decision_id) <http://demo.openlinksw.com/schemas/CustomerKG/forCustomer> <http://demo.openlinksw.com/schemas/CustomerKG/customer_iri>(de.customer_id) as virtrdf:CustomerKG-decision-customer .
    <http://demo.openlinksw.com/schemas/CustomerKG/decision_iri>(de.decision_id) <http://demo.openlinksw.com/schemas/CustomerKG/inCampaign> <http://demo.openlinksw.com/schemas/CustomerKG/campaign_iri>(de.campaign_id) as virtrdf:CustomerKG-decision-campaign .
    <http://demo.openlinksw.com/schemas/CustomerKG/decision_iri>(de.decision_id) <http://demo.openlinksw.com/schemas/CustomerKG/usesOffer> <http://demo.openlinksw.com/schemas/CustomerKG/offer_iri>(de.offer_id) where (^{de.}^.offer_id is not null) as virtrdf:CustomerKG-decision-offer .
    <http://demo.openlinksw.com/schemas/CustomerKG/decision_iri>(de.decision_id) <http://demo.openlinksw.com/schemas/CustomerKG/viaChannel> <http://demo.openlinksw.com/schemas/CustomerKG/channel_iri>(de.channel_id) where (^{de.}^.channel_id is not null) as virtrdf:CustomerKG-decision-channel .
    <http://demo.openlinksw.com/schemas/CustomerKG/decision_iri>(dg.decision_id) <http://demo.openlinksw.com/schemas/CustomerKG/constrainedBy> <http://demo.openlinksw.com/schemas/CustomerKG/guardrail_iri>(dg.guardrail_id) as virtrdf:CustomerKG-decision-guardrail .
    <http://demo.openlinksw.com/schemas/CustomerKG/context_iri>(ci.item_id) <http://www.w3.org/1999/02/22-rdf-syntax-ns#type> <http://demo.openlinksw.com/schemas/CustomerKG/ContextItem> as virtrdf:CustomerKG-context-type .
    <http://demo.openlinksw.com/schemas/CustomerKG/context_iri>(ci.item_id) <http://demo.openlinksw.com/schemas/CustomerKG/contextType> ci.context_type as virtrdf:CustomerKG-context-kind .
    <http://demo.openlinksw.com/schemas/CustomerKG/context_iri>(ci.item_id) <http://demo.openlinksw.com/schemas/CustomerKG/contextKey> ci.context_key as virtrdf:CustomerKG-context-key .
    <http://demo.openlinksw.com/schemas/CustomerKG/context_iri>(ci.item_id) <http://demo.openlinksw.com/schemas/CustomerKG/contextValue> ci.context_value as virtrdf:CustomerKG-context-value .
    <http://demo.openlinksw.com/schemas/CustomerKG/context_iri>(ci.item_id) <http://demo.openlinksw.com/schemas/CustomerKG/informs> <http://demo.openlinksw.com/schemas/CustomerKG/decision_iri>(ci.decision_id) as virtrdf:CustomerKG-context-decision .
    <http://demo.openlinksw.com/schemas/CustomerKG/outcome_iri>(ou.outcome_id) <http://www.w3.org/1999/02/22-rdf-syntax-ns#type> <http://demo.openlinksw.com/schemas/CustomerKG/Outcome> as virtrdf:CustomerKG-outcome-type .
    <http://demo.openlinksw.com/schemas/CustomerKG/outcome_iri>(ou.outcome_id) <http://demo.openlinksw.com/schemas/CustomerKG/ordered> ou.ordered as virtrdf:CustomerKG-outcome-ordered .
    <http://demo.openlinksw.com/schemas/CustomerKG/outcome_iri>(ou.outcome_id) <http://demo.openlinksw.com/schemas/CustomerKG/revenueUsd> ou.revenue_usd as virtrdf:CustomerKG-outcome-revenue .
    <http://demo.openlinksw.com/schemas/CustomerKG/outcome_iri>(ou.outcome_id) <http://demo.openlinksw.com/schemas/CustomerKG/marginUsd> ou.margin_usd as virtrdf:CustomerKG-outcome-margin .
    <http://demo.openlinksw.com/schemas/CustomerKG/outcome_iri>(ou.outcome_id) <http://demo.openlinksw.com/schemas/CustomerKG/mediaCostUsd> ou.media_cost_usd as virtrdf:CustomerKG-outcome-media .
    <http://demo.openlinksw.com/schemas/CustomerKG/outcome_iri>(ou.outcome_id) <http://demo.openlinksw.com/schemas/CustomerKG/discountCostUsd> ou.discount_cost_usd as virtrdf:CustomerKG-outcome-discount .
    <http://demo.openlinksw.com/schemas/CustomerKG/outcome_iri>(ou.outcome_id) <http://demo.openlinksw.com/schemas/CustomerKG/repeatVisit30d> ou.repeat_visit_30d as virtrdf:CustomerKG-outcome-repeat .
    <http://demo.openlinksw.com/schemas/CustomerKG/outcome_iri>(ou.outcome_id) <http://demo.openlinksw.com/schemas/CustomerKG/windowEnd> ou.window_end as virtrdf:CustomerKG-outcome-window .
    <http://demo.openlinksw.com/schemas/CustomerKG/outcome_iri>(ou.outcome_id) <http://demo.openlinksw.com/schemas/CustomerKG/ofDecision> <http://demo.openlinksw.com/schemas/CustomerKG/decision_iri>(ou.decision_id) as virtrdf:CustomerKG-outcome-decision .
  }
} ;

A small physical graph for identity reconciliation. A vocabulary declares ckg:emailHash an owl:InverseFunctionalProperty, a rule set is built from it, customer facts are derived from the live view with SPARQL INSERT ... WHERE, and records from other systems are added: two that share a customer's email hash, one linked by an explicit owl:sameAs, and one that matches nobody. It is separate from the view because owl:sameAs merging works over physical graphs. Query 3 reads it.

-- 1. Vocabulary: declare the identifying property inverse functional, in its own graph
DB.DBA.TTLP(file_to_string_output('customerkg-identity-vocabulary-claude_sonnet_5_5-1.ttl'), '', 'http://demo.openlinksw.com/schemas/CustomerKG/identity/');
-- The Turtle loaded by that call:
@prefix ckg: <http://demo.openlinksw.com/schemas/CustomerKG/> .
@prefix owl: <http://www.w3.org/2002/07/owl#> .
@prefix rdfs: <http://www.w3.org/2000/01/rdf-schema#> .
@prefix schema: <http://schema.org/> .
@prefix xsd: <http://www.w3.org/2001/XMLSchema#> .

<http://demo.openlinksw.com/schemas/CustomerKG/identity/> a owl:Ontology ;
    rdfs:label "CustomerKG identity reconciliation vocabulary"@en .

ckg:emailHash a owl:InverseFunctionalProperty, owl:DatatypeProperty ;
    rdfs:isDefinedBy <http://demo.openlinksw.com/schemas/CustomerKG/identity/> ;
    rdfs:label "email hash"@en ;
    rdfs:comment "A pseudonymous hash of an email address. Two records that carry the same hash describe the same person, so the property is declared inverse functional and a reasoner derives owl:sameAs between them."@en ;
    rdfs:domain schema:Person ;
    rdfs:range xsd:string .

-- 2. Rule set: derive reasoning rules from that vocabulary
DB.DBA.rdfs_rule_set('urn:customerkg:identity-inference', 'http://demo.openlinksw.com/schemas/CustomerKG/identity/');

-- 3. Identity graph, part one: facts derived from the live RDF View (nothing is retyped)
SPARQL PREFIX ckg: <http://demo.openlinksw.com/schemas/CustomerKG/> PREFIX schema: <http://schema.org/>
INSERT INTO GRAPH <http://demo.openlinksw.com/CustomerKG/identity#> { ?c ckg:emailHash ?v }
WHERE { GRAPH <http://demo.openlinksw.com/CustomerKG#> { ?s a ckg:IdentitySignal ; ckg:signalKind "email" ; ckg:signalValue ?v ; ckg:resolvesTo ?c } };

SPARQL PREFIX ckg: <http://demo.openlinksw.com/schemas/CustomerKG/> PREFIX schema: <http://schema.org/>
INSERT INTO GRAPH <http://demo.openlinksw.com/CustomerKG/identity#> { ?c a schema:Person ; schema:name ?n }
WHERE { GRAPH <http://demo.openlinksw.com/CustomerKG#> { ?c a ckg:Customer ; schema:name ?n } };

-- 4. Identity graph, part two: records from other systems, one explicit owl:sameAs, one record that matches nobody
SPARQL PREFIX ckg: <http://demo.openlinksw.com/schemas/CustomerKG/> PREFIX schema: <http://schema.org/> PREFIX owl: <http://www.w3.org/2002/07/owl#>
INSERT DATA INTO GRAPH <http://demo.openlinksw.com/CustomerKG/identity#> {
  <http://demo.openlinksw.com/CustomerKG/external/crm/501#this> a schema:Person ; schema:name "A. Quinn (CRM export)" ; ckg:emailHash "hem:a1f3" .
  <http://demo.openlinksw.com/CustomerKG/external/app/77#this> a schema:Person ; schema:name "Avery Q. (app profile)" ; ckg:emailHash "hem:a1f3" .
  <http://demo.openlinksw.com/CustomerKG/external/crm/502#this> a schema:Person ; schema:name "B. Moreno (CRM export)" ; ckg:emailHash "hem:b2c4" .
  <http://demo.openlinksw.com/CustomerKG/external/crm/599#this> a schema:Person ; schema:name "Unmatched (CRM export)" ; ckg:emailHash "hem:ffff" .
  <http://demo.openlinksw.com/CustomerKG/external/loyalty/LY-10001#this> a schema:Person ; schema:name "Loyalty member LY-10001" ; owl:sameAs <http://demo.openlinksw.com/CustomerKG/customer/1#this> .
};

The RDF View defines the IRIs but does not by itself make them resolve. The generator RDFVIEW_GENERATE_DATA_RULES was called with iri_path_segment CustomerKG and include_ontology_rules 1 and returned these fourteen statements: six regular-expression rules, two rule lists and two virtual directories, /CustomerKG and /schemas/CustomerKG. After they ran, an entity IRI answers with a 303 to a describe page.

DB.DBA.URLREWRITE_CREATE_REGEX_RULE (
'customerkg_rule2',
1,
'(/[^#]*)',
vector('path'),
1,
'/sparql?query=DESCRIBE+%%3Chttp%%3A//^{URIQADefaultHost}^%U%%23this%%3E+FROM+%%3Chttp%%3A//^{URIQADefaultHost}^/CustomerKG%%23%%3E&format=%U',
vector('path', '*accept*'),
null,
'(text/rdf.n3)|(application/rdf.xml)|(text/n3)|(application/json)|(text/turtle)',
2,
null
);
DB.DBA.URLREWRITE_CREATE_REGEX_RULE (
'customerkg_rule4',
1,
'/CustomerKG/stat([^#]*)',
vector('path'),
1,
'/sparql?query=DESCRIBE+%%3Chttp%%3A//^{URIQADefaultHost}^/CustomerKG/stat%%23%%3E+%%3Fo+FROM+%%3Chttp%%3A//^{URIQADefaultHost}^/CustomerKG%%23%%3E+WHERE+{+%%3Chttp%%3A//^{URIQADefaultHost}^/CustomerKG/stat%%23%%3E+%%3Fp+%%3Fo+}&format=%U',
vector('*accept*'),
null,
'(text/rdf.n3)|(application/rdf.xml)|(text/n3)|(application/json)|(text/turtle)',
2,
null
);
DB.DBA.URLREWRITE_CREATE_REGEX_RULE (
'customerkg_rule6',
1,
'/CustomerKG/objects/([^#]*)',
vector('path'),
1,
'/sparql?query=DESCRIBE+%%3Chttp%%3A//^{URIQADefaultHost}^/CustomerKG/objects/%U%%3E+FROM+%%3Chttp%%3A//^{URIQADefaultHost}^/CustomerKG%%23%%3E&format=%U',
vector('path', '*accept*'),
null,
'(text/rdf.n3)|(application/rdf.xml)|(text/n3)|(application/json)|(text/turtle)',
2,
null
);
DB.DBA.URLREWRITE_CREATE_REGEX_RULE (
'customerkg_rule1',
1,
'([^#]*)',
vector('path'),
1,
'/describe/?url=http%%3A//^{URIQADefaultHost}^%U%%23this&graph=http%%3A//^{URIQADefaultHost}^/CustomerKG%%23&distinct=0',
vector('path'),
null,
null,
2,
303
);
DB.DBA.URLREWRITE_CREATE_REGEX_RULE (
'customerkg_rule7',
1,
'/CustomerKG/stat([^#]*)',
vector('path'),
1,
'/describe/?url=http%%3A//^{URIQADefaultHost}^/CustomerKG/stat%%23&graph=http%%3A//^{URIQADefaultHost}^/CustomerKG%%23',
vector('path'),
null,
null,
2,
303
);
DB.DBA.URLREWRITE_CREATE_REGEX_RULE (
'customerkg_rule5',
1,
'/CustomerKG/objects/(.*)',
vector('path'),
1,
'/services/rdf/object.binary?path=%%2FCustomerKG%%2Fobjects%%2F%U&accept=%U',
vector('path', '*accept*'),
null,
null,
2,
null
);
DB.DBA.URLREWRITE_CREATE_RULELIST ( 'customerkg_rule_list1', 1, vector ( 'customerkg_rule1', 'customerkg_rule7', 'customerkg_rule5', 'customerkg_rule2', 'customerkg_rule4', 'customerkg_rule6'));
DB.DBA.VHOST_REMOVE (lpath=>'/CustomerKG');
DB.DBA.VHOST_DEFINE (lpath=>'/CustomerKG', ppath=>'/', vsp_user=>'dba', is_dav=>0,
is_brws=>0, opts=>vector ('url_rewrite', 'customerkg_rule_list1')
);
DB.DBA.URLREWRITE_CREATE_REGEX_RULE (
'customerkg_owl_rule2',
1,
'(/[^#]*)',
vector('path'),
1,
'/sparql?query=DESCRIBE+%%3Chttp%%3A//^{URIQADefaultHost}^%U%%3E+FROM+%%3Chttp%%3A//^{URIQADefaultHost}^/schemas/CustomerKG%%23%%3E&format=%U',
vector('path', '*accept*'),
null,
'(text/rdf.n3)|(application/rdf.xml)|(text/n3)|(application/json)|(text/turtle)',
2,
null
);
DB.DBA.URLREWRITE_CREATE_REGEX_RULE (
'customerkg_owl_rule1',
1,
'([^#]*)',
vector('path'),
1,
'/describe/?url=http://^{URIQADefaultHost}^%U',
vector('path'),
null,
null,
2,
303
);
DB.DBA.URLREWRITE_CREATE_RULELIST ( 'customerkg_owl_rule_list1', 1, vector ( 'customerkg_owl_rule1', 'customerkg_owl_rule2'));
DB.DBA.VHOST_REMOVE (lpath=>'/schemas/CustomerKG');
DB.DBA.VHOST_DEFINE (lpath=>'/schemas/CustomerKG', ppath=>'/', vsp_user=>'dba', is_dav=>0,
is_brws=>0, opts=>vector ('url_rewrite', 'customerkg_owl_rule_list1')
);