-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathsql_queries.py
51 lines (34 loc) · 2.5 KB
/
sql_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
# DROP TABLES
songplay_table_drop = " DROP TABLE IF EXISTS songplays "
user_table_drop = " DROP TABLE IF EXISTS users "
song_table_drop = " DROP TABLE IF EXISTS songs "
artist_table_drop = " DROP TABLE IF EXISTS artists "
time_table_drop = " DROP TABLE IF EXISTS time "
# CREATE TABLES
songplay_table_create = (""" CREATE TABLE IF NOT EXISTS songplays (songplay_id SERIAL, start_time timestamp NOT NULL, user_id int NOT NULL, level varchar, song_id varchar, artist_id varchar, session_id int, location varchar, user_agent varchar, PRIMARY KEY(songplay_id));
""")
user_table_create = ("""CREATE TABLE IF NOT EXISTS users (user_id int, first_name varchar, last_name varchar, gender varchar, level varchar, PRIMARY KEY(user_id));
""")
song_table_create = ("""CREATE TABLE IF NOT EXISTS songs (song_id varchar, title varchar, artist_id varchar, year int, duration numeric, PRIMARY KEY(song_id));
""")
artist_table_create = ("""CREATE TABLE IF NOT EXISTS artists (artist_id varchar, name varchar, location varchar, latitude numeric, longitude numeric, PRIMARY KEY(artist_id));
""")
time_table_create = ("""CREATE TABLE IF NOT EXISTS time (start_time timestamp, hour int, day int, week int, month int, year int, weekday int, PRIMARY KEY(start_time));
""")
# INSERT RECORDS
songplay_table_insert = (""" INSERT INTO songplays(songplay_id, start_time, user_id, level, song_id, artist_id, session_id, location, user_agent) VALUES (%s,%s,%s,%s,%s,%s,%s,%s,%s) ON CONFLICT (songplay_id) DO NOTHING
""")
user_table_insert = (""" INSERT INTO users(user_id, first_name, last_name, gender, level) VALUES (%s,%s,%s,%s,%s) ON CONFLICT (user_id) DO NOTHING
""")
song_table_insert = (""" INSERT INTO songs(song_id, title, artist_id, year, duration) VALUES (%s,%s,%s,%s,%s) ON CONFLICT (song_id) DO NOTHING
""")
artist_table_insert = (""" INSERT INTO artists(artist_id, name, location, latitude, longitude) VALUES (%s,%s,%s,%s,%s) ON CONFLICT (artist_id) DO NOTHING
""")
time_table_insert = (""" INSERT INTO time(start_time, hour, day, week, month, year, weekday) VALUES (%s,%s,%s,%s,%s,%s,%s) ON CONFLICT (start_time) DO NOTHING
""")
# FIND SONGS
song_select = (""" SELECT song_id, songs.artist_id FROM songs JOIN artists ON songs.artist_id = artists.artist_id WHERE title = %s AND name = %s AND duration = %s
""")
# QUERY LISTS
create_table_queries = [songplay_table_create, user_table_create, song_table_create, artist_table_create, time_table_create]
drop_table_queries = [songplay_table_drop, user_table_drop, song_table_drop, artist_table_drop, time_table_drop]