本文介绍了原子如果不存在，则插入MongoDB.Net驱动程序的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！
问题描述
假设我有以下模型：
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驱动程序的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持编程学习网！
本站部分内容来源互联网,如果有图片或者内容侵犯您的权益请联系我们删除！