We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents b6bd734 + 2259ec4 commit 6ed4a28Copy full SHA for 6ed4a28
1 file changed
lib/mongo_ecto/connection.ex
@@ -237,12 +237,18 @@ defmodule Mongo.Ecto.Connection do
237
["REPLACE", format_part("coll", coll), format_part("filter", filter),
238
format_part("document", doc)]
239
end
240
- defp format_query(%Query{action: :find_rest, extra: coll}, [cursor]) do
+ defp format_query(%Query{action: :get_more, extra: coll}, [cursor]) do
241
["GET_MORE", format_part("coll", coll), format_part("cursor_id", cursor)]
242
243
+ defp format_query(%Query{action: :get_more, extra: coll}, []) do
244
+ ["GET_MORE", format_part("coll", coll), format_part("cursor_id", "")]
245
+ end
246
defp format_query(%Query{action: :kill_cursors, extra: coll}, [cursors]) do
247
["KILL_CURSORS", format_part("cursor_ids", cursors)]
248
249
+ defp format_query(%Query{action: :kill_cursors, extra: coll}, []) do
250
+ ["KILL_CURSORS", format_part("cursor_ids", "")]
251
252
253
defp format_part(name, value) do
254
[" ", name, "=" | inspect(value)]
0 commit comments