Транзации p2p

Author: Jardinesdelareina

databases/datafarm/src/data/init.sql

@@ -141,6 +141,7 @@ CREATE TABLE p2p.wallets
 (
     fk_user_owner service.valid_email REFERENCES profile.users(email),
     fk_currency VARCHAR(6) REFERENCES p2p.exchange_currencies(ticker),
+    is_deleted BOOLEAN DEFAULT FALSE,
     balance NUMERIC DEFAULT 0
 );
 
@@ -399,6 +400,27 @@ END;
 $$ LANGUAGE plpgsql;
 
 
+-- Создание счета
+CREATE OR REPLACE PROCEDURE p2p.create_wallet(
+    input_user_owner service.valid_email,
+    input_currency VARCHAR(6)
+) AS $$
+    INSERT INTO p2p.wallets(fk_user_owner, fk_currency)
+    VALUES(input_user_owner, input_currency);
+$$ LANGUAGE sql;
+
+
+-- Удаление счета
+CREATE OR REPLACE PROCEDURE p2p.delete_wallet(
+    input_user_owner service.valid_email,
+    input_currency VARCHAR(6)
+) AS $$
+    UPDATE p2p.wallets
+    SET is_deleted = TRUE
+    WHERE fk_user_owner = input_user_owner AND fk_currency = input_currency;
+$$ LANGUAGE sql;
+
+
 -- Добавление платежного способа
 CREATE OR REPLACE PROCEDURE p2p.create_payment(
     input_emitent VARCHAR(50),

databases/datafarm/src/data/test_p2p.sql

@@ -1,7 +1,17 @@
 CALL profile.create_user('[email protected]', '1234');
 CALL profile.create_user('[email protected]', '1234');
-CALL p2p.create_offer('BUY', 'btc', 5, 3, NULL, 'Comment', '[email protected]');
-CALL p2p.create_deal(4, 1, '[email protected]');
-CALL p2p.create_deal(1, 1, '[email protected]');
+--CALL p2p.create_offer('BUY', 'btc', 5, 3, NULL, 'Comment', '[email protected]');
+--CALL p2p.create_deal(4, 1, '[email protected]');
+--CALL p2p.create_deal(1, 1, '[email protected]');
 --CALL p2p.check_deal_time('7100bacd-20a2-462b-9c4d-86ac8558e6df');
---CALL p2p.deal_payment(1, 'cc23797a-12ea-4d68-90d8-e0b34f687a5f');
+--CALL p2p.deal_payment(1, 'cc23797a-12ea-4d68-90d8-e0b34f687a5f');
+CALL p2p.create_wallet('[email protected]', 'BTC');
+CALL p2p.create_wallet('[email protected]', 'BTC');
+
+
+UPDATE p2p.wallets
+SET balance = 100
+WHERE fk_user_owner = '[email protected]' AND fk_currency = 'BTC';
+
+
+CALL p2p.create_p2p_transaction('[email protected]', '[email protected]', 'BTC', 50);

dba/QUERIES.md

@@ -24,15 +24,15 @@ WHERE spcname<>'pg_global';
 Суммарный размер всех таблиц, суммарный размер всех индексов, общий суммарный размер схемы и суммарное количество строк во всех таблицах схемы.
 ```sql
 SELECT A.schemaname,
-       pg_size_pretty (SUM(pg_relation_size(C.oid))) as table, 
-       pg_size_pretty (SUM(pg_total_relation_size(C.oid)-pg_relation_size(C.oid))) as index, 
-       pg_size_pretty (SUM(pg_total_relation_size(C.oid))) as table_index,
+       pg_size_pretty(SUM(pg_relation_size(C.oid))) as table, 
+       pg_size_pretty(SUM(pg_total_relation_size(C.oid)-pg_relation_size(C.oid))) as index, 
+       pg_size_pretty(SUM(pg_total_relation_size(C.oid))) as table_index,
        SUM(n_live_tup)
 FROM pg_class C
 LEFT JOIN pg_namespace N ON (N.oid = C .relnamespace)
 INNER JOIN pg_stat_user_tables A ON C.relname = A.relname
 WHERE nspname NOT IN ('pg_catalog', 'information_schema')
-AND C .relkind <> 'i'
+AND C.relkind <> 'i'
 AND nspname !~ '^pg_toast'
 GROUP BY A.schemaname;
 ```
@@ -44,9 +44,9 @@ GROUP BY A.schemaname;
 ```sql
 SELECT schemaname,
        C.relname AS relation,
-       pg_size_pretty (pg_relation_size(C.oid)) as table,
-       pg_size_pretty (pg_total_relation_size (C.oid)-pg_relation_size(C.oid)) as index,
-       pg_size_pretty (pg_total_relation_size (C.oid)) as table_index,
+       pg_size_pretty(pg_relation_size(C.oid)) as table,
+       pg_size_pretty(pg_total_relation_size (C.oid)-pg_relation_size(C.oid)) as index,
+       pg_size_pretty(pg_total_relation_size (C.oid)) as table_index,
        n_live_tup
 FROM pg_class C
 LEFT JOIN pg_namespace N ON (N.oid = C .relnamespace)
@@ -98,13 +98,13 @@ SELECT pg_terminate_backend(PID_ID);
 
 ### Доля кэшированных данных в таблицах
 
-Какая доля каких таблиц закеширована (и насколько активно используются эти данные).
+Какая доля каких таблиц закеширована (и насколько активно используются эти данные). Модуль `pg_buffercache`.
 
 ```sql
 SELECT c.relname,
   count(*) blocks,
-  round( 100.0 * 8192 * count(*) / pg_table_size(c.oid) ) "% of rel",
-  round( 100.0 * 8192 * count(*) FILTER (WHERE b.usagecount > 3) / pg_table_size(c.oid) ) "% hot"
+  round(100.0 * 8192 * count(*) / pg_table_size(c.oid)) "% of rel",
+  round(100.0 * 8192 * count(*) FILTER (WHERE b.usagecount > 3) / pg_table_size(c.oid)) "% hot"
 FROM pg_buffercache b
   JOIN pg_class c ON pg_relation_filenode(c.oid) = b.relfilenode
 WHERE  b.reldatabase IN (