create table .accountoperation ( accountoperationid numeric(20) not null constraint pk_accountoperation primary key, administratorid numeric(10), accountid numeric(10), operationtypeid numeric(10), orderid numeric(20), basis text, sum numeric(20, 8), createdat timestamp with time zone, counteroperationid numeric(20), positionid numeric(20), tradeid numeric(20), valuedate timestamp with time zone, assetid numeric(10), subtypeid numeric(2), lastmodified timestamp with time zone, troptype numeric(1), externalid text, caexecutionid numeric(10), productid numeric(10), caid numeric(20), catype numeric(10) ); create index ix_accountoperation_operationtypeid on .accountoperation (operationtypeid); create index ix_accountoperation_orderid_accountid_operationtypeid on .accountoperation (orderid, accountid, operationtypeid); create index ix_accountoperation_tradeid_accountid on .accountoperation (tradeid, accountid); create index ix_accountoperation_tradeid_accountid_operationtypeid on .accountoperation (tradeid, accountid, operationtypeid); create index ix_accountoperation_tradeid_operationtype on .accountoperation (tradeid, accountid, operationtypeid); create trigger trg_sync_swaps_insert after insert on .accountoperation referencing new table new_table execute procedure .sync_swaps_insert(); create trigger trg_sync_swaps_update after update on .accountoperation referencing new table new_table execute procedure .sync_swaps_update(); create trigger trg_sync_swaps_delete after delete on .accountoperation referencing old table old_table execute procedure .sync_swaps_delete(); create trigger sync_accountop_to_trades_bifrost_insert after insert on .accountoperation referencing new table new_accops execute procedure bifrost.sync_accountop_to_trades_bifrost_insert(); create trigger sync_accountop_to_trades_bifrost_update after update on .accountoperation referencing new table new_accops execute procedure bifrost.sync_accountop_to_trades_bifrost_update(); create trigger sync_accountop_to_trades_bifrost_delete after delete on .accountoperation referencing old table old_accops execute procedure bifrost.sync_accountop_to_trades_bifrost_delete();