Привет, я тоже с этим боролся и нашел очень элегантное решение.
По сути, вам необходимо использовать метод DataContext.Attach (EntityToUpdate, OriginalEntity).
Есть несколько ошибок ... Итак, прочитайте эту информацию, она все объяснит .
Как только вы прочитаете это, просто возвращайтесь ко мне с любыми вопросами. Я написал действительно полезный класс EntitySaver, основанный на этой информации, поэтому, если вам нужно, мы можем пройти ваш класс, как только вы получите ошибки.
ура
EDIT :
Вот мой класс полностью, на случай, если вы захотите попробовать. Это на самом деле обрабатывает обновления и вставки автоматически. дайте мне знать, у вас есть какие-либо вопросы.
Entity Saver:
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using QDAL.CoreContext;
using QDAL.CoreEntities;
using LinqExtension.CustomExtensions;
namespace QDAL
{
internal class DisconnectedEntitySaver
{
private QDataDataContext ContextForUpdate;
public DisconnectedEntitySaver() {
ContextForUpdate = Base.CreateDataContext();
}
public List<TEntityType> SaveEntities<TEntityType, TKeyType>(List<TEntityType> EntitiesToSave) {
string PKName;
PKName = Base.GetPrimaryKeyName(typeof(TEntityType), ContextForUpdate);
return SaveEntities<TEntityType, TKeyType>(EntitiesToSave, PKName);
}
public List<TEntityType> SaveEntities<TEntityType, TKeyType>(List<TEntityType> EntitiesToSave, string KeyFieldName)
{
List<TEntityType> EntitiesToPossiblyUpdate;
List<TEntityType> EntitiesToInsert;
List<TEntityType> HandledEntities = new List<TEntityType>();
bool TimeStampEntity;
Type ActualFieldType;
if (EntitiesToSave.Count > 0) {
TimeStampEntity = Base.EntityContainsTimeStamp(typeof(TEntityType), ContextForUpdate);
ActualFieldType = EntitiesToSave.FirstOrDefault().GetPropertyType(KeyFieldName);
if (ActualFieldType != typeof(TKeyType)) {
throw new Exception("The UniqueFieldType[" + typeof(TKeyType).Name + "] specified does not match the actual field Type[" + ActualFieldType.Name + "]");
}
if (ActualFieldType == typeof(string)) {
EntitiesToPossiblyUpdate = EntitiesToSave.Where(ent => string.IsNullOrEmpty(ent.GetPropertyValue<string>(KeyFieldName)) == false).ToList();
EntitiesToInsert = EntitiesToSave.Where(ent => string.IsNullOrEmpty(ent.GetPropertyValue<string>(KeyFieldName)) == true).ToList();
} else {
EntitiesToPossiblyUpdate = EntitiesToSave.Where(ent => EqualityComparer<TKeyType>.Default.Equals(ent.GetPropertyValue<TKeyType>(KeyFieldName), default(TKeyType)) == false).ToList();
EntitiesToInsert = EntitiesToSave.Where(ent => EqualityComparer<TKeyType>.Default.Equals(ent.GetPropertyValue<TKeyType>(KeyFieldName), default(TKeyType)) == true).ToList();
}
if (EntitiesToPossiblyUpdate.Count > 0) {
EntitiesToInsert.AddRange(ResolveUpdatesReturnInserts<TEntityType, TKeyType>(EntitiesToPossiblyUpdate, KeyFieldName));
HandledEntities.AddRange(EntitiesToPossiblyUpdate.Where(ent => EntitiesToInsert.Select(eti => eti.GetPropertyValue<TKeyType>(KeyFieldName)).Contains(ent.GetPropertyValue<TKeyType>(KeyFieldName)) == false));
}
if (EntitiesToInsert.Count > 0) {
ContextForUpdate.GetTable(typeof(TEntityType)).InsertAllOnSubmit(EntitiesToInsert);
HandledEntities.AddRange(EntitiesToInsert);
}
ContextForUpdate.SubmitChanges();
ContextForUpdate = null;
return HandledEntities;
} else {
return EntitiesToSave;
}
}
private List<TEntityType> ResolveUpdatesReturnInserts<TEntityType, TKeyType>(List<TEntityType> PossibleUpdates, string KeyFieldName)
{
QDataDataContext ContextForOrginalEntities;
List<TKeyType> EntityToSavePrimaryKeys;
List<TEntityType> EntitiesToInsert = new List<TEntityType>();
List<TEntityType> OriginalEntities;
TEntityType NewEntityToUpdate;
TEntityType OriginalEntity;
string TableName;
ContextForOrginalEntities = Base.CreateDataContext();
TableName = ContextForOrginalEntities.Mapping.GetTable(typeof(TEntityType)).TableName;
EntityToSavePrimaryKeys = (from ent in PossibleUpdates select ent.GetPropertyValue<TKeyType>(KeyFieldName)).ToList();
OriginalEntities = ContextForOrginalEntities.ExecuteQuery<TEntityType>("SELECT * FROM " + TableName + " WHERE " + KeyFieldName + " IN('" + string.Join("','", EntityToSavePrimaryKeys.Select(varobj => varobj.ToString().Trim()).ToArray()) + "')").ToList();
//kill original entity getter
ContextForOrginalEntities = null;
foreach (TEntityType NewEntity in PossibleUpdates)
{
NewEntityToUpdate = NewEntity;
OriginalEntity = OriginalEntities.Where(ent => EqualityComparer<TKeyType>.Default.Equals(ent.GetPropertyValue<TKeyType>(KeyFieldName),NewEntityToUpdate.GetPropertyValue<TKeyType>(KeyFieldName)) == true).FirstOrDefault();
if (OriginalEntity == null)
{
EntitiesToInsert.Add(NewEntityToUpdate);
}
else
{
ContextForUpdate.GetTable(typeof(TEntityType)).Attach(CloneEntity<TEntityType>(NewEntityToUpdate), OriginalEntity);
}
}
return EntitiesToInsert;
}
protected TEntityType CloneEntity<TEntityType>(TEntityType EntityToClone)
{
var dcs = new System.Runtime.Serialization.DataContractSerializer(typeof(TEntityType));
using (var ms = new System.IO.MemoryStream())
{
dcs.WriteObject(ms, EntityToClone);
ms.Seek(0, System.IO.SeekOrigin.Begin);
return (TEntityType)dcs.ReadObject(ms);
}
}
}
}
Вам также понадобятся эти помощники:
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using QDAL.CoreContext;
using QDAL.CoreEntities;
using System.Configuration;
namespace QDAL
{
internal class Base
{
public Base() {
}
internal static QDataDataContext CreateDataContext() {
QDataDataContext newContext;
string ConnStr;
ConnStr = ConfigurationManager.ConnectionStrings["ConnectionString"].ConnectionString;
newContext = new QDataDataContext(ConnStr);
return newContext;
}
internal static string GetTableName(Type EntityType, QDataDataContext CurrentContext) {
return CurrentContext.Mapping.GetTable(EntityType).TableName;
}
internal static string GetPrimaryKeyName(Type EntityType, QDataDataContext CurrentContext) {
return (from m in CurrentContext.Mapping.MappingSource.GetModel(CurrentContext.GetType()).GetMetaType(EntityType).DataMembers where m.IsPrimaryKey == true select m.Name).FirstOrDefault();
}
internal static bool EntityContainsTimeStamp(Type EntityType, QDataDataContext CurrentContext) {
return (CurrentContext.Mapping.MappingSource.GetModel(CurrentContext.GetType()).GetMetaType(EntityType).DataMembers.Where(dm => dm.IsVersion == true).FirstOrDefault() != null);
}
}
}
и эти расширения облегчают отражение:
<System.Runtime.CompilerServices.Extension()> _
Public Function GetPropertyValue(Of ValueType)(ByVal Source As Object, ByVal PropertyName As String) As ValueType
Dim pInfo As System.Reflection.PropertyInfo
pInfo = Source.GetType.GetProperty(PropertyName)
If pInfo Is Nothing Then
Throw New Exception("Property " & PropertyName & " does not exists for object of type " & Source.GetType.Name)
Else
Return pInfo.GetValue(Source, Nothing)
End If
End Function
<System.Runtime.CompilerServices.Extension()> _
Public Function GetPropertyType(ByVal Source As Object, ByVal PropertyName As String) As Type
Dim pInfo As System.Reflection.PropertyInfo
pInfo = Source.GetType.GetProperty(PropertyName)
If pInfo Is Nothing Then
Throw New Exception("Property " & PropertyName & " does not exists for object of type " & Source.GetType.Name)
Else
Return pInfo.PropertyType
End If
End Function