diff --git a/migration.sql b/migration.sql index 12843fe..1ee6de0 100644 --- a/migration.sql +++ b/migration.sql @@ -1,7 +1,7 @@ CREATE SCHEMA banking_stage_results_2; CREATE TABLE banking_stage_results_2.transactions( - signature text primary key, + signature char(88) primary key, transaction_id bigserial, UNIQUE(transaction_id) ); @@ -35,8 +35,8 @@ CREATE INDEX idx_transaction_slot_slot ON banking_stage_results_2.transaction_sl CREATE TABLE banking_stage_results_2.blocks ( slot BIGINT PRIMARY KEY, - block_hash text, - leader_identity text, + block_hash char(44), + leader_identity char(44), successful_transactions BIGINT, processed_transactions BIGINT, total_cu_used BIGINT, @@ -59,8 +59,6 @@ CREATE TABLE banking_stage_results_2.accounts_map_transaction( PRIMARY KEY (transaction_id, acc_id) ); -ALTER TABLE banking_stage_results_2.accounts_map_transaction ADD COLUMN is_atl BOOL; - CREATE INDEX accounts_map_transaction_acc_id ON banking_stage_results_2.accounts_map_transaction(acc_id); CREATE INDEX accounts_map_transaction_transaction_id ON banking_stage_results_2.accounts_map_transaction(transaction_id); @@ -122,8 +120,6 @@ VACUUM FULL banking_stage_results_2.blocks; CLUSTER banking_stage_results_2.transaction_slot using idx_transaction_slot_timestamp; VACUUM FULL banking_stage_results_2.transaction_slot; -ALTER TABLE banking_stage_results_2.transactions ALTER COLUMN signature TYPE TEXT; - CLUSTER banking_stage_results_2.accounts_map_transaction using accounts_map_transaction_pkey; CLUSTER banking_stage_results_2.transactions using transactions_pkey; diff --git a/src/postgres.rs b/src/postgres.rs index 1b48ef8..9704dc9 100644 --- a/src/postgres.rs +++ b/src/postgres.rs @@ -134,7 +134,7 @@ impl PostgresSession { format!( r#" CREATE TEMP TABLE {}( - signature text + signature char(88) ); "#, temp_table @@ -307,8 +307,8 @@ impl PostgresSession { .execute( format!( "CREATE TEMP TABLE {}( - account_key text, - signature text, + account_key char(44), + signature char(88), is_writable BOOL, is_signer BOOL, is_atl BOOL @@ -381,7 +381,7 @@ impl PostgresSession { .execute( format!( "CREATE TEMP TABLE {}( - signature text, + signature char(88), processed_slot BIGINT, is_successful BOOL, cu_requested BIGINT, @@ -470,7 +470,7 @@ impl PostgresSession { .execute( format!( "CREATE TEMP TABLE {}( - account_key TEXT, + account_key char(44), slot BIGINT, is_write_locked BOOL, total_cu_requested BIGINT,