from snowflake.connector.cursor import SnowflakeCursor

from app.functions.read_from_sql import read_from_sql
from utils.connection import connect

import uuid


def main() -> None:
    # Establecer la conexión
    ctx = connect()
    cur = ctx.cursor()
    data = {
        'ID': ['1'],
        'NAME': ['test1'],
        'GLOBAL_PARTICIPANT_ID': [str(uuid.uuid4())],
        'VENDOR_ID': [123212],
        'SUBACCOUNT_ID': [123],
        'CREATED_AT': ['2022-02-02']
    }
    #write(ctx, data, 'SONGWHIP_PRESAVE_PAGE_DBT')
    print(read_from_sql(cur, "SELECT * FROM SONGWHIP_PRESAVE_PAGE_DBT;"))
    #read_from_file(cur)


main()