私は自分のアプリケーションでTag
モデルを持っている:EntityFrameworkのSaveChanges()メソッドが既に存在する場合、そのエントリをスキップする方法はありますか?
public class Tag
{
public Tag() { }
public Tag(string t)
{
Name = t;
Pictures = new List<Picture>();
}
public int Id { get; set; }
[MaxLength(96), Index(IsUnique = true)]
public string Name { get; set; }
public virtual List<Picture> Pictures { get; set; }
}
ON DUPLICATE DO NOTHING
を行うためのフレームワークを伝えるためにどのような方法が同じName
を持つレコードがすでに存在する場合、ありますか?これは常にDuplicate例外をスローし、無視して移動したいと思います。
編集:私はこれまで多くのスレッド間EFコードを変更しました:
async Task SaveQueue()
{
for (;;)
{
try
{
await Task.Delay(7500);
dbUploadProgress.Visibility = Visibility.Visible;
dbUploadProgress.Value = 0;
var q = new ObservableCollection<Picture>(manager.Queue.ToList().AsEnumerable());
manager.Queue.Clear();
var imgcount = q.Count();
for (int i = 0; i < imgcount; i++)
{
using (var pc = new PicsContext())
{
var tags = q[i].GetTags();
pc.Sites.Attach(q[i].Site); // I'm actually not sure how to use this.
var curUrl = q[i].Url;
if (pc.Pictures.FirstOrDefault(o => o.Url == curUrl) != null)
continue;
foreach (var t in tags)
{
var tag = pc.Tags.Where(o => o.Name == t).FirstOrDefault();
if (tag == null)
{
tag = new ViewModel.Tag(t);
}
q[i].Tags.Add(tag);
try
{
await pc.SaveChangesAsync();
}
catch { }
}
pc.Pictures.Add(q[i]);
try
{
await pc.SaveChangesAsync();
}
catch { }
dbUploadProgress.Value = (i + 1)/(double)imgcount;
}
}
q.Clear();
MainWindow.AddLog(string.Format("Saved {0} pictures.", imgcount));
dbUploadProgress.Visibility = Visibility.Collapsed;
await Task.Delay(1500);
}
catch { }
if (isStopped)
break;
}
}
問題がまだ存在している、しかし。
私は を使用しています。var tag = pc.Tags.Where(o => o.Name == t).FirstOrDefault(); if(tag == null) { tag = new ViewModel.Tag(t); } q [i] .Tags.Add(タグ); しかし、多くのタスクが一度に異なるスレッドを実行するため、十分ではないようです。それは混乱します。 – Reynevan
エンティティコンテキストはスレッドセーフではありません。私はあなたが各スレッドごとに異なったコンテキストを使用していると仮定します。 –
私はコードを変更しました。あなたはそれを見てみることができますか?私は元の投稿を編集しました。 – Reynevan