CREATE SINK alinma_bff.accounts_sink AS
SELECT
account_id,
account_name,
account_number,
account_type,
base_currency_code,
opening_date,
created_at,
is_restricted,
product_id,
product_type,
product_name_en,
product_name_ar,
status_label_id,
status_name_en,
status_name_ar,
status_color,
system_status,
currency_code,
currency_name_en,
currency_name_ar,
currency_symbol,
owners,
owner_count,
portfolios,
portfolio_count,
task_active_count,
task_high_priority_count,
CAST(0 AS INT) AS task_overdue_count,
market_value,
fair_value,
market_value_system_currency,
fair_value_system_currency,
available_balance,
hold_balance,
purchasing_power,
profit_rate,
profit_accrued,
principal,
maturity_date,
auto_renewal_status,
credit_limit,
last_statement_balance,
minimum_payment_due,
payment_due_date,
last_4_digits,
financing_limit,
outstanding_balance,
reference_identifiers
FROM alinma_bff.book_of_business_accounts_mv AS book_of_business_accounts_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='accounts',
schema='advisor_portal_bff',
type='upsert',
force_compaction='true',
primary_key='account_id'
)