你将如何编写一个用于LINQ to SQL的Upsert？

发布时间：2020-12-12 16:13:31 所属栏目：MsSql教程来源：网络整理

导读：所以我想为LINQ to SQL编写一个通用的Upsert函数,并且我在概念化方法上有一些麻烦.我想要这样工作： var db = new DataContext();db.Customers.UpsertOnSubmit(customer); 所以它必须是通用的某种方式,我猜和扩展方法在表.我已经能够确定基础表的主键： var c

所以我想为LINQ to SQL编写一个通用的Upsert函数,并且我在概念化方法上有一些麻烦.我想要这样工作：

var db = new DataContext();
db.Customers.UpsertOnSubmit(customer);

所以它必须是通用的某种方式,我猜和扩展方法在表.我已经能够确定基础表的主键：

var context = source.Context;
var table = context.Mapping.GetTable(source.GetType());
var primaryMember = table.RowType.DataMembers.SingleOrDefault(m => m.IsPrimaryKey);

我假设有必要这样做来撰写一个查询来告诉项目是否已经在DB中,但我不知道该怎么处理这一点.

解决方法

我做类似的事情,但采用不同的方法.每个实体实现IEntity. IEntity的属性之一是一个状态,如果该对象是新的或现有的.然后我为每个实体实现,如：

public EntityState EntityState
{
    get
    {
        if (_Id > 0)
            return EntityState.Exisiting;
        else
            return EntityState.New;
    }
}

然后,通用的Upsert可以是(在通用存储库类型类上)：

public virtual void Upsert<Ta>(Ta entity)
    where Ta: class
{
    if (!(entity is IEntity))
        throw new Exception("T must be of type IEntity");

    if (((IEntity)entity).EntityState == EntityState.Exisiting)
        GetTable<Ta>().Attach(entity,true);
    else
        GetTable<Ta>().InsertOnSubmit(entity);
}

private System.Data.Linq.Table<Ta> GetTable<Ta>()
    where Ta: class
{
    return _dataContext.Context.GetTable<Ta>();
}

如果你从另一个数据文本附加,还要确保你的对象有一个时间戳.

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!