实体框架：避免插入重复项
比方说，我有以下的概念模型，有标签的标签（多于一个，所以它是多对多的关系），加上每个标签都属于特定的类别。
我的数据来自外部来源，插入之前我想确保没有添加重复标签。
更新的代码片段：
static void Main(string[] args)
{
Story story1 = new Story();
story1.Title = "Introducing the Entity Framework";
story1.Tags.Add(new Tag { Name = ".net", });
story1.Tags.Add(new Tag { Name = "database" });
Story story2 = new Story();
story2.Title = "Working with Managed DirectX";
story2.Tags.Add(new Tag { Name = ".net" });
story2.Tags.Add(new Tag { Name = "graphics" });
List<Story> stories = new List<Story>();
stories.Add(story1);
stories.Add(story2);
EfQuestionEntities db = new EfQuestionEntities();
Category category = (from c in db.Categories
where c.Name == "Programming"
select c).First();
foreach (Story story in stories)
{
foreach (Tag tag in story.Tags)
{
Tag currentTag = tag;
currentTag = GetTag(tag.Name, category, db);
}
db.Stories.AddObject(story);
}
db.SaveChanges();
}
public static Tag GetTag(string name, Category category, EfQuestionEntities db)
{
var dbTag = from t in db.Tags.Include("Category")
where t.Name == name
select t;
if (dbTag.Count() > 0)
{
return dbTag.First();
}
var cachedTag = db.ObjectStateManager.GetObjectStateEntries(EntityState.Added).
Where(ose => ose.EntitySet == db.Tags.EntitySet).
Select(ose => ose.Entity).
Cast<Tag>().Where(x => x.Name == name);
if (cachedTag.Count() != 0)
{
return cachedTag.First();
}
Tag tag = new Tag();
tag.Name = name;
tag.Category = category;
db.Tags.AddObject(tag);
return tag;
}
但是，我得到一个关于ObjectContext中已存在的相同EntityKey的对象的异常。
另外，如果我删除else语句，我将得到一个关于违反FK约束的异常，所以它的Category属性被设置为null。
我和EF有同样的问题。 以下是我最终做的事情：
story1.Tags.Add(new Tag { Name = ".net", }) ，通过这样一个辅助方法路由所有Tag创建： story1.Tags.Add(GetTag(".net")) 。 GetTag方法检查上下文中的标记，看看它是否应该返回现有的实体，就像你一样。 如果有，它会返回。 ObjectStateManager以查看是否存在已添加到上下文但尚未写入数据库的Tag实体。 如果它找到匹配的Tag ，则返回该Tag 。 Tag ，它会创建一个新的Tag ，将其添加到上下文中，然后将其返回。 从本质上讲，这将确保在整个程序中不会使用任何Tag一个实例（不管它是已经存在的还是刚创建的）。
一些示例代码从我的项目中解除（使用InventoryItem而不是Tag ，但您明白了）。
步骤3中的检查是这样完成的：
// Second choice: maybe it's not in the database yet, but it's awaiting insertion?
inventoryItem = context.ObjectStateManager.GetObjectStateEntries(EntityState.Added)
.Where(ose => ose.EntitySet == context.InventoryItems.EntitySet)
.Select(ose => ose.Entity)
.Cast<InventoryItem>()
.Where(equalityPredicate.Compile())
.SingleOrDefault();
if (inventoryItem != null) {
return inventoryItem;
}
如果在步骤3中找不到Tag则下面是步骤4的代码：
inventoryItem = new InventoryItem();
context.InventoryItems.AddObject(inventoryItem);
return inventoryItem;
更新：
它应该像这样使用：
Story story1 = new Story();
story1.Title = "Introducing the Entity Framework";
story1.Tags.Add(GetTag(".net", category, db));
story1.Tags.Add(GetTag("database", category, db));