emilegill743

# Connecting to Snowflake
import snowflake.connector

ctx = snowflake.connector.connect(
          user='emilegill',
          password='XXXX',
          account='XXXX')
cs = ctx.cursor()

try:

emilegill743

-- Load data into table
copy into worldwide_cases
    from @test_db.public.test_stage
    file_format = (
        type = csv
        skip_header=1
        error_on_column_count_mismatch = false
        field_optionally_enclosed_by='"');

emilegill743

-- List files in stage
ls @test_db.public.test_stage;

emilegill743

put file://C:\Users\emile\OneDrive\Documents\GitHub\snowflake-basics\ecdc_covid_cases.csv @test_db.public.test_stage;

emilegill743

-- Create Internal Stage
create or replace stage test_stage;

emilegill743

-- Create External Stage
create or replace stage test_external_stage
    url = 's3://<bucket>[/<path>/]'
    credentials = (aws_key_id='XXXX' aws_secret_key='XXXX');

emilegill743

-- Create Table
create or replace table worldwide_cases (
    date_rep string,
    day string,
    month string,
    year string,
    cases number,
    deaths number,
    countries_and_territories string,
    geo_id string,

emilegill743

-- Check current context
select current_warehouse(), current_database(), current_schema()

emilegill743

-- Create Database
create or replace database test_db;

emilegill743

-- Create Virtual Warehouse
create or replace warehouse test_wh with
    warehouse_size="X-SMALL"
    auto_suspend=180
    auto_resume=true
    initially_suspended=true;