DROP TABLE IF EXISTS orders_stream;
DROP TABLE IF EXISTS customers;
CREATE TABLE customers (
customer_id TEXT PRIMARY KEY,
tier TEXT NOT NULL,
discount_pct INT NOT NULL
);
CREATE TABLE orders_stream (
order_id UUID PRIMARY KEY,
payload JSONB NOT NULL
);
INSERT INTO customers VALUES
('CUST-101', 'PLATINUM', 15),
('CUST-102', 'GOLD', 10),
('CUST-103', 'SILVER', 5);
INSERT INTO orders_stream VALUES
('11111111-1111-1111-1111-111111111111',
'{"customer_id": "CUST-101", "total": 250.00, "items": 5}'::jsonb),
('22222222-2222-2222-2222-222222222222',
'{"customer_id": "CUST-102", "total": 125.00, "items": 2}'::jsonb),
('33333333-3333-3333-3333-333333333333',
'{"customer_id": "CUST-103", "total": 75.00, "items": 1}'::jsonb);