diff --git a/sql/procedures.sql b/sql/procedures.sql
index 733b3c9..a106323 100644
--- a/sql/procedures.sql
+++ b/sql/procedures.sql
@@ -54,6 +54,16 @@ begin
 end;
 $$ language plpgsql;
 
+create or replace function clear_user_data(p_user_id uuid)
+returns void
+as $$
+begin
+  delete from staking_source where user_id = p_user_id;
+  delete from inventory_item where user_id = p_user_id;
+  update bank_account set balance = 2000 where user_id = p_user_id;
+  update resource_account set balance = 0 where user_id = p_user_id;
+end;
+$$ language plpgsql;
 
 create or replace function get_staking_sources(user_id uuid)
 returns table (
diff --git a/sql/queries.sql b/sql/queries.sql
index 325e4c5..a2a8d4a 100644
--- a/sql/queries.sql
+++ b/sql/queries.sql
@@ -38,29 +38,3 @@ delete from claim_event;
 
 alter table store_item alter column price type integer using price::integer;
 
--- Import config from google sheets
-drop table test_csv_import;
-
-create table test_csv_import (
-    id integer,
-    name text,
-    description text,
-    image text,
-    claimAmount int,
-    completionTimeInMins int,
-    tier1price int,
-    tier1claimboost int,
-    tier2price int,
-    tier2claimboost int,
-    tier3price int,
-    tier3claimboost int,
-    tier4price int,
-    tier4claimboost int,
-    tier5price int,
-    tier5claimboost int
-);
-
-\copy test_csv_import from '../storeitems.csv' delimiter ',' csv header;
-
-select * from test_csv_import;
-
diff --git a/sql/tables.sql b/sql/tables.sql
index 4997edd..a8578a2 100644
--- a/sql/tables.sql
+++ b/sql/tables.sql
@@ -82,7 +82,7 @@ create table upgrade_event (
     inventory_item_id uuid not null,
     created_at timestamp with time zone default timezone('utc', now()),
     constraint fk_iid_upgrade_event foreign key(inventory_item_id)
-        references inventory_item(id)
+        references inventory_item(id) on delete cascade
 );
 
 create table staking_event (
@@ -98,7 +98,7 @@ create table staking_event (
     constraint fk_wid_staking_event foreign key(well_id)
         references resource_well(id),
     constraint fk_iiid_staking_event foreign key(inventory_item_id)
-        references inventory_item(id)
+        references inventory_item(id) on delete cascade
 );
 
 create table claim_event (
diff --git a/test-endpoints.restclient b/test-endpoints.restclient
index 4df6d31..ebd8d24 100644
--- a/test-endpoints.restclient
+++ b/test-endpoints.restclient
@@ -20,6 +20,10 @@ POST http://localhost:3000/api/user/login
 GET http://localhost:3000/api/user/:user_id/bank-account
 :headers
 
+# Get bank account
+POST http://localhost:3000/api/user/:user_id/clear-data
+:headers
+
 # Get bank account
 GET http://localhost:3000/api/leaderboards
 :headers