原子如果不存在，则插入MongoDB.Net驱动程序 [英] Atomic if not exist then insert in Mongodb .Net driver

问题描述

假设我有以下模型：

public class Person
{
    [BsonId]
    public Guid Id { get; set; }
    public string Name { get; set; }
    public string Title { get; set; }
    public DateTime ReceivedAt { get; set; }
}

并且我有N个线程执行"如果不存在则插入"，如何确保只有一个线程在数据库中插入文档。

我尝试的是：

 void test(DBContext context)
    {

        var person = new Person() { Id = Guid.NewGuid(), Name = "name", Title = "title", ReceivedAt = DateTime.Now };
        Console.WriteLine(DateTime.Now);
        var update = Builders<Person>.Update.Combine(
              Builders<Person>.Update.SetOnInsert(y => y.Name, person.Name)
            , Builders<Person>.Update.SetOnInsert(y => y.Title, person.Title)
            , Builders<Person>.Update.SetOnInsert(y => y.ReceivedAt, person.ReceivedAt)
            , Builders<Person>.Update.SetOnInsert(y => y.Id, person.Id));
        var result = context.People.FindOneAndUpdateAsync<Person>(
            x => x.Title == person.Title && x.Name == person.Name && x.ReceivedAt > person.ReceivedAt - TimeSpan.FromSeconds(10),
            update,
            new FindOneAndUpdateOptions<Person>() { IsUpsert = true,ReturnDocument = ReturnDocument.Before}).GetAwaiter().GetResult();
        if (result?.Id != null)
        {
            Console.WriteLine("duplicate");
        }
        else
        {
            Console.WriteLine("first time");
        }
    }

并使用以下命令进行测试：

DBContext context = new DBContext ();
for (int i = 0; i < 10; i++)
  {
   Task.Run(() => test(context));
  }

但上面的代码将多个文档插入到集合中，似乎FindOneAndUpdateAsync不是原子的。

在MongoDB中，有没有办法实现只有一个线程将文档插入集合？

推荐答案

您需要唯一的索引。你的模型的目的是什么？您是想要一个人的一条记录，而接收时间是他们最后一次收到的时间，还是说这更像是每次他们收到一次就应该到达这里的事件？ 在(名称，标题)或(名称，标题，接收日期)上创建唯一索引。 由于DateTime.Now将在运行时递增，因此在第二种情况下，您将第一次看到多个&。在第一种情况下，您应该将ReceivedAt从SetOnInsert更改为Just Set。

这篇关于原子如果不存在，则插入MongoDB.Net驱动程序的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！