-ensure single transaction for exchange-0001.sql / shard-0001.sql

6 files changed, 75 insertions, 190 deletions

diff --git a/src/exchangedb/Makefile.am b/src/exchangedb/Makefile.am
index af2bfc0c6..01ce13dec 100644
--- a/src/exchangedb/Makefile.am
+++ b/src/exchangedb/Makefile.am
@@ -16,8 +16,10 @@ sqldir = $(prefix)/share/taler/sql/exchange/
 
 sqlinputs = \
   common-0001.sql \
+  exchange-0001.sql.in \
   exchange-0001-part.sql \
-  shard-0001-part.sql 
+  shard-0001-part.sql \
+  shard-0001.sql.in
 
 sql_DATA = \
   benchmark-0001.sql \
@@ -25,7 +27,7 @@ sql_DATA = \
   exchange-0001.sql \
   drop.sql \
   procedures.sql \
-  shard-0001.sql 
+  shard-0001.sql
 
 BUILT_SOURCES = \
   shard-0001.sql \
@@ -35,16 +37,16 @@ BUILT_SOURCES = \
 
 CLEANFILES = \
   shard-0001.sql \
-  exchange-0001.sql 
+  exchange-0001.sql
 
-exchange-0001.sql: common-0001.sql exchange-0001-part.sql
+exchange-0001.sql: common-0001.sql exchange-0001-part.sql exchange-0001.sql.in
 	chmod +w $@ || true
-	cat common-0001.sql exchange-0001-part.sql >$@
+	gcc -E -P -undef - < exchange-0001.sql.in 2>/dev/null | sed -e "s/--.*//" | awk 'NF' - >$@
 	chmod ugo-w $@
 
-shard-0001.sql: common-0001.sql shard-0001-part.sql
+shard-0001.sql: common-0001.sql shard-0001-part.sql exchange-0001.sql.in
 	chmod +w $@ || true
-	cat common-0001.sql shard-0001-part.sql >$@
+	gcc -E -P -undef - < shard-0001.sql.in 2>/dev/null | sed -e "s/--.*//" | awk 'NF' - >$@
 	chmod ugo-w $@
 
 EXTRA_DIST = \
diff --git a/src/exchangedb/common-0001.sql b/src/exchangedb/common-0001.sql
index 6c4a60248..7ec6ce6a9 100644
--- a/src/exchangedb/common-0001.sql
+++ b/src/exchangedb/common-0001.sql
@@ -14,16 +14,6 @@
 -- TALER; see the file COPYING.  If not, see <http://www.gnu.org/licenses/>
 --
 
--- Everything in one big transaction
-BEGIN;
-
--------------------- Schema ----------------------------
-
-CREATE SCHEMA exchange;
-COMMENT ON SCHEMA exchange IS 'taler-exchange data';
-
-SET search_path TO exchange;
-
 -------------------- Tables ----------------------------
 
 CREATE OR REPLACE FUNCTION create_partitioned_table(
@@ -2750,5 +2740,3 @@ BEGIN
 
 END
 $$;
-
-COMMIT;
diff --git a/src/exchangedb/exchange-0001-part.sql b/src/exchangedb/exchange-0001-part.sql
index 150897780..60b45b440 100644
--- a/src/exchangedb/exchange-0001-part.sql
+++ b/src/exchangedb/exchange-0001-part.sql
@@ -14,12 +14,6 @@
 -- TALER; see the file COPYING.  If not, see <http://www.gnu.org/licenses/>
 --
 
--- Everything in one big transaction
-BEGIN;
-
--- Check patch versioning is in place.
-SELECT _v.register_patch('exchange-0001', NULL, NULL);
-
 -- ------------------------------ denominations ----------------------------------------
 
 CREATE TABLE IF NOT EXISTS denominations
@@ -1404,12 +1398,3 @@ CREATE TRIGGER purse_requests_on_update
 COMMENT ON TRIGGER purse_requests_on_update
   ON purse_requests
   IS 'This covers the case where a deposit is made into a purse, which inherently then changes the purse balance via an UPDATE. If the merge is already present and the balance matches the total, we trigger the router. Once the router sets the purse to finished, the trigger will remove the purse from the watchlist of the router.';
-
-
-
--------------------------------------------------------------
---                   THE END
--------------------------------------------------------------
-
--- Complete transaction
-COMMIT;
diff --git a/src/exchangedb/exchange-0001.sql.in b/src/exchangedb/exchange-0001.sql.in
new file mode 100644
index 000000000..a01ac3a8a
--- /dev/null
+++ b/src/exchangedb/exchange-0001.sql.in
@@ -0,0 +1,33 @@
+--
+-- This file is part of TALER
+-- Copyright (C) 2014--2022 Taler Systems SA
+--
+-- TALER is free software; you can redistribute it and/or modify it under the
+-- terms of the GNU General Public License as published by the Free Software
+-- Foundation; either version 3, or (at your option) any later version.
+--
+-- TALER is distributed in the hope that it will be useful, but WITHOUT ANY
+-- WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR
+-- A PARTICULAR PURPOSE.  See the GNU General Public License for more details.
+--
+-- You should have received a copy of the GNU General Public License along with
+-- TALER; see the file COPYING.  If not, see <http://www.gnu.org/licenses/>
+--
+
+-- Everything in one big transaction
+BEGIN;
+
+-- Check patch versioning is in place.
+SELECT _v.register_patch('exchange-0001', NULL, NULL);
+
+-------------------- Schema ----------------------------
+
+CREATE SCHEMA exchange;
+COMMENT ON SCHEMA exchange IS 'taler-exchange data';
+
+SET search_path TO exchange;
+
+#include "common-0001.sql"
+#include "exchange-0001-part.sql"
+
+COMMIT;
diff --git a/src/exchangedb/shard-0001-part.sql b/src/exchangedb/shard-0001-part.sql
index e642fe65e..629dac537 100644
--- a/src/exchangedb/shard-0001-part.sql
+++ b/src/exchangedb/shard-0001-part.sql
@@ -14,12 +14,6 @@
 -- TALER; see the file COPYING.  If not, see <http://www.gnu.org/licenses/>
 --
 
--- Everything in one big transaction
-BEGIN;
-
--- Check patch versioning is in place.
-SELECT _v.register_patch('shard-0001', NULL, NULL);
-
 CREATE OR REPLACE FUNCTION setup_shard(
   shard_idx INTEGER
 )
@@ -121,153 +115,3 @@ BEGIN
   PERFORM add_constraints_to_wad_in_entries_partition(shard_suffix);
 END
 $$;
-
-
-CREATE OR REPLACE FUNCTION drop_shard(
-  shard_idx INTEGER
-)
-  RETURNS VOID
-  LANGUAGE plpgsql
-AS $$
-DECLARE
-  shard_suffix VARCHAR;
-BEGIN
-
-  shard_suffix = shard_idx::varchar;
-
-  EXECUTE FORMAT(
-    'DROP TABLE IF EXISTS %I CASCADE'
-    ,'wire_targets_' || shard_suffix
-  );
-  EXECUTE FORMAT(
-    'DROP TABLE IF EXISTS %I CASCADE'
-    ,'reserves_' || shard_suffix
-  );
-  EXECUTE FORMAT(
-    'DROP TABLE IF EXISTS %I CASCADE'
-    ,'reserves_in_' || shard_suffix
-  );
-  EXECUTE FORMAT(
-    'DROP TABLE IF EXISTS %I CASCADE'
-    ,'reserves_out_' || shard_suffix
-  );
-  EXECUTE FORMAT(
-    'DROP TABLE IF EXISTS %I CASCADE'
-    ,'reserves_close_' || shard_suffix
-  );
-  EXECUTE FORMAT(
-    'DROP TABLE IF EXISTS %I CASCADE'
-    ,'known_coins_' || shard_suffix
-  );
-  EXECUTE FORMAT(
-    'DROP TABLE IF EXISTS %I CASCADE'
-    ,'refresh_commitments_' || shard_suffix
-  );
-  EXECUTE FORMAT(
-    'DROP TABLE IF EXISTS %I CASCADE'
-    ,'refresh_revealed_coins_' || shard_suffix
-  );
-  EXECUTE FORMAT(
-    'DROP TABLE IF EXISTS %I CASCADE'
-    ,'refresh_transfer_keys_' || shard_suffix
-  );
-  EXECUTE FORMAT(
-    'DROP TABLE IF EXISTS %I CASCADE'
-    ,'deposits_' || shard_suffix
-  );
-  EXECUTE FORMAT(
-    'DROP TABLE IF EXISTS %I CASCADE'
-    ,'deposits_by_ready_' || shard_suffix
-  );
-  EXECUTE FORMAT(
-    'DROP TABLE IF EXISTS %I CASCADE'
-    ,'deposits_for_matching_' || shard_suffix
-  );
-  EXECUTE FORMAT(
-    'DROP TABLE IF EXISTS %I CASCADE'
-    ,'refunds_' || shard_suffix
-  );
-  EXECUTE FORMAT(
-    'DROP TABLE IF EXISTS %I CASCADE'
-    ,'wire_out_' || shard_suffix
-  );
-  EXECUTE FORMAT(
-    'DROP TABLE IF EXISTS %I CASCADE'
-    ,'aggregation_transient_' || shard_suffix
-  );
-  EXECUTE FORMAT(
-    'DROP TABLE IF EXISTS %I CASCADE'
-    ,'aggregation_tracking_' || shard_suffix
-  );
-  EXECUTE FORMAT(
-    'DROP TABLE IF EXISTS %I CASCADE'
-    ,'recoup_' || shard_suffix
-  );
-  EXECUTE FORMAT(
-    'DROP TABLE IF EXISTS %I CASCADE'
-    ,'recoup_by_reserve_' || shard_suffix
-  );
-  EXECUTE FORMAT(
-    'DROP TABLE IF EXISTS %I CASCADE'
-    ,'reserves_out_by_reserve_' || shard_suffix
-  );
-  EXECUTE FORMAT(
-    'DROP TABLE IF EXISTS %I CASCADE'
-    ,'recoup_refresh_' || shard_suffix
-  );
-  EXECUTE FORMAT(
-    'DROP TABLE IF EXISTS %I CASCADE'
-    ,'prewire_' || shard_suffix
-  );
-  EXECUTE FORMAT(
-    'DROP TABLE IF EXISTS %I CASCADE'
-    ,'cs_nonce_locks_' || shard_suffix
-  );
-  EXECUTE FORMAT(
-    'DROP TABLE IF EXISTS %I CASCADE'
-    ,'purse_requests_' || shard_suffix
-  );
-  EXECUTE FORMAT(
-    'DROP TABLE IF EXISTS %I CASCADE'
-    ,'purse_refunds_' || shard_suffix
-  );
-  EXECUTE FORMAT(
-    'DROP TABLE IF EXISTS %I CASCADE'
-    ,'purse_merges_' || shard_suffix
-  );
-  EXECUTE FORMAT(
-    'DROP TABLE IF EXISTS %I CASCADE'
-    ,'account_merges_' || shard_suffix
-  );
-  EXECUTE FORMAT(
-    'DROP TABLE IF EXISTS %I CASCADE'
-    ,'contracts_' || shard_suffix
-  );
-  EXECUTE FORMAT(
-    'DROP TABLE IF EXISTS %I CASCADE'
-    ,'history_requests_' || shard_suffix
-  );
-  EXECUTE FORMAT(
-    'DROP TABLE IF EXISTS %I CASCADE'
-    ,'close_requests_' || shard_suffix
-  );
-  EXECUTE FORMAT(
-    'DROP TABLE IF EXISTS %I CASCADE'
-    ,'purse_deposits_' || shard_suffix
-  );
-  EXECUTE FORMAT(
-    'DROP TABLE IF EXISTS %I CASCADE'
-    ,'wad_out_entries_' || shard_suffix
-  );
-  EXECUTE FORMAT(
-    'DROP TABLE IF EXISTS %I CASCADE'
-    ,'wads_in_' || shard_suffix
-  );
-  EXECUTE FORMAT(
-    'DROP TABLE IF EXISTS %I CASCADE'
-    ,'wad_in_entries_' || shard_suffix
-  );
-END
-$$;
-
-COMMIT;
diff --git a/src/exchangedb/shard-0001.sql.in b/src/exchangedb/shard-0001.sql.in
new file mode 100644
index 000000000..5a849a8ae
--- /dev/null
+++ b/src/exchangedb/shard-0001.sql.in
@@ -0,0 +1,33 @@
+--
+-- This file is part of TALER
+-- Copyright (C) 2014--2022 Taler Systems SA
+--
+-- TALER is free software; you can redistribute it and/or modify it under the
+-- terms of the GNU General Public License as published by the Free Software
+-- Foundation; either version 3, or (at your option) any later version.
+--
+-- TALER is distributed in the hope that it will be useful, but WITHOUT ANY
+-- WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR
+-- A PARTICULAR PURPOSE.  See the GNU General Public License for more details.
+--
+-- You should have received a copy of the GNU General Public License along with
+-- TALER; see the file COPYING.  If not, see <http://www.gnu.org/licenses/>
+--
+
+-- Everything in one big transaction
+BEGIN;
+
+-- Check patch versioning is in place.
+SELECT _v.register_patch('shard-0001', NULL, NULL);
+
+-------------------- Schema ----------------------------
+
+CREATE SCHEMA exchange;
+COMMENT ON SCHEMA exchange IS 'taler-exchange data';
+
+SET search_path TO exchange;
+
+#include "common-0001.sql"
+#include "shard-0001-part.sql"
+
+COMMIT;