create table .trades_summary ( accountid numeric(10), tradeid numeric(20) not null constraint pk_tradeid primary key, time timestamp with time zone not null, tradeamount numeric(20, 8), isbuy numeric(1), tradableinstrumentid numeric(20), instrumentname text, lotsize numeric(38, 8), tradeprice numeric(20, 8), positionid numeric(20), positionamount numeric(20, 8), opentradeid numeric(20), opentradetime timestamp with time zone, openfilledprice numeric(20, 8), openfilledamount numeric(20, 8), openfee numeric(20, 8), openstrategyid text, openorderid numeric(20), orderid numeric(20), ordertype numeric(1), iscloseorder numeric(1), executedat timestamp with time zone, createdat timestamp with time zone, orderprice numeric(20, 8), averagefilledprice numeric(20, 8), filledamount numeric(20, 8), strategyid text, stopout boolean, accountcurrencyid numeric(10), accountcurrency varchar(64), accountname text, userid numeric(10), email varchar(320), groupid numeric(10), groupname text, grossprofit numeric(20, 8), brokeragefee numeric(20, 8), isremoved boolean, swapamount numeric(20, 8), accountname_prefix text, slorderid numeric(20), slordertype numeric(5), slprice numeric(20, 8), tporderid numeric(20), tpordertype numeric(5), tpprice numeric(20, 8), crossprice numeric(20, 8), routeid numeric(10), open_cross_price. numeric(20, 8), sltroffset. numeric, remotehost text ); create index ix_trades_summary_positionid on .trades_summary (positionid); create index ix_trades_summary_accountid on .trades_summary (accountid); create index ix_trades_summary_closed_positions on .trades_summary (time, accountname_prefix, accountid, positionid) where (positionamount = (0)::numeric); create index ix_trades_summary_positionid_iscloseorder_time on .trades_summary (positionid, iscloseorder, time); create index ix_trades_summary_close_trades_info on .trades_summary (positionid) include (time, averagefilledprice, slprice, tpprice) where (iscloseorder = (1)::numeric); create index ix_trades_summary_time_iscloseorder_accountname_prefix_close on .trades_summary (accountname_prefix asc, iscloseorder asc, time desc); create index ix_trades_summary_orderid on .trades_summary (orderid); create index ix_trades_summary_accountname_prefix_positionid on .trades_summary (accountname_prefix, positionid) include (accountid, groupid, openorderid, instrumentname, opentradetime, openfilledprice, accountcurrency, isbuy); create trigger trg_insert_trades_bifrost after insert on .trades_summary for each row execute procedure bifrost.sync_trades_summary_insert_to_bifrost(); create trigger trg_trades_summary_update_bifrost after update on .trades_summary referencing new table new_table execute procedure bifrost.sync_trades_summary_update_to_bifrost(); create trigger trg_sync_bifrost_delete after delete on .trades_summary referencing old table old_table execute procedure bifrost.sync_bifrost_delete();