CREATE SINK alinma_bff.clients_sink AS
SELECT
client_id,
client_type,
base_currency_code,
created_at,
onboarding_date,
next_kyc_review_date,
account_group_type,
display_name,
local_display_name,
preferred_name,
prefix,
suffix,
first_name,
last_name,
customer_identification_file,
segment_label_id,
segment_name_en,
segment_name_ar,
segment_color,
status_label_id,
status_name_en,
status_name_ar,
status_color,
currency_code,
currency_name_en,
currency_name_ar,
currency_symbol,
portfolio_count,
contact_count,
task_active_count,
task_high_priority_count,
market_value,
fair_value,
relationship_value,
fair_relationship_value,
market_value_system_currency,
fair_value_system_currency,
relationship_value_system_currency,
fair_relationship_value_system_currency,
aum_value,
fair_aum_value,
aum_value_system_currency,
fair_aum_value_system_currency,
total_fees,
transactional_fees,
non_transactional_fees,
total_fees_system_currency,
transactional_fees_system_currency,
non_transactional_fees_system_currency,
reference_identifiers
FROM alinma_bff.book_of_business_clients_mv AS book_of_business_clients_mv_next
WITH (
connector='postgres',
host='psql-nonprod-uae-derived.postgres.database.azure.com',
port='6432',
user='migration_user',
password='***',
database='alinma-qa-advisor-portal-bff',
table='clients',
schema='advisor_portal_bff',
type='upsert',
force_compaction='true',
primary_key='client_id,account_group_type'
)