CREATE SINK adib_rm.holding_breaks_sink AS
SELECT
break_id,
source_system,
business_date,
break_type,
severity,
status,
account_id,
asset_id,
order_id,
file_id,
row_ordinal,
expected,
actual,
detected_at,
resolved_at,
resolution_note,
resolved_by
FROM adib_rm.holding_breaks_mv
WITH (
connector='postgres',
host='psql-nonprod-uae-derived.postgres.database.azure.com',
port='6432',
user='migration_user',
password='***',
database='adib-qa-investor-adib-bff',
schema='admin_portal_bff',
table='holding_breaks',
type='upsert',
force_compaction='true',
primary_key='break_id'
)