jesspanni

/// <summary>
/// A client for submitting queries to Snowflake.
/// </summary>
public class SnowflakeClient
{
    private readonly string connectionString;

    /// <summary>
    /// Initializes a new instance of the <see cref="SnowflakeClient"/> class.
    /// </summary>

jesspanni

public static class SnowflakeClientExtensions
{
    /// <summary>
    /// Instructs Snowflake to load data from a stage into a target table.
    /// </summary>
    public static int Load(this SnowflakeClient client, string stage, string targetTable, string[] files = null, string warehouse = null, string database = null, string schema = null, bool force = false)
    {
        IList<string> commands = DefineSnowflakeQueryContext(warehouse, database, schema);
        commands.Add(LoadSnowflakeCommand(stage, targetTable, files, force));
        return client.ExecuteNonQuery(commands.ToArray());

jesspanni

USE DATABASE SALES;
USE SCHEMA SALES;

SELECT * FROM LINEITEMS;

jesspanni

public static class SnowflakeClientExtensions
{
    /// <summary>
    /// Instructs Snowflake to load data from a stage into a target table.
    /// </summary>       
    public static int Load(this SnowflakeClient client, string stage, string targetTable, string[] files = null, string warehouse = null, string database = null, string schema = null, bool force = false)
    {
        IList<string> commands = DefineSnowflakeQueryContext(warehouse, database, schema);
        commands.Add(LoadSnowflakeCommand(stage, targetTable, files, force));
        return client.ExecuteNonQuery(commands.ToArray());

jesspanni

public class UnloadCommand
{
    public string Database { get; set; }
    public string Schema { get; set; }
    public string Warehouse { get; set; }
    public string Stage { get; set; }
    public string Query { get; set; }
    public string FilePrefix { get; set; }
    public bool SingleFile { get; set; }
    public bool Overwrite { get; set; }

jesspanni

public class LoadCommand
{
    public string Database { get; set; }
    public string Schema { get; set; }
    public string Warehouse { get; set; }
    public string Stage { get; set; }
    public string TargetTable { get; set; }
    public string[] Files { get; set; }
    public bool Force { get; set; }

jesspanni

[FunctionName("Load")]
public static async Task<HttpResponseMessage> Run(
    [HttpTrigger(AuthorizationLevel.Function, "post", Route = "v1/load")]
    HttpRequestMessage req,
    ILogger logger,
    ExecutionContext context)
{
    ServiceProvider serviceProvider = Initializer.Initialize(context);

    string body = await req.Content.ReadAsStringAsync().ConfigureAwait(false);

jesspanni

public static async Task<HttpResponseMessage> Run(
    [HttpTrigger(AuthorizationLevel.Function, "post", Route = "v1/unload")]
    HttpRequestMessage req,
    ILogger logger,
    ExecutionContext context)
{
    ServiceProvider serviceProvider = Initializer.Initialize(context);

    string body = await req.Content.ReadAsStringAsync().ConfigureAwait(false);
    UnloadCommand command = JsonConvert.DeserializeObject<UnloadCommand>(body);

jesspanni

CREATE DATABASE IF NOT EXISTS "ADF-DB";

USE DATABASE "ADF-DB";

CREATE SCHEMA IF NOT EXISTS "SALES";

USE SCHEMA "SALES";

CREATE TABLE IF NOT EXISTS LINEITEM (
	L_ORDERKEY NUMBER(38,0),

jesspanni