-
Notifications
You must be signed in to change notification settings - Fork 225
/
V1.1.0__initial_database_objects.sql
55 lines (49 loc) · 1.29 KB
/
V1.1.0__initial_database_objects.sql
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
52
53
54
55
-- Use Demo Database if it doesn't exist
use database {{ database_name }};
use schema {{ schema_name }};
-- Create the file formats
CREATE OR REPLACE FILE FORMAT CSV_NO_HEADER
TYPE='CSV'
COMPRESSION = 'AUTO'
FIELD_DELIMITER = ','
SKIP_HEADER = 0
FIELD_OPTIONALLY_ENCLOSED_BY = '"'
NULL_IF = ('NULL','\\N','\N', '');
CREATE OR REPLACE FILE FORMAT JSON
TYPE='JSON'
COMPRESSION = 'AUTO'
ENABLE_OCTAL = FALSE
ALLOW_DUPLICATE = FALSE
STRIP_OUTER_ARRAY = FALSE
STRIP_NULL_VALUES = FALSE
IGNORE_UTF8_ERRORS = FALSE;
-- Create the stages
CREATE OR REPLACE STAGE TRIPS
URL = 's3://snowflake-workshop-lab/citibike-trips';
CREATE OR REPLACE STAGE WEATHER
URL = 's3://snowflake-workshop-lab/weather-nyc';
-- Create the tables
CREATE OR REPLACE TABLE TRIPS
(
TRIPDURATION INTEGER
,STARTTIME TIMESTAMP
,STOPTIME TIMESTAMP
,START_STATION_ID INTEGER
,START_STATION_NAME STRING
,START_STATION_LATITUDE FLOAT
,START_STATION_LONGITUDE FLOAT
,END_STATION_ID INTEGER
,END_STATION_NAME STRING
,END_STATION_LATITUDE FLOAT
,END_STATION_LONGITUDE FLOAT
,BIKEID INTEGER
,MEMBERSHIP_TYPE STRING
,USERTYPE STRING
,BIRTH_YEAR INTEGER
,GENDER INTEGER
);
CREATE OR REPLACE TABLE WEATHER
(
V VARIANT
,T TIMESTAMP
);