diff options
Diffstat (limited to 'src/exchangedb/plugin_exchangedb_postgres.c')
-rw-r--r-- | src/exchangedb/plugin_exchangedb_postgres.c | 53 |
1 files changed, 53 insertions, 0 deletions
diff --git a/src/exchangedb/plugin_exchangedb_postgres.c b/src/exchangedb/plugin_exchangedb_postgres.c index 754654e32..9a3229f47 100644 --- a/src/exchangedb/plugin_exchangedb_postgres.c +++ b/src/exchangedb/plugin_exchangedb_postgres.c @@ -2123,6 +2123,22 @@ prepare_statements (struct PostgresClosure *pg) " ORDER BY recoup_refresh_uuid DESC" " LIMIT 1;", 0), + GNUNET_PQ_make_prepare ( + "select_serial_by_table_extensions", + "SELECT" + " extension_id AS serial" + " FROM extensions" + " ORDER BY extension_id DESC" + " LIMIT 1;", + 0), + GNUNET_PQ_make_prepare ( + "select_serial_by_table_extension_details", + "SELECT" + " extension_details_serial_id AS serial" + " FROM extension_details" + " ORDER BY extension_details_serial_id DESC" + " LIMIT 1;", + 0), /* For postgres_lookup_records_by_table */ GNUNET_PQ_make_prepare ( "select_above_serial_by_table_denominations", @@ -2727,6 +2743,23 @@ prepare_statements (struct PostgresClosure *pg) ") VALUES " "($1, $2, $3, $4, $5, $6, $7, $8);", 8), + GNUNET_PQ_make_prepare ( + "insert_into_table_extensions", + "INSERT INTO extensions" + "(extension_id" + ",name" + ",config" + ") VALUES " + "($1, $2, $3);", + 3), + GNUNET_PQ_make_prepare ( + "insert_into_table_extension_details", + "INSERT INTO extension_details" + "(extension_details_serial_id" + ",extension_options" + ") VALUES " + "($1, $2);", + 2), /* Used in #postgres_begin_shard() */ GNUNET_PQ_make_prepare ( @@ -10807,6 +10840,12 @@ postgres_lookup_serial_by_table (void *cls, case TALER_EXCHANGEDB_RT_RECOUP_REFRESH: statement = "select_serial_by_table_recoup_refresh"; break; + case TALER_EXCHANGEDB_RT_EXTENSIONS: + statement = "select_serial_by_table_extensions"; + break; + case TALER_EXCHANGEDB_RT_EXTENSION_DETAILS: + statement = "select_serial_by_table_extension_details"; + break; default: GNUNET_break (0); return GNUNET_DB_STATUS_HARD_ERROR; @@ -10972,6 +11011,14 @@ postgres_lookup_records_by_table (void *cls, statement = "select_above_serial_by_table_recoup_refresh"; rh = &lrbt_cb_table_recoup_refresh; break; + case TALER_EXCHANGEDB_RT_EXTENSIONS: + statement = "select_above_serial_by_table_extensions"; + rh = &lrbt_cb_table_extensions; + break; + case TALER_EXCHANGEDB_RT_EXTENSION_DETAILS: + statement = "select_above_serial_by_table_extension_details"; + rh = &lrbt_cb_table_extension_details; + break; default: GNUNET_break (0); return GNUNET_DB_STATUS_HARD_ERROR; @@ -11097,6 +11144,12 @@ postgres_insert_records_by_table (void *cls, case TALER_EXCHANGEDB_RT_RECOUP_REFRESH: rh = &irbt_cb_table_recoup_refresh; break; + case TALER_EXCHANGEDB_RT_EXTENSIONS: + rh = &irbt_cb_table_extensions; + break; + case TALER_EXCHANGEDB_RT_EXTENSION_DETAILS: + rh = &irbt_cb_table_extension_details; + break; default: GNUNET_break (0); return GNUNET_DB_STATUS_HARD_ERROR; |