diff options
| author | Christian Grothoff <grothoff@gnunet.org> | 2022-10-10 08:49:47 +0200 |
|---|---|---|
| committer | Christian Grothoff <grothoff@gnunet.org> | 2022-10-10 08:49:47 +0200 |
| commit | 3a4515c029156e859126e6e0e6d2a0c9a0d90fe1 (patch) | |
| tree | c60e10b4806ff9c9d359b9c752ca4e9c5ed42458 | |
| parent | d0debc467e46497f042e8e61d01e86e76e08aa92 (diff) | |
| download | exchange-3a4515c029156e859126e6e0e6d2a0c9a0d90fe1.tar.gz exchange-3a4515c029156e859126e6e0e6d2a0c9a0d90fe1.tar.bz2 exchange-3a4515c029156e859126e6e0e6d2a0c9a0d90fe1.zip | |
-implement missing select_serial_by_table_ statements
| -rw-r--r-- | src/exchangedb/pg_lookup_serial_by_table.c | 40 |
1 files changed, 40 insertions, 0 deletions
diff --git a/src/exchangedb/pg_lookup_serial_by_table.c b/src/exchangedb/pg_lookup_serial_by_table.c index 5a0b493bf..500569c14 100644 --- a/src/exchangedb/pg_lookup_serial_by_table.c +++ b/src/exchangedb/pg_lookup_serial_by_table.c @@ -77,6 +77,22 @@ TEH_PG_lookup_serial_by_table (void *cls, " ORDER BY wire_target_serial_id DESC" " LIMIT 1;"); break; + case TALER_EXCHANGEDB_RT_LEGITIMIZATION_PROCESSES: + XPREPARE ("select_serial_by_table_legitimization_processes", + "SELECT" + " legitimization_process_serial_id AS serial" + " FROM legitimization_processes" + " ORDER BY legitimization_process_serial_id DESC" + " LIMIT 1;"); + break; + case TALER_EXCHANGEDB_RT_LEGITIMIZATION_REQUIREMENTS: + XPREPARE ("select_serial_by_table_legitimization_requiremetns", + "SELECT" + " legitimization_requirement_serial_id AS serial" + " FROM legitimization_requirements" + " ORDER BY legitimization_requirement_serial_id DESC" + " LIMIT 1;"); + break; case TALER_EXCHANGEDB_RT_RESERVES: XPREPARE ("select_serial_by_table_reserves", "SELECT" @@ -101,6 +117,30 @@ TEH_PG_lookup_serial_by_table (void *cls, " ORDER BY close_uuid DESC" " LIMIT 1;"); break; + case TALER_EXCHANGEDB_RT_RESERVES_OPEN_REQUESTS: + XPREPARE ("select_serial_by_table_reserves_open_requests", + "SELECT" + " open_request_uuid AS serial" + " FROM reserves_open_requests" + " ORDER BY open_request_uuid DESC" + " LIMIT 1;"); + break; + case TALER_EXCHANGEDB_RT_RESERVES_OPEN_DEPOSITS: + XPREPARE ("select_serial_by_table_reserves_open_deposits", + "SELECT" + " open_request_uuid AS serial" + " FROM reserves_open_deposits" + " ORDER BY open_request_uuid DESC" + " LIMIT 1;"); + break; + case TALER_EXCHANGEDB_RT_RESERVES_CLOSE_REQUESTS: + XPREPARE ("select_serial_by_table_reserves_close_requests", + "SELECT" + " close_request_uuid AS serial" + " FROM reserves_close_requests" + " ORDER BY close_request_uuid DESC" + " LIMIT 1;"); + break; case TALER_EXCHANGEDB_RT_RESERVES_OUT: XPREPARE ("select_serial_by_table_reserves_out", "SELECT" |