diff options
Diffstat (limited to 'src/backenddb/pg_update_wirewatch_progress.c')
| -rw-r--r-- | src/backenddb/pg_update_wirewatch_progress.c | 16 |
1 files changed, 11 insertions, 5 deletions
diff --git a/src/backenddb/pg_update_wirewatch_progress.c b/src/backenddb/pg_update_wirewatch_progress.c index d702c314..8ffdfe70 100644 --- a/src/backenddb/pg_update_wirewatch_progress.c +++ b/src/backenddb/pg_update_wirewatch_progress.c @@ -29,21 +29,27 @@ enum GNUNET_DB_QueryStatus TMH_PG_update_wirewatch_progress ( void *cls, - const char *section, + const char *instance, + const char *payto_uri, uint64_t last_serial) { struct PostgresClosure *pg = cls; struct GNUNET_PQ_QueryParam params[] = { - GNUNET_PQ_query_param_string (section), + GNUNET_PQ_query_param_string (instance), + GNUNET_PQ_query_param_string (payto_uri), GNUNET_PQ_query_param_uint64 (&last_serial), GNUNET_PQ_query_param_end }; PREPARE (pg, "update_wirewatch_progress", - "UPDATE merchant_wirewatch" - " SET last_bank_serial=$2" - " WHERE account_section=$1"); + "UPDATE merchant_accounts" + " SET last_bank_serial=$3" + " WHERE payto_uri=$2" + " AND merchant_serial =" + " (SELECT merchant_serial" + " FROM merchant_instances" + " WHERE merchant_id=$1)"); check_connection (pg); return GNUNET_PQ_eval_prepared_non_select (pg->conn, "update_wirewatch_progress", |