taler/exchange
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

add missing indices where needed

Browse Source
This commit is contained in:
Christian Grothoff 2017-07-14 18:18:23 +02:00
parent 3a0e643b68
commit a301aadd28
No known key found for this signature in database
GPG Key ID: 939E6BE1E29FC3CC
1 changed files with 33 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
src/exchangedb/plugin_exchangedb_postgres.c
View File

@ -174,6 +174,10 @@ postgres_create_tables (void *cls)
",fee_refund_frac INT4 NOT NULL" ",fee_refund_frac INT4 NOT NULL"
",fee_refund_curr VARCHAR("TALER_CURRENCY_LEN_STR") NOT NULL" ",fee_refund_curr VARCHAR("TALER_CURRENCY_LEN_STR") NOT NULL"
")"), ")"),
/* index for gc_denominations */
GNUNET_PQ_make_try_execute ("CREATE INDEX denominations_expire_legal_index ON "
"denominations (expire_legal);"),
/* denomination_revocations table is for remembering which denomination keys have been revoked */ /* denomination_revocations table is for remembering which denomination keys have been revoked */
GNUNET_PQ_make_execute ("CREATE TABLE IF NOT EXISTS denomination_revocations" GNUNET_PQ_make_execute ("CREATE TABLE IF NOT EXISTS denomination_revocations"
"(denom_revocations_serial_id BIGSERIAL UNIQUE" "(denom_revocations_serial_id BIGSERIAL UNIQUE"
@ -196,8 +200,9 @@ postgres_create_tables (void *cls)
/* index on reserves table */ /* index on reserves table */
GNUNET_PQ_make_try_execute ("CREATE INDEX reserves_reserve_pub_index ON " GNUNET_PQ_make_try_execute ("CREATE INDEX reserves_reserve_pub_index ON "
"reserves (reserve_pub);"), "reserves (reserve_pub);"),
/* index for get_expired_reserves */
GNUNET_PQ_make_try_execute ("CREATE INDEX reserves_expiration_index" GNUNET_PQ_make_try_execute ("CREATE INDEX reserves_expiration_index"
" ON reserves (expiration_date);"), " ON reserves (expiration_date,current_balance_val,current_balance_frac);"),
/* reserves_in table collects the transactions which transfer funds /* reserves_in table collects the transactions which transfer funds
into the reserve. The rows of this table correspond to each into the reserve. The rows of this table correspond to each
incoming transaction. */ incoming transaction. */
@ -280,6 +285,9 @@ postgres_create_tables (void *cls)
",num_newcoins INT2 NOT NULL" ",num_newcoins INT2 NOT NULL"
",noreveal_index INT2 NOT NULL" ",noreveal_index INT2 NOT NULL"
");"), ");"),
GNUNET_PQ_make_try_execute ("CREATE INDEX refresh_sessions_old_coin_pub_index ON "
"refresh_sessions (old_coin_pub);"),
/* Table with information about the desired denominations to be created /* Table with information about the desired denominations to be created
during a refresh operation; contains the denomination key for each during a refresh operation; contains the denomination key for each
of the coins (for a given refresh session) */ of the coins (for a given refresh session) */
@ -308,10 +316,8 @@ postgres_create_tables (void *cls)
"(session_hash BYTEA NOT NULL REFERENCES refresh_sessions (session_hash) ON DELETE CASCADE" "(session_hash BYTEA NOT NULL REFERENCES refresh_sessions (session_hash) ON DELETE CASCADE"
",newcoin_index INT2 NOT NULL" ",newcoin_index INT2 NOT NULL"
",coin_ev BYTEA NOT NULL" ",coin_ev BYTEA NOT NULL"
",UNIQUE (session_hash, newcoin_index)" ",PRIMARY KEY (session_hash, newcoin_index)"
");"), ");"),
GNUNET_PQ_make_try_execute("CREATE INDEX refresh_commit_coin_session_hash_index "
"ON refresh_commit_coin(session_hash, newcoin_index)"),
/* Table with the signatures over coins generated during a refresh /* Table with the signatures over coins generated during a refresh
operation. Needed to answer /refresh/link queries later. Stores operation. Needed to answer /refresh/link queries later. Stores
the coin signatures under the respective session hash and index. */ the coin signatures under the respective session hash and index. */
@ -319,10 +325,8 @@ postgres_create_tables (void *cls)
"(session_hash BYTEA NOT NULL REFERENCES refresh_sessions (session_hash) ON DELETE CASCADE" "(session_hash BYTEA NOT NULL REFERENCES refresh_sessions (session_hash) ON DELETE CASCADE"
",newcoin_index INT2 NOT NULL" ",newcoin_index INT2 NOT NULL"
",ev_sig BYTEA NOT NULL" ",ev_sig BYTEA NOT NULL"
",UNIQUE (session_hash, newcoin_index)" ",PRIMARY KEY (session_hash, newcoin_index)"
");"), ");"),
GNUNET_PQ_make_try_execute("CREATE INDEX refresh_out_session_hash_index "
"ON refresh_out(session_hash, newcoin_index)"),
/* This table contains the wire transfers the exchange is supposed to /* This table contains the wire transfers the exchange is supposed to
execute to transmit funds to the merchants (and manage refunds). */ execute to transmit funds to the merchants (and manage refunds). */
GNUNET_PQ_make_execute("CREATE TABLE IF NOT EXISTS deposits " GNUNET_PQ_make_execute("CREATE TABLE IF NOT EXISTS deposits "
@ -346,6 +350,16 @@ postgres_create_tables (void *cls)
/* Index for get_deposit statement on coin_pub, h_contract_terms and merchant_pub */ /* Index for get_deposit statement on coin_pub, h_contract_terms and merchant_pub */
GNUNET_PQ_make_try_execute("CREATE INDEX deposits_coin_pub_index " GNUNET_PQ_make_try_execute("CREATE INDEX deposits_coin_pub_index "
"ON deposits(coin_pub, h_contract_terms, merchant_pub)"), "ON deposits(coin_pub, h_contract_terms, merchant_pub)"),
/* Index for get_deposit_for_wtid */
GNUNET_PQ_make_try_execute("CREATE INDEX deposits_coin_pub_merchant_contract_index "
"ON deposits(coin_pub, merchant_pub, h_contract_terms)"),
/* Index for deposits_get_ready */
GNUNET_PQ_make_try_execute("CREATE INDEX deposits_get_ready_index "
"ON deposits(tiny,done,wire_deadline,refund_deadline)"),
/* Index for deposits_iterate_matching */
GNUNET_PQ_make_try_execute("CREATE INDEX deposits_iterate_matching "
"ON deposits(merchant_pub,h_wire,done,wire_deadline)"),
/* Table with information about coins that have been refunded. (Technically /* Table with information about coins that have been refunded. (Technically
one of the deposit operations that a coin was involved with is refunded.)*/ one of the deposit operations that a coin was involved with is refunded.)*/
GNUNET_PQ_make_execute("CREATE TABLE IF NOT EXISTS refunds " GNUNET_PQ_make_execute("CREATE TABLE IF NOT EXISTS refunds "
@ -360,6 +374,8 @@ postgres_create_tables (void *cls)
",amount_with_fee_curr VARCHAR("TALER_CURRENCY_LEN_STR") NOT NULL" ",amount_with_fee_curr VARCHAR("TALER_CURRENCY_LEN_STR") NOT NULL"
",PRIMARY KEY (coin_pub, merchant_pub, h_contract_terms, rtransaction_id)" /* this combo must be unique, and we usually select by coin_pub */ ",PRIMARY KEY (coin_pub, merchant_pub, h_contract_terms, rtransaction_id)" /* this combo must be unique, and we usually select by coin_pub */
");"), ");"),
GNUNET_PQ_make_try_execute("CREATE INDEX refunds_coin_pub_index "
"ON refunds(coin_pub)"),
/* This table contains the data for /* This table contains the data for
wire transfers the exchange has executed. */ wire transfers the exchange has executed. */
GNUNET_PQ_make_execute("CREATE TABLE IF NOT EXISTS wire_out " GNUNET_PQ_make_execute("CREATE TABLE IF NOT EXISTS wire_out "
@ -395,6 +411,9 @@ postgres_create_tables (void *cls)
/* Index for lookup_transactions statement on wtid */ /* Index for lookup_transactions statement on wtid */
GNUNET_PQ_make_try_execute("CREATE INDEX aggregation_tracking_wtid_index " GNUNET_PQ_make_try_execute("CREATE INDEX aggregation_tracking_wtid_index "
"ON aggregation_tracking(wtid_raw);"), "ON aggregation_tracking(wtid_raw);"),
/* Index for gc_wire_fee */
GNUNET_PQ_make_try_execute("CREATE INDEX wire_fee_gc_index "
"ON wire_fee(end_date);"),
/* Table for /payback information */ /* Table for /payback information */
GNUNET_PQ_make_execute("CREATE TABLE IF NOT EXISTS payback " GNUNET_PQ_make_execute("CREATE TABLE IF NOT EXISTS payback "
"(payback_uuid BIGSERIAL UNIQUE" "(payback_uuid BIGSERIAL UNIQUE"
@ -420,9 +439,9 @@ postgres_create_tables (void *cls)
",finished BOOLEAN NOT NULL DEFAULT false" ",finished BOOLEAN NOT NULL DEFAULT false"
",buf BYTEA NOT NULL" ",buf BYTEA NOT NULL"
");"), ");"),
/* Index for prepare_data_iterate statement */ /* Index for wire_prepare_data_get and gc_prewire statement */
GNUNET_PQ_make_try_execute("CREATE INDEX prepare_iteration_index " GNUNET_PQ_make_try_execute("CREATE INDEX prepare_iteration_index "
"ON prewire(type,finished);"), "ON prewire(finished);"),
GNUNET_PQ_EXECUTE_STATEMENT_END GNUNET_PQ_EXECUTE_STATEMENT_END
}; };
PGconn *conn; PGconn *conn;
@ -896,7 +915,8 @@ postgres_prepare (PGconn *db_conn)
"SELECT" "SELECT"
" coin_ev" " coin_ev"
" FROM refresh_commit_coin" " FROM refresh_commit_coin"
" WHERE session_hash=$1 AND newcoin_index=$2;", " WHERE session_hash=$1"
" AND newcoin_index=$2;",
2), 2),
/* Store information about a /deposit the exchange is to execute. /* Store information about a /deposit the exchange is to execute.
Used in #postgres_insert_deposit(). */ Used in #postgres_insert_deposit(). */
@ -1147,7 +1167,9 @@ postgres_prepare (PGconn *db_conn)
NOTE: This may (in theory) return multiple results, one per session NOTE: This may (in theory) return multiple results, one per session
that the old coin was melted into. */ that the old coin was melted into. */
GNUNET_PQ_make_prepare ("get_transfer", GNUNET_PQ_make_prepare ("get_transfer",
"SELECT transfer_pub,session_hash" "SELECT"
" transfer_pub"
",session_hash"
" FROM refresh_sessions rs" " FROM refresh_sessions rs"
" JOIN refresh_transfer_public_key rcl" " JOIN refresh_transfer_public_key rcl"
" USING (session_hash)" " USING (session_hash)"