136 lines
3.9 KiB
PL/PgSQL
136 lines
3.9 KiB
PL/PgSQL
CREATE SCHEMA banking_stage_results_2;
|
|
|
|
CREATE TABLE banking_stage_results_2.transactions(
|
|
signature char(88) primary key,
|
|
transaction_id bigserial,
|
|
UNIQUE(transaction_id)
|
|
);
|
|
|
|
CREATE TABLE banking_stage_results_2.transaction_infos (
|
|
transaction_id BIGINT PRIMARY KEY,
|
|
processed_slot BIGINT,
|
|
is_successful BOOL,
|
|
cu_requested BIGINT,
|
|
cu_consumed BIGINT,
|
|
prioritization_fees BIGINT,
|
|
supp_infos text
|
|
);
|
|
|
|
CREATE TABLE banking_stage_results_2.errors (
|
|
error_code int primary key,
|
|
error_text text
|
|
);
|
|
|
|
CREATE TABLE banking_stage_results_2.transaction_slot (
|
|
transaction_id BIGINT,
|
|
slot BIGINT,
|
|
error_code INT REFERENCES banking_stage_results_2.errors(error_code),
|
|
count INT,
|
|
utc_timestamp TIMESTAMP NOT NULL,
|
|
PRIMARY KEY (transaction_id, slot, error_code)
|
|
);
|
|
|
|
CREATE INDEX idx_transaction_slot_slot ON banking_stage_results_2.transaction_slot(slot);
|
|
|
|
CREATE TABLE banking_stage_results_2.blocks (
|
|
slot BIGINT PRIMARY KEY,
|
|
block_hash char(44),
|
|
leader_identity char(44),
|
|
successful_transactions BIGINT,
|
|
processed_transactions BIGINT,
|
|
total_cu_used BIGINT,
|
|
total_cu_requested BIGINT,
|
|
supp_infos text
|
|
);
|
|
|
|
CREATE TABLE banking_stage_results_2.accounts(
|
|
acc_id bigserial primary key,
|
|
account_key char(44),
|
|
UNIQUE (account_key)
|
|
);
|
|
|
|
CREATE TABLE banking_stage_results_2.accounts_map_transaction(
|
|
acc_id BIGINT,
|
|
transaction_id BIGINT,
|
|
is_writable BOOL,
|
|
is_signer BOOL,
|
|
is_atl BOOL,
|
|
PRIMARY KEY (transaction_id, acc_id)
|
|
);
|
|
|
|
CREATE INDEX accounts_map_transaction_transaction_id ON banking_stage_results_2.accounts_map_transaction(transaction_id);
|
|
|
|
CREATE TABLE banking_stage_results_2.accounts_map_blocks (
|
|
acc_id BIGINT,
|
|
slot BIGINT,
|
|
is_write_locked BOOL,
|
|
total_cu_consumed BIGINT,
|
|
total_cu_requested BIGINT,
|
|
prioritization_fees_info text,
|
|
supp_infos text,
|
|
PRIMARY KEY (acc_id, slot, is_write_locked)
|
|
);
|
|
|
|
insert into banking_stage_results_2.errors (error_text, error_code) VALUES
|
|
('AccountBorrowOutstanding', 0),
|
|
('AccountInUse', 1),
|
|
('AccountLoadedTwice', 2),
|
|
('AccountNotFound', 3),
|
|
('AddressLookupTableNotFound', 4),
|
|
('AlreadyProcessed', 5),
|
|
('BlockhashNotFound', 6),
|
|
('CallChainTooDeep', 7),
|
|
('ClusterMaintenance', 8),
|
|
('DuplicateInstruction', 9),
|
|
('InstructionError', 10),
|
|
('InsufficientFundsForFee', 11),
|
|
('InsufficientFundsForRent', 12),
|
|
('InvalidAccountForFee', 13),
|
|
('InvalidAccountIndex', 14),
|
|
('InvalidAddressLookupTableData', 15),
|
|
('InvalidAddressLookupTableIndex', 16),
|
|
('InvalidAddressLookupTableOwner', 17),
|
|
('InvalidLoadedAccountsDataSizeLimit', 18),
|
|
('InvalidProgramForExecution', 19),
|
|
('InvalidRentPayingAccount', 20),
|
|
('InvalidWritableAccount', 21),
|
|
('MaxLoadedAccountsDataSizeExceeded', 22),
|
|
('MissingSignatureForFee', 23),
|
|
('ProgramAccountNotFound', 24),
|
|
('ResanitizationNeeded', 25),
|
|
('SanitizeFailure', 26),
|
|
('SignatureFailure', 27),
|
|
('TooManyAccountLocks', 28),
|
|
('UnbalancedTransaction', 29),
|
|
('UnsupportedVersion', 30),
|
|
('WouldExceedAccountDataBlockLimit', 31),
|
|
('WouldExceedAccountDataTotalLimit', 32),
|
|
('WouldExceedMaxAccountCostLimit', 33),
|
|
('WouldExceedMaxBlockCostLimit', 34),
|
|
('WouldExceedMaxVoteCostLimit', 35);
|
|
|
|
CREATE TABLE banking_stage_results_2.accounts_map_transaction_latest(
|
|
acc_id BIGINT PRIMARY KEY,
|
|
-- sorted: oldest to latest, max 1000
|
|
tx_ids BIGINT[]
|
|
);
|
|
|
|
CREATE OR REPLACE FUNCTION array_dedup_append(base bigint[], append bigint[], n_limit int)
|
|
RETURNS bigint[]
|
|
AS $$
|
|
DECLARE
|
|
tmplist bigint[];
|
|
el bigint;
|
|
len int;
|
|
BEGIN
|
|
tmplist := base;
|
|
FOREACH el IN ARRAY append LOOP
|
|
tmplist := array_remove(tmplist, el);
|
|
tmplist := tmplist || el;
|
|
END LOOP;
|
|
|
|
len := CARDINALITY(tmplist);
|
|
RETURN tmplist[(len + 1 - n_limit):];
|
|
END
|
|
$$ LANGUAGE plpgsql IMMUTABLE CALLED ON NULL INPUT;
|