1 files changed, 10 insertions, 9 deletions
diff --git a/src/exchangedb/0002-aggregation_tracking.sql b/src/exchangedb/0002-aggregation_tracking.sql
index f6135c5ac..d07960247 100644
--- a/src/exchangedb/0002-aggregation_tracking.sql
+++ b/src/exchangedb/0002-aggregation_tracking.sql
@@ -15,22 +15,22 @@
 --
 
 CREATE FUNCTION create_table_aggregation_tracking(
-  IN partition_suffix VARCHAR DEFAULT NULL
+  IN partition_suffix TEXT DEFAULT NULL
 )
 RETURNS VOID
 LANGUAGE plpgsql
 AS $$
 DECLARE
-  table_name VARCHAR DEFAULT 'aggregation_tracking';
+  table_name TEXT DEFAULT 'aggregation_tracking';
 BEGIN
   PERFORM create_partitioned_table(
     'CREATE TABLE %I'
       '(aggregation_serial_id BIGINT GENERATED BY DEFAULT AS IDENTITY'
-      ',deposit_serial_id INT8 PRIMARY KEY'
+      ',batch_deposit_serial_id INT8 PRIMARY KEY'
       ',wtid_raw BYTEA NOT NULL'
     ') %s ;'
     ,table_name
-    ,'PARTITION BY HASH (deposit_serial_id)'
+    ,'PARTITION BY HASH (batch_deposit_serial_id)'
     ,partition_suffix
   );
   PERFORM comment_partitioned_table(
@@ -49,13 +49,13 @@ $$;
 
 
 CREATE FUNCTION constrain_table_aggregation_tracking(
-  IN partition_suffix VARCHAR
+  IN partition_suffix TEXT
 )
 RETURNS VOID
 LANGUAGE plpgsql
 AS $$
 DECLARE
-  table_name VARCHAR DEFAULT 'aggregation_tracking';
+  table_name TEXT DEFAULT 'aggregation_tracking';
 BEGIN
   table_name = concat_ws('_', table_name, partition_suffix);
   EXECUTE FORMAT (
@@ -81,13 +81,14 @@ RETURNS VOID
 LANGUAGE plpgsql
 AS $$
 DECLARE
-  table_name VARCHAR DEFAULT 'aggregation_tracking';
+  table_name TEXT DEFAULT 'aggregation_tracking';
 BEGIN
   EXECUTE FORMAT (
     'ALTER TABLE ' || table_name ||
     ' ADD CONSTRAINT ' || table_name || '_foreign_deposit'
-    ' FOREIGN KEY (deposit_serial_id) '
-    ' REFERENCES deposits (deposit_serial_id) ON DELETE CASCADE' -- FIXME change to coin_pub + deposit_serial_id for more efficient deposit???
+    ' FOREIGN KEY (batch_deposit_serial_id)'
+    ' REFERENCES batch_deposits (batch_deposit_serial_id)'
+    ' ON DELETE CASCADE'
   );
 END
 $$;