CREATE SINK adib_rm.sdk_activity_enriched_sink AS
SELECT
client_id,
activity_id,
activity_kind,
activity_date,
transaction_type_id,
transaction_type,
activity_type_name_en,
activity_type_name_ar,
account_id,
portfolio_id,
asset_id,
asset_name_en,
asset_name_ar,
asset_type,
asset_currency_code,
asset_ticker,
asset_isin,
issuer_name_en,
issuer_name_ar,
order_asset_id,
order_asset_name_en,
order_asset_name_ar,
order_asset_type,
order_asset_currency_code,
order_asset_ticker,
order_asset_isin,
trade_order_side_label_id,
trade_order_side_name_en,
trade_order_side_name_ar,
currency_code,
gross_value,
net_value,
quantity,
order_side,
order_status,
filled_quantity,
average_price,
gross_executed_amount,
total_fee,
estimated_gross_amount,
estimated_net_amount,
estimated_fee_amount,
order_id,
event_at,
transaction_source,
portfolio_ids
FROM adib_rm.sdk_activity_enriched_mv
WITH (
connector='postgres',
host='psql-nonprod-uae-derived.postgres.database.azure.com',
port='6432',
user='migration_user',
password='***',
database='adib-int-investor-adib-bff',
schema='investor_adib_bff',
table='sdk_activity_enriched',
type='upsert',
force_compaction='true',
primary_key='client_id,activity_id'
)