Wie würde Sie schreiben ein Upsert für LINQ to SQL?

Also ich möchte schreiben eine generische Upsert-Funktion für LINQ to SQL und ich habe einige Schwierigkeiten, die Konzeptualisierung, wie es zu tun. Ich möchte es für die Arbeit, so etwas wie dieses:

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

So müsste es allgemein in gewisser Weise, und ich denke und extension-Methode auf die Tabelle. Ich habe in der Lage, so weit zu kommen bei der Bestimmung der Primärschlüssel der zugrunde liegenden Tabelle:

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

Ich gehe davon aus, dass es notwendig sein wird, um diese zu verfassen, eine Abfrage zu sagen, wenn der Artikel ist in der DB bereits oder nicht, aber ich weiß wirklich nicht, was zu tun an diesem Punkt.

InformationsquelleAutor JC Grubbs | 2009-03-12
  1. 8

    Ich tun etwas ähnliches, aber mit einem anderen Ansatz. Jede Entität implementiert IEntity. Eine der Eigenschaften der IEntity ist ein Zustand, wenn das Objekt neu ist oder bereits vorhanden ist. Ich habe dann implementieren, dass für jede Entität, wie:

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

    Dann eine generische Upsert werden könnte (auf einem generischen repository-Typ-Klasse):

    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>();
}

    Wenn Ihr das anbringen von anderen datacontext, auch stellen Sie sicher, dass Sie einen Zeitstempel auf Ihre Objekte.

    • Naja... der ganze Sinn des upsert ist, dass Sie nicht wissen, ob es existiert oder nicht, Sie wollen einfach nur die Datenbank um die neuen Inhalte; der upsert spart man sich die extra roundtrip', um festzustellen, dass. Ihre Lösung ist keine Antwort; was benötigt wird, ist ein sql - MERGE wie hier beschrieben: stackoverflow.com/questions/2479488/... .
    • Diese Antwort gilt für Entity Framework. Siehe meine Antwort für eine LINQ-to-SQL-Lösung.
    InformationsquelleAutor ericvg
  2. 1

    Kurze Antwort:

    Schnappen Sie sich diese: EntityExtensionMethods.cs

    Erklärung

    Tun UPSERT in LINQ-to-SQL ohne Abfrage zuerst die Datensätze, die Sie tun können, die folgenden. Es wird noch treffen, die db einmal zu überprüfen, ob Datensatz vorhanden, aber nicht ziehen Sie die Aufzeichnung:

    var blob = new Blob { Id = "some id", Value = "some value" }; //Id is primary key (PK)

if (dbContext.Blobs.Contains(blob)) //if blob exists by PK then update
{
    //This will update all columns that are not set in 'original' object. For
    //this to work, Blob has to have UpdateCheck=Never for all properties except
    //for primary keys. This will update the record without querying it first.
    dbContext.Blobs.Attach(blob, original: new Blob { Id = blob.Id });
}
else //insert
{
    dbContext.Blobs.InsertOnSubmit(blob);
}
dbContext.Blobs.SubmitChanges();

    Erweiterung Methode

    Ich kam mit der folgenden extension Methode für Sie.

    public static class EntityExtensionMethods
{
    public static void InsertOrUpdateOnSubmit<TEntity>(this Table<TEntity> table, TEntity entity, TEntity original = null)
        where TEntity : class, new()
    {
        if (table.Contains(entity)) //if entity exists by PK then update
        {
            if (original == null)
            {
                //Create original object with only primary keys set
                original = new TEntity();
                var entityType = typeof(TEntity);
                var dataMembers = table.Context.Mapping.GetMetaType(entityType).DataMembers;
                foreach (var member in dataMembers.Where(m => m.IsPrimaryKey))
                {
                    var propValue = entityType.GetProperty(member.Name).GetValue(entity, null);
                    entityType.InvokeMember(member.Name, BindingFlags.SetProperty, Type.DefaultBinder,
                        original, new[] {propValue});
                }
            }

            //This will update all columns that are not set in 'original' object. For
            //this to work, entity has to have UpdateCheck=Never for all properties except
            //for primary keys. This will update the record without querying it first.
            table.Attach(entity, original);
        }
        else //insert
        {
            table.InsertOnSubmit(entity);
        }
    }
}

    Verwenden Sie es wie unten:

    var blob = new Blob { Id = "some id", Value = "some value" }; //Id is primary key (PK)
dbContext.Blobs.InsertOrUpdateOnSubmit(blob);
dbContext.Blobs.SubmitChanges();

    Ich oben Hinzugefügt-Erweiterung-Methode mit mehr Material zu diesem gist: EntityExtensionMethods.cs

    InformationsquelleAutor orad
Schreibe einen Kommentar