Packages

snowflex

0.0.1
1.6.0 1.5.0 1.4.1 1.4.0 1.3.1 1.3.0 1.2.1 1.2.0 1.1.0 1.0.5 1.0.4 1.0.3 1.0.2 1.0.1 1.0.0 0.5.2 0.5.1 0.5.0 0.4.5 0.4.4 0.4.3 0.4.2 0.4.1 0.4.0 0.3.3 0.3.2 0.3.1 0.3.0 0.2.2 0.2.1 0.2.0 0.1.1 0.1.0 0.0.4 0.0.3 0.0.2 0.0.1

The client interface for connecting to the Snowflake data warehouse.

HexDocs

Current section

Files

Jump to
Readme
37 Versions
3 Dependencies
Dependants
Files
Activity
snowflex lib snowflex query.ex
Raw

lib/snowflex/query.ex 

defmodule Snowflex.Query do

  @moduledoc false

  import Ecto.Changeset



  defmacro __using__(_opts) do

    quote do

      import Snowflex.Query

    end

  end



  defmacro snowflake_query(query) do

    quote do

      def sql_query, do: unquote(query)



      def execute_query do

        sql_query(sql_query())

      end



      def execute_query(binding_params) do

        param_query(sql_query(), binding_params)

      end

    end

  end



  def cast_results(data, schema) do

    Enum.map(data, &cast_row(&1, schema))

  end



  def int_param(val), do: {:sql_integer, val}

  def string_param(val, length \\ 250), do: {{:sql_varchar, length}, val}



  def sql_query(query, post_process \\ fn x -> x end) do

    case Snowflex.sql_query(query) do

      {:error, err} -> {:error, err}

      results -> results |> post_process.()

    end

  end



  def param_query(query, params, post_process \\ fn x -> x end) do

    case Snowflex.param_query(query, params) do

      {:error, err} -> {:error, err}

      results -> results |> post_process.()

    end

  end



  defp cast_row(row, schema) do

    schema

    |> struct()

    |> cast(row, schema.__schema__(:fields))

    |> apply_changes()

  end

end