/
queries.py
51 lines (39 loc) · 1.07 KB
/
queries.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
USERS_INFO_TABLE_PATH = "user_personal_info"
STATES_TABLE_PATH = "states"
get_user_state = f"""
DECLARE $user_id AS Uint64;
SELECT state
FROM `{STATES_TABLE_PATH}`
WHERE user_id == $user_id;
"""
set_user_state = f"""
DECLARE $user_id AS Uint64;
DECLARE $state AS Utf8?;
UPSERT INTO `{STATES_TABLE_PATH}` (`user_id`, `state`)
VALUES ($user_id, $state);
"""
get_user_info = f"""
DECLARE $user_id AS Int64;
SELECT
user_id,
age,
first_name,
last_name
FROM `{USERS_INFO_TABLE_PATH}`
WHERE user_id == $user_id;
"""
add_user_info = f"""
DECLARE $user_id AS Uint64;
DECLARE $first_name AS Utf8;
DECLARE $last_name AS Utf8;
DECLARE $age AS Uint64;
INSERT INTO `{USERS_INFO_TABLE_PATH}` (user_id, first_name, last_name, age)
VALUES ($user_id, $first_name, $last_name, $age);
"""
delete_user_info = f"""
DECLARE $user_id AS Uint64;
DELETE FROM `{USERS_INFO_TABLE_PATH}`
WHERE user_id == $user_id;
DELETE FROM `{STATES_TABLE_PATH}`
WHERE user_id == $user_id;
"""