From 4c6aa0782ee76b6d2b8ffc44613e62ea07ec1c5e Mon Sep 17 00:00:00 2001 From: Aravinth Manivannan Date: Sun, 14 Jul 2024 18:24:24 +0530 Subject: [PATCH] fix: use UUID based IDs to identify records instead of view_id in queries --- ...a37ac4ccf493ebced9cf690f4030e78bd439.json} | 5 ++-- ...ada6797292064485b1f3ce342d7eb0cb3ccf4.json | 28 +++++++++++++++++++ ...75fcac797644d104d3d580715587ecb2e2119.json | 18 ++++++++++++ ...f1f09069e1d6d168f9e93b729cf964e97c35.json} | 6 ++-- ...469fb66ddb078d016fd6f05cb5e62ef0b23d5.json | 28 ------------------- ...04d5849c3990f0965de479b76630317f8a6e.json} | 5 ++-- ...567aa41b8a7ef1fbdba42116d90aa000584b8.json | 28 +++++++++++++++++++ ...e3436d3983e8a32400bbcefd91efb945190cd.json | 22 +++++++++++++++ ...1def62da1715c65214a4d404a5ce551c501bd.json | 19 ------------- ...49cae596a9f621e6a64c31270d744406271ec.json | 19 ------------- ...859bc6e2fb1a75da0ed248debf126ba39c1d1.json | 28 ------------------- ...eb3d28b2a1fe005190cd3599c2772dd01f7d.json} | 6 ++-- ...b4c5ee1d3beb6dda94290c80c5ae038894116.json | 18 ++++++++++++ migrations/20240516200802_cqrs_init.sql | 2 +- ...13073740_cqrs_inventory_category_query.sql | 16 +---------- ...40713080804_cqrs_inventory_store_query.sql | 16 +---------- 16 files changed, 127 insertions(+), 137 deletions(-) rename .sqlx/{query-e66276ae53a3155b2a682a451bf4800f2ec7f777cc822cbe0866105def3e11af.json => query-2ca5f8ca1b3ac04175346c1d7e57a37ac4ccf493ebced9cf690f4030e78bd439.json} (50%) create mode 100644 .sqlx/query-2dbbf0eb4388333b57ad5bda586ada6797292064485b1f3ce342d7eb0cb3ccf4.json create mode 100644 .sqlx/query-48aa5f3eacaaec4a74ba5d2908875fcac797644d104d3d580715587ecb2e2119.json rename .sqlx/{query-4d7b12d7ff5e008054bab7aa61d6ba1f559293608196e540788947789cad244c.json => query-5385ba9531992b91670e52b5332af1f09069e1d6d168f9e93b729cf964e97c35.json} (82%) delete mode 100644 .sqlx/query-74313c3fbf8a5985b6deae21b56469fb66ddb078d016fd6f05cb5e62ef0b23d5.json rename .sqlx/{query-eb97288edbbbe8c5f30454040584a3e182ba5f4a303c142668956be3846c6d18.json => query-89ebb8b413db2c4da15adff8a09d04d5849c3990f0965de479b76630317f8a6e.json} (52%) create mode 100644 .sqlx/query-a392b3e1146beac19a37da465bf567aa41b8a7ef1fbdba42116d90aa000584b8.json create mode 100644 .sqlx/query-b84fb940a2aa673d3b19b2317e1e3436d3983e8a32400bbcefd91efb945190cd.json delete mode 100644 .sqlx/query-bb92f2d0c882653e92f2837353c1def62da1715c65214a4d404a5ce551c501bd.json delete mode 100644 .sqlx/query-c524c7fc3281e8ffe5d3d6f237d49cae596a9f621e6a64c31270d744406271ec.json delete mode 100644 .sqlx/query-c6e90aa1e4fc851ac37318ada15859bc6e2fb1a75da0ed248debf126ba39c1d1.json rename .sqlx/{query-1e9dcba9a2b5a7e0bbb2b8c0d87166c24567420c5f7579aaa12b9d3d60c4e24d.json => query-d396a3ccbe58a02acc0710700274eb3d28b2a1fe005190cd3599c2772dd01f7d.json} (81%) create mode 100644 .sqlx/query-fed365b25499b05fbeb73416310b4c5ee1d3beb6dda94290c80c5ae038894116.json diff --git a/.sqlx/query-e66276ae53a3155b2a682a451bf4800f2ec7f777cc822cbe0866105def3e11af.json b/.sqlx/query-2ca5f8ca1b3ac04175346c1d7e57a37ac4ccf493ebced9cf690f4030e78bd439.json similarity index 50% rename from .sqlx/query-e66276ae53a3155b2a682a451bf4800f2ec7f777cc822cbe0866105def3e11af.json rename to .sqlx/query-2ca5f8ca1b3ac04175346c1d7e57a37ac4ccf493ebced9cf690f4030e78bd439.json index 32f191e..afbefda 100644 --- a/.sqlx/query-e66276ae53a3155b2a682a451bf4800f2ec7f777cc822cbe0866105def3e11af.json +++ b/.sqlx/query-2ca5f8ca1b3ac04175346c1d7e57a37ac4ccf493ebced9cf690f4030e78bd439.json @@ -1,11 +1,10 @@ { "db_name": "PostgreSQL", - "query": "INSERT INTO cqrs_inventory_category_query (\n view_id, version, name, description, category_id, store_id\n ) VALUES (\n $1, $2, $3, $4, $5, $6\n );", + "query": "INSERT INTO cqrs_inventory_category_query (\n version, name, description, category_id, store_id\n ) VALUES (\n $1, $2, $3, $4, $5\n );", "describe": { "columns": [], "parameters": { "Left": [ - "Text", "Int8", "Text", "Text", @@ -15,5 +14,5 @@ }, "nullable": [] }, - "hash": "e66276ae53a3155b2a682a451bf4800f2ec7f777cc822cbe0866105def3e11af" + "hash": "2ca5f8ca1b3ac04175346c1d7e57a37ac4ccf493ebced9cf690f4030e78bd439" } diff --git a/.sqlx/query-2dbbf0eb4388333b57ad5bda586ada6797292064485b1f3ce342d7eb0cb3ccf4.json b/.sqlx/query-2dbbf0eb4388333b57ad5bda586ada6797292064485b1f3ce342d7eb0cb3ccf4.json new file mode 100644 index 0000000..0672f43 --- /dev/null +++ b/.sqlx/query-2dbbf0eb4388333b57ad5bda586ada6797292064485b1f3ce342d7eb0cb3ccf4.json @@ -0,0 +1,28 @@ +{ + "db_name": "PostgreSQL", + "query": "SELECT \n category_id, version\n FROM\n cqrs_inventory_category_query\n WHERE\n category_id = $1;", + "describe": { + "columns": [ + { + "ordinal": 0, + "name": "category_id", + "type_info": "Uuid" + }, + { + "ordinal": 1, + "name": "version", + "type_info": "Int8" + } + ], + "parameters": { + "Left": [ + "Uuid" + ] + }, + "nullable": [ + false, + false + ] + }, + "hash": "2dbbf0eb4388333b57ad5bda586ada6797292064485b1f3ce342d7eb0cb3ccf4" +} diff --git a/.sqlx/query-48aa5f3eacaaec4a74ba5d2908875fcac797644d104d3d580715587ecb2e2119.json b/.sqlx/query-48aa5f3eacaaec4a74ba5d2908875fcac797644d104d3d580715587ecb2e2119.json new file mode 100644 index 0000000..f4f37cf --- /dev/null +++ b/.sqlx/query-48aa5f3eacaaec4a74ba5d2908875fcac797644d104d3d580715587ecb2e2119.json @@ -0,0 +1,18 @@ +{ + "db_name": "PostgreSQL", + "query": "UPDATE\n cqrs_inventory_store_query\n SET\n version = $1,\n name = $2,\n address = $3,\n store_id = $4,\n owner = $5;", + "describe": { + "columns": [], + "parameters": { + "Left": [ + "Int8", + "Text", + "Text", + "Uuid", + "Text" + ] + }, + "nullable": [] + }, + "hash": "48aa5f3eacaaec4a74ba5d2908875fcac797644d104d3d580715587ecb2e2119" +} diff --git a/.sqlx/query-4d7b12d7ff5e008054bab7aa61d6ba1f559293608196e540788947789cad244c.json b/.sqlx/query-5385ba9531992b91670e52b5332af1f09069e1d6d168f9e93b729cf964e97c35.json similarity index 82% rename from .sqlx/query-4d7b12d7ff5e008054bab7aa61d6ba1f559293608196e540788947789cad244c.json rename to .sqlx/query-5385ba9531992b91670e52b5332af1f09069e1d6d168f9e93b729cf964e97c35.json index b15a991..c7ff970 100644 --- a/.sqlx/query-4d7b12d7ff5e008054bab7aa61d6ba1f559293608196e540788947789cad244c.json +++ b/.sqlx/query-5385ba9531992b91670e52b5332af1f09069e1d6d168f9e93b729cf964e97c35.json @@ -1,6 +1,6 @@ { "db_name": "PostgreSQL", - "query": "SELECT \n name, address, store_id, owner\n FROM\n cqrs_inventory_store_query\n WHERE\n view_id = $1;", + "query": "SELECT \n name, address, store_id, owner\n FROM\n cqrs_inventory_store_query\n WHERE\n store_id = $1;", "describe": { "columns": [ { @@ -26,7 +26,7 @@ ], "parameters": { "Left": [ - "Text" + "Uuid" ] }, "nullable": [ @@ -36,5 +36,5 @@ false ] }, - "hash": "4d7b12d7ff5e008054bab7aa61d6ba1f559293608196e540788947789cad244c" + "hash": "5385ba9531992b91670e52b5332af1f09069e1d6d168f9e93b729cf964e97c35" } diff --git a/.sqlx/query-74313c3fbf8a5985b6deae21b56469fb66ddb078d016fd6f05cb5e62ef0b23d5.json b/.sqlx/query-74313c3fbf8a5985b6deae21b56469fb66ddb078d016fd6f05cb5e62ef0b23d5.json deleted file mode 100644 index 7473eb6..0000000 --- a/.sqlx/query-74313c3fbf8a5985b6deae21b56469fb66ddb078d016fd6f05cb5e62ef0b23d5.json +++ /dev/null @@ -1,28 +0,0 @@ -{ - "db_name": "PostgreSQL", - "query": "SELECT \n view_id, version\n FROM\n cqrs_inventory_category_query\n WHERE\n view_id = $1;", - "describe": { - "columns": [ - { - "ordinal": 0, - "name": "view_id", - "type_info": "Text" - }, - { - "ordinal": 1, - "name": "version", - "type_info": "Int8" - } - ], - "parameters": { - "Left": [ - "Text" - ] - }, - "nullable": [ - false, - false - ] - }, - "hash": "74313c3fbf8a5985b6deae21b56469fb66ddb078d016fd6f05cb5e62ef0b23d5" -} diff --git a/.sqlx/query-eb97288edbbbe8c5f30454040584a3e182ba5f4a303c142668956be3846c6d18.json b/.sqlx/query-89ebb8b413db2c4da15adff8a09d04d5849c3990f0965de479b76630317f8a6e.json similarity index 52% rename from .sqlx/query-eb97288edbbbe8c5f30454040584a3e182ba5f4a303c142668956be3846c6d18.json rename to .sqlx/query-89ebb8b413db2c4da15adff8a09d04d5849c3990f0965de479b76630317f8a6e.json index 9aed436..5fe35f2 100644 --- a/.sqlx/query-eb97288edbbbe8c5f30454040584a3e182ba5f4a303c142668956be3846c6d18.json +++ b/.sqlx/query-89ebb8b413db2c4da15adff8a09d04d5849c3990f0965de479b76630317f8a6e.json @@ -1,11 +1,10 @@ { "db_name": "PostgreSQL", - "query": "INSERT INTO cqrs_inventory_store_query (\n view_id, version, name, address, store_id, owner\n ) VALUES (\n $1, $2, $3, $4, $5, $6\n );", + "query": "INSERT INTO cqrs_inventory_store_query (\n version, name, address, store_id, owner\n ) VALUES (\n $1, $2, $3, $4, $5\n );", "describe": { "columns": [], "parameters": { "Left": [ - "Text", "Int8", "Text", "Text", @@ -15,5 +14,5 @@ }, "nullable": [] }, - "hash": "eb97288edbbbe8c5f30454040584a3e182ba5f4a303c142668956be3846c6d18" + "hash": "89ebb8b413db2c4da15adff8a09d04d5849c3990f0965de479b76630317f8a6e" } diff --git a/.sqlx/query-a392b3e1146beac19a37da465bf567aa41b8a7ef1fbdba42116d90aa000584b8.json b/.sqlx/query-a392b3e1146beac19a37da465bf567aa41b8a7ef1fbdba42116d90aa000584b8.json new file mode 100644 index 0000000..925ab5b --- /dev/null +++ b/.sqlx/query-a392b3e1146beac19a37da465bf567aa41b8a7ef1fbdba42116d90aa000584b8.json @@ -0,0 +1,28 @@ +{ + "db_name": "PostgreSQL", + "query": "SELECT \n store_id, version\n FROM\n cqrs_inventory_store_query\n WHERE\n store_id = $1;", + "describe": { + "columns": [ + { + "ordinal": 0, + "name": "store_id", + "type_info": "Uuid" + }, + { + "ordinal": 1, + "name": "version", + "type_info": "Int8" + } + ], + "parameters": { + "Left": [ + "Uuid" + ] + }, + "nullable": [ + false, + false + ] + }, + "hash": "a392b3e1146beac19a37da465bf567aa41b8a7ef1fbdba42116d90aa000584b8" +} diff --git a/.sqlx/query-b84fb940a2aa673d3b19b2317e1e3436d3983e8a32400bbcefd91efb945190cd.json b/.sqlx/query-b84fb940a2aa673d3b19b2317e1e3436d3983e8a32400bbcefd91efb945190cd.json new file mode 100644 index 0000000..57a2ff3 --- /dev/null +++ b/.sqlx/query-b84fb940a2aa673d3b19b2317e1e3436d3983e8a32400bbcefd91efb945190cd.json @@ -0,0 +1,22 @@ +{ + "db_name": "PostgreSQL", + "query": "SELECT EXISTS (\n SELECT 1\n FROM cqrs_inventory_store_query\n WHERE\n name = $1\n );", + "describe": { + "columns": [ + { + "ordinal": 0, + "name": "exists", + "type_info": "Bool" + } + ], + "parameters": { + "Left": [ + "Text" + ] + }, + "nullable": [ + null + ] + }, + "hash": "b84fb940a2aa673d3b19b2317e1e3436d3983e8a32400bbcefd91efb945190cd" +} diff --git a/.sqlx/query-bb92f2d0c882653e92f2837353c1def62da1715c65214a4d404a5ce551c501bd.json b/.sqlx/query-bb92f2d0c882653e92f2837353c1def62da1715c65214a4d404a5ce551c501bd.json deleted file mode 100644 index e112a23..0000000 --- a/.sqlx/query-bb92f2d0c882653e92f2837353c1def62da1715c65214a4d404a5ce551c501bd.json +++ /dev/null @@ -1,19 +0,0 @@ -{ - "db_name": "PostgreSQL", - "query": "UPDATE\n cqrs_inventory_store_query\n SET\n view_id = $1,\n version = $2,\n name = $3,\n address = $4,\n store_id = $5,\n owner = $6;", - "describe": { - "columns": [], - "parameters": { - "Left": [ - "Text", - "Int8", - "Text", - "Text", - "Uuid", - "Text" - ] - }, - "nullable": [] - }, - "hash": "bb92f2d0c882653e92f2837353c1def62da1715c65214a4d404a5ce551c501bd" -} diff --git a/.sqlx/query-c524c7fc3281e8ffe5d3d6f237d49cae596a9f621e6a64c31270d744406271ec.json b/.sqlx/query-c524c7fc3281e8ffe5d3d6f237d49cae596a9f621e6a64c31270d744406271ec.json deleted file mode 100644 index f5b81b5..0000000 --- a/.sqlx/query-c524c7fc3281e8ffe5d3d6f237d49cae596a9f621e6a64c31270d744406271ec.json +++ /dev/null @@ -1,19 +0,0 @@ -{ - "db_name": "PostgreSQL", - "query": "UPDATE\n cqrs_inventory_category_query\n SET\n view_id = $1,\n version = $2,\n name = $3,\n description = $4,\n category_id = $5,\n store_id = $6;", - "describe": { - "columns": [], - "parameters": { - "Left": [ - "Text", - "Int8", - "Text", - "Text", - "Uuid", - "Uuid" - ] - }, - "nullable": [] - }, - "hash": "c524c7fc3281e8ffe5d3d6f237d49cae596a9f621e6a64c31270d744406271ec" -} diff --git a/.sqlx/query-c6e90aa1e4fc851ac37318ada15859bc6e2fb1a75da0ed248debf126ba39c1d1.json b/.sqlx/query-c6e90aa1e4fc851ac37318ada15859bc6e2fb1a75da0ed248debf126ba39c1d1.json deleted file mode 100644 index cb8771e..0000000 --- a/.sqlx/query-c6e90aa1e4fc851ac37318ada15859bc6e2fb1a75da0ed248debf126ba39c1d1.json +++ /dev/null @@ -1,28 +0,0 @@ -{ - "db_name": "PostgreSQL", - "query": "SELECT \n view_id, version\n FROM\n cqrs_inventory_store_query\n WHERE\n view_id = $1;", - "describe": { - "columns": [ - { - "ordinal": 0, - "name": "view_id", - "type_info": "Text" - }, - { - "ordinal": 1, - "name": "version", - "type_info": "Int8" - } - ], - "parameters": { - "Left": [ - "Text" - ] - }, - "nullable": [ - false, - false - ] - }, - "hash": "c6e90aa1e4fc851ac37318ada15859bc6e2fb1a75da0ed248debf126ba39c1d1" -} diff --git a/.sqlx/query-1e9dcba9a2b5a7e0bbb2b8c0d87166c24567420c5f7579aaa12b9d3d60c4e24d.json b/.sqlx/query-d396a3ccbe58a02acc0710700274eb3d28b2a1fe005190cd3599c2772dd01f7d.json similarity index 81% rename from .sqlx/query-1e9dcba9a2b5a7e0bbb2b8c0d87166c24567420c5f7579aaa12b9d3d60c4e24d.json rename to .sqlx/query-d396a3ccbe58a02acc0710700274eb3d28b2a1fe005190cd3599c2772dd01f7d.json index f4413b8..26e15b0 100644 --- a/.sqlx/query-1e9dcba9a2b5a7e0bbb2b8c0d87166c24567420c5f7579aaa12b9d3d60c4e24d.json +++ b/.sqlx/query-d396a3ccbe58a02acc0710700274eb3d28b2a1fe005190cd3599c2772dd01f7d.json @@ -1,6 +1,6 @@ { "db_name": "PostgreSQL", - "query": "SELECT \n name, description, category_id, store_id\n FROM\n cqrs_inventory_category_query\n WHERE\n view_id = $1;", + "query": "SELECT \n name, description, category_id, store_id\n FROM\n cqrs_inventory_category_query\n WHERE\n category_id = $1;", "describe": { "columns": [ { @@ -26,7 +26,7 @@ ], "parameters": { "Left": [ - "Text" + "Uuid" ] }, "nullable": [ @@ -36,5 +36,5 @@ false ] }, - "hash": "1e9dcba9a2b5a7e0bbb2b8c0d87166c24567420c5f7579aaa12b9d3d60c4e24d" + "hash": "d396a3ccbe58a02acc0710700274eb3d28b2a1fe005190cd3599c2772dd01f7d" } diff --git a/.sqlx/query-fed365b25499b05fbeb73416310b4c5ee1d3beb6dda94290c80c5ae038894116.json b/.sqlx/query-fed365b25499b05fbeb73416310b4c5ee1d3beb6dda94290c80c5ae038894116.json new file mode 100644 index 0000000..8419d01 --- /dev/null +++ b/.sqlx/query-fed365b25499b05fbeb73416310b4c5ee1d3beb6dda94290c80c5ae038894116.json @@ -0,0 +1,18 @@ +{ + "db_name": "PostgreSQL", + "query": "UPDATE\n cqrs_inventory_category_query\n SET\n version = $1,\n name = $2,\n description = $3,\n category_id = $4,\n store_id = $5;", + "describe": { + "columns": [], + "parameters": { + "Left": [ + "Int8", + "Text", + "Text", + "Uuid", + "Uuid" + ] + }, + "nullable": [] + }, + "hash": "fed365b25499b05fbeb73416310b4c5ee1d3beb6dda94290c80c5ae038894116" +} diff --git a/migrations/20240516200802_cqrs_init.sql b/migrations/20240516200802_cqrs_init.sql index e52ff9e..edeff0f 100644 --- a/migrations/20240516200802_cqrs_init.sql +++ b/migrations/20240516200802_cqrs_init.sql @@ -2,7 +2,7 @@ -- -- SPDX-License-Identifier: AGPL-3.0-or-later -CREATE TABLE IF NOT EXISTS user_events +CREATE TABLE IF NOT EXISTS events ( aggregate_type text NOT NULL, aggregate_id text NOT NULL, diff --git a/migrations/20240713073740_cqrs_inventory_category_query.sql b/migrations/20240713073740_cqrs_inventory_category_query.sql index 95398df..e6d9dd2 100644 --- a/migrations/20240713073740_cqrs_inventory_category_query.sql +++ b/migrations/20240713073740_cqrs_inventory_category_query.sql @@ -2,22 +2,8 @@ -- -- SPDX-License-Identifier: AGPL-3.0-or-later -CREATE TABLE IF NOT EXISTS categoty_events -( - aggregate_type text NOT NULL, - aggregate_id text NOT NULL, - sequence bigint CHECK (sequence >= 0) NOT NULL, - event_type text NOT NULL, - event_version text NOT NULL, - payload json NOT NULL, - metadata json NOT NULL, - timestamp timestamp with time zone DEFAULT (CURRENT_TIMESTAMP), - PRIMARY KEY (aggregate_type, aggregate_id, sequence) -); - CREATE TABLE IF NOT EXISTS cqrs_inventory_category_query ( - view_id text NOT NULL, version bigint CHECK (version >= 0) NOT NULL, name TEXT NOT NULL, @@ -27,7 +13,7 @@ CREATE TABLE IF NOT EXISTS cqrs_inventory_category_query category_id UUID NOT NULL UNIQUE, UNIQUE(store_id, name), - PRIMARY KEY (view_id) + PRIMARY KEY (category_id) ); CREATE UNIQUE INDEX IF NOT EXISTS diff --git a/migrations/20240713080804_cqrs_inventory_store_query.sql b/migrations/20240713080804_cqrs_inventory_store_query.sql index 3d2d7b9..2701498 100644 --- a/migrations/20240713080804_cqrs_inventory_store_query.sql +++ b/migrations/20240713080804_cqrs_inventory_store_query.sql @@ -2,22 +2,8 @@ -- -- SPDX-License-Identifier: AGPL-3.0-or-later -CREATE TABLE IF NOT EXISTS categoty_events -( - aggregate_type text NOT NULL, - aggregate_id text NOT NULL, - sequence bigint CHECK (sequence >= 0) NOT NULL, - event_type text NOT NULL, - event_version text NOT NULL, - payload json NOT NULL, - metadata json NOT NULL, - timestamp timestamp with time zone DEFAULT (CURRENT_TIMESTAMP), - PRIMARY KEY (aggregate_type, aggregate_id, sequence) -); - CREATE TABLE IF NOT EXISTS cqrs_inventory_store_query ( - view_id text NOT NULL, version bigint CHECK (version >= 0) NOT NULL, name TEXT NOT NULL, @@ -26,7 +12,7 @@ CREATE TABLE IF NOT EXISTS cqrs_inventory_store_query store_id UUID NOT NULL UNIQUE, deleted BOOLEAN NOT NULL DEFAULT FALSE, - PRIMARY KEY (view_id) + PRIMARY KEY (store_id) ); CREATE UNIQUE INDEX IF NOT EXISTS store_store_id_index ON cqrs_inventory_store_query (store_id);