Packages

mssqlex

0.1.0
2.0.0-beta.0 1.1.0 1.0.0 0.8.0 0.7.0 0.6.7 0.6.6 0.6.5 0.6.4 0.6.3 0.6.2 0.6.1 0.6.0 0.5.4 0.5.3 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.0 0.1.1 0.1.0 0.0.10 0.0.9 0.0.8 0.0.7 0.0.6 0.0.5 0.0.4 0.0.3 0.0.2 0.0.1

Adapter to Microsoft SQL Server. Using DBConnection and ODBC.

HexDocs

Current section

Files

Jump to
Readme
41 Versions
2 Dependencies
Dependants
Files
Activity
mssqlex lib mssqlex query.ex
Raw

lib/mssqlex/query.ex 

defmodule Mssqlex.Query do

  @moduledoc """

  Implementation of `DBConnection.Query` for `Mssqlex`.



  The structure is:

    * `name` - currently not used.

    * `statement` - SQL statement to run using `:odbc`.

  """



  @type t :: %__MODULE__{

    name: iodata,

    statement: iodata,

  }



  defstruct [:name, :statement]

end



defimpl DBConnection.Query, for: Mssqlex.Query do

  alias Mssqlex.Query

  alias Mssqlex.Result

  alias Mssqlex.Type



  @spec parse(query :: Query.t(), opts :: Keyword.t()) :: Query.t()

  def parse(query, _opts), do: query



  @spec describe(query :: Query.t(), opts :: Keyword.t()) :: Query.t()

  def describe(query, _opts), do: query



  @spec encode(query :: Query.t(),

    params :: [Type.param()], opts :: Keyword.t()) :: [Type.param()]

  def encode(_query, params, opts) do

    Enum.map(params, &(Type.encode(&1, opts)))

  end



  @spec decode(query :: Query.t(), result :: Result.t(), opts :: Keyword.t()) ::

    Result.t()

  def decode(_query, %Result{rows: rows} = result, opts) when not is_nil(rows) do

    Map.put(result, :rows, Enum.map(rows, fn row -> Enum.map(row, &(Type.decode(&1, opts))) end))

  end

  def decode(_query, result, _opts), do: result

end



defimpl String.Chars, for: Mssqlex.Query do

  def to_string(%Mssqlex.Query{statement: statement}) do

    IO.iodata_to_binary(statement)

  end

end