Packages

mongodb_driver

0.5.0
1.6.3 1.6.2 1.6.1 1.6.0 1.5.6 1.5.5 1.5.4 1.5.2 1.5.1 1.5.0 1.4.1 1.4.0 1.2.1 1.2.0 1.1.0 1.0.3 1.0.2 1.0.1 1.0.0 0.9.2 0.9.1 0.9.0 0.9.0-rc.1 0.9.0-rc.0 0.8.4 0.8.3 0.8.2 0.8.1 0.8.0 0.7.4 0.7.3 0.7.2 0.7.1 0.7.0 0.6.5 0.6.4 0.6.3 0.6.2 0.6.1 0.6.0 0.5.7 0.5.6 0.5.5 0.5.4 0.5.3 0.5.2 0.5.1 0.5.0

The MongoDB driver for Elixir

HexDocs

Current section

Files

Jump to
Readme
48 Versions
3 Dependencies
Dependants
Files
Activity
mongodb_driver lib mongo query.ex
Raw

lib/mongo/query.ex 

defmodule Mongo.Query do

  @moduledoc false



  defstruct action: nil, extra: nil, encoded?: false

end



defimpl DBConnection.Query, for: Mongo.Query do

  import Mongo.Messages, only: [op_reply: 1, op_reply: 2]



  def parse(query, _opts), do: query

  def describe(query, _opts), do: query



  def encode(query, params, _opts) do

    if query.encoded? do

      params

    else

      Enum.map(params, fn

        nil -> ""

        doc -> BSON.Encoder.document(doc)

      end)

    end

  end



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

  def decode(_query, wire_version, _opts) when is_integer(wire_version), do: wire_version

  def decode(_query, op_reply(docs: docs) = reply, _opts), do: op_reply(reply, docs: BSON.Decoder.documents(docs))

end