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

SQL fixes

Browse Source
This commit is contained in:
Christian Grothoff 2021-10-31 13:58:20 +01:00
parent 35e3506660
commit 1d5edc6882
No known key found for this signature in database
GPG Key ID: 939E6BE1E29FC3CC
1 changed files with 40 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

51
src/exchangedb/plugin_exchangedb_postgres.c
View File

@ -405,24 +405,23 @@ prepare_statements (struct PostgresClosure *pg)
" wire_target_serial_id=$1", " wire_target_serial_id=$1",
1), 1),
/* Used in #postgres_inselect_wallet_kyc_status() */ /* Used in #postgres_inselect_wallet_kyc_status() */
// FIXME: Note that this statement has not been debugged at all...
// It just represents the _idea_.
GNUNET_PQ_make_prepare ( GNUNET_PQ_make_prepare (
"inselect_wallet_kyc_status", "insert_kyc_status",
"WITH cte AS (" "INSERT INTO wire_targets"
" INSERT INTO wire_targets"
" (h_payto" " (h_payto"
" ,payto_uri" " ,payto_uri"
" ) VALUES " " ) VALUES "
" ($1, $2)" " ($1, $2)"
" ON CONFLICT (wire_target_serial_id) DO NOTHING" " RETURNING wire_target_serial_id",
") " 2),
GNUNET_PQ_make_prepare (
"select_kyc_status_by_payto",
"SELECT " "SELECT "
" kyc_ok" " kyc_ok"
",wire_target_serial_id" ",wire_target_serial_id"
" FROM wire_targets" " FROM wire_targets"
" WHERE h_payto=$1;", " WHERE h_payto=$1;",
2), 1),
/* Used in #reserves_get() */ /* Used in #reserves_get() */
GNUNET_PQ_make_prepare ( GNUNET_PQ_make_prepare (
"reserves_get", "reserves_get",
@ -3901,7 +3900,6 @@ inselect_account_kyc_status (
{ {
struct GNUNET_PQ_QueryParam params[] = { struct GNUNET_PQ_QueryParam params[] = {
GNUNET_PQ_query_param_auto_from_type (&h_payto), GNUNET_PQ_query_param_auto_from_type (&h_payto),
GNUNET_PQ_query_param_string (payto_uri),
GNUNET_PQ_query_param_end GNUNET_PQ_query_param_end
}; };
uint8_t ok8 = 0; uint8_t ok8 = 0;
@ -3914,11 +3912,37 @@ inselect_account_kyc_status (
}; };
qs = GNUNET_PQ_eval_prepared_singleton_select (pg->conn, qs = GNUNET_PQ_eval_prepared_singleton_select (pg->conn,
"inselect_wallet_kyc_status", "select_kyc_status_by_payto",
params, params,
rs); rs);
if (GNUNET_DB_STATUS_SUCCESS_NO_RESULTS == qs)
{
struct GNUNET_PQ_QueryParam iparams[] = {
GNUNET_PQ_query_param_auto_from_type (&h_payto),
GNUNET_PQ_query_param_string (payto_uri),
GNUNET_PQ_query_param_end
};
struct GNUNET_PQ_ResultSpec irs[] = {
GNUNET_PQ_result_spec_uint64 ("wire_target_serial_id",
&kyc->payment_target_uuid),
GNUNET_PQ_result_spec_end
};
qs = GNUNET_PQ_eval_prepared_singleton_select (pg->conn,
"insert_kyc_status",
iparams,
irs);
if (qs < 0)
return qs;
if (GNUNET_DB_STATUS_SUCCESS_NO_RESULTS == qs)
return GNUNET_DB_STATUS_SOFT_ERROR;
kyc->ok = false;
}
else
{
kyc->ok = (0 != ok8); kyc->ok = (0 != ok8);
} }
}
kyc->type = TALER_EXCHANGEDB_KYC_BALANCE; kyc->type = TALER_EXCHANGEDB_KYC_BALANCE;
return qs; return qs;
} }
@ -4150,15 +4174,18 @@ postgres_reserves_in_insert (void *cls,
struct TALER_EXCHANGEDB_KycStatus kyc; struct TALER_EXCHANGEDB_KycStatus kyc;
enum GNUNET_DB_QueryStatus qs3; enum GNUNET_DB_QueryStatus qs3;
memset (&kyc,
0,
sizeof (kyc));
qs3 = inselect_account_kyc_status (pg, qs3 = inselect_account_kyc_status (pg,
sender_account_details, sender_account_details,
&kyc); &kyc);
if (qs3 <= 0) if (qs3 <= 0)
{ {
GNUNET_break (GNUNET_DB_STATUS_HARD_ERROR == qs3);
GNUNET_break (GNUNET_DB_STATUS_SOFT_ERROR == qs3); GNUNET_break (GNUNET_DB_STATUS_SOFT_ERROR == qs3);
return qs3; return qs3;
} }
GNUNET_assert (0 != kyc.payment_target_uuid);
if (GNUNET_DB_STATUS_SUCCESS_NO_RESULTS == qs1) if (GNUNET_DB_STATUS_SUCCESS_NO_RESULTS == qs1)
{ {
struct GNUNET_PQ_QueryParam params[] = { struct GNUNET_PQ_QueryParam params[] = {
@ -4968,7 +4995,7 @@ postgres_select_withdraw_amounts_by_account (
qs = GNUNET_PQ_eval_prepared_multi_select ( qs = GNUNET_PQ_eval_prepared_multi_select (
pg->conn, pg->conn,
"select_XXX", "select_XXX_FIXME",
params, params,
&withdraw_amount_by_account_cb, &withdraw_amount_by_account_cb,
&wac); &wac);