如何在Ecto MongoDB中执行$ push $ pull $ set等原子操作

Question

我正在使用mongodb_ecto，我想知道如何在深度嵌套字段上执行$ push或$ pull操作？目前我写回整个文档，有时会由于竞争条件导致数据库中存在错误数据。

Answer 1

好吧，我有点想通了。不要为此使用Ecto。在某些情况下，您需要MongoDB positional operator，这只能通过Mongo适配器直接完成。现在为一些使用示例：

我有一个选项列表doucment。选项有投票支持该选项的ID，标签和用户标识列表。

顺便说一句，以生成的ObjectID（这是需要直接谈话的MongoDB的适配器）使用此：

id = "584a5b9419d51d724d146e3f" # string form 
value = (for <<hex::16 <- id>>, into: <<>>, do: <<String.to_integer(<<hex::16>>, 16)::8>>) 
object_id = %BSON.ObjectId{value: value} 

而现在的一些例子：

# update label of option 
Mongo.update_one(Repo.Pool, "polls", 
    %{"_id" => document_id, "options.id" => option_id}, # query 
    %{"$set" => %{"data.options.$.label" => new_label}} # update 
) 

# add new option to poll 
Mongo.update_one(Repo.Pool, "polls", 
    %{"_id" => document_id}, 
    %{"$addToSet" => %{"options" => %{label: label, id: random_new_id, votes: []}}} 
) 

# add user_id to option 
Mongo.update_one(Repo.Pool, "polls", 
    %{"_id" => document_id, "options.id" => option_id}, 
    %{"$addToSet" => %{"options.$.votes" => user_id}} 
) 

# remove user_id form option 
Mongo.update_one(Repo.Pool, "polls", 
    %{"_id" => document_id, "options.id" => option_id}, 
    %{"$pull" => %{"data.options.$.votes" => user_id}} 
)