Hello, I was wondering If this supported latest mongo version ? such as 4.2 or 4.4 ?
chaichai
zookzook
zookzook
The new version 0.8.0 has been released.
- supports MongoDB versions 3.2, 3.4, 3.6, 4.x, 5.x
- replica set connection: faster topology update if the primary is down (thanks to p-mongo)
- added custom
Mongo.Encoderprotocol (thanks to esse) - added collection from yildun project
- fixed an issue that the bulk operation does not stop after any insert/update/delete failed (thanks to ja-jimenez)
1
karthichamp99
How to use aggregation in your driver?
i tried this
Mongo.aggregate(:mongo, "customer", %{"$group" => %{ "_id" => "$cust_id", "total" => %{ "$sum" => "$amount"}}})
but it returns following struct instead of actual records.
%Mongo.Cursor{
cmd: [
aggregate: "customer",
pipeline: %{
"$group" => %{"_id" => "$cust_id", "total" => %{"$sum" => "$amount"}}
},
cursor: %{}
],
on_resume_token: nil,
opts: [],
topology_pid: :mongo
}
0
zookzook
The result is a cursor. You can stream or “enum” the cursor like this:
cursor = Mongo.aggregate(:mongo, "customer", %{"$group" => %{ "_id" => "$cust_id", "total" => %{ "$sum" => "$amount"}}})
cursor
|> Enum.to_list()
|> IO.inspect
0
karthichamp99
but i got the following error
# 1
{:error,
%Mongo.Error{
code: 14,
host: nil,
message: "'pipeline' option must be specified as an array"
}}
but this solved it wrapping the group statement inside an array solved it
0
karthichamp99
found it .
cursor = Mongo.aggregate(:mongo, "sales_dtl", [%{"$lookup" => %{"from" => "target_dtl", "localField" => "Finyr", "foreignField" => "Finyr", "as" => "fFinyr"}}], limit: 1)
cursor |> Enumto_list
1
zookzook
The new version 0.8.1 has been released.
Enhancements:
- Fix for serializing BSON Regex without options (thanks to MillionIntegrals)
- Misc doc changes (thanks to kianmeng)
- Added support for OP_MSG exhaustAllowed flag
- Added support for streaming protocol
- Added Insights app for development
0
