CREATE SINK alinma_bff.notes_sink AS
SELECT
id,
content_text,
content_format,
created_at,
updated_at,
is_archived,
archived_at,
client_id,
portfolio_id,
account_id,
draft_account_id,
party_id,
entity_type,
entity_id,
tag_ids,
created_by_id,
updated_by_id,
client_display_name,
client_local_display_name,
client_preferred_name,
client_customer_identification_file,
portfolio_number,
portfolio_owners,
account_name,
account_number,
account_owners
FROM alinma_bff.notes_mv
WITH (
connector='postgres',
host='psql-nonprod-uae-derived.postgres.database.azure.com',
port='6432',
user='migration_user',
password='***',
database='alinma-int-advisor-portal-bff',
table='notes',
schema='advisor_portal_bff',
type='upsert',
force_compaction='true',
primary_key='id'
)