CREATE SINK alinma_bff.portfolios_sink AS
SELECT
portfolio_id,
number,
base_currency_code,
service_type_id,
service_type,
opening_date,
closing_date,
created_at,
account_group_type,
status_label_id,
status_name_en,
status_name_ar,
status_color,
currency_code,
currency_name_en,
currency_name_ar,
currency_symbol,
owners,
owner_count,
task_active_count,
task_high_priority_count,
market_value,
fair_value,
market_value_system_currency,
fair_value_system_currency,
reference_identifiers
FROM alinma_bff.book_of_business_portfolios_mv AS book_of_business_portfolios_mv_next
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='portfolios',
schema='advisor_portal_bff',
type='upsert',
force_compaction='true',
primary_key='portfolio_id,account_group_type'
)