/ / Entity Framework та точки збереження SQL Server - .net, .net-4.0, entity-framework-4, sql-server-2008-r2, точки збереження

Entity Framework і SQL Server Savepoints - .net, .net-4.0, entity-framework-4, sql-server-2008-r2

Я запитав інше питання про вкладені угоди та відповідь на моє запитання навчило мене настільки, щоб допомогти зрозуміти, що я погано задавав питання. Тож тут краще запитання.

Як я можу ефективно реалізувати точки збереження SQL Server (посилання 1, посилання 2) з DAL, побудованим на Entity Framework 4.0?

Я хотів би написати наступний код і зробити так, щоб він працював так, як SAVEPOINTS SQL Server

public void Bar()
{
using (var ts = new TransactionScope())
{
var ctx = new Context();
DoSomeStuff(ctx);

bool isSuccessful;

using (var spA = new SavePoint("A")) // <-- this object doesn"t really exist, I don"t think
{
isSuccessful = DoSomeOtherStuff(ctx);
if (isSuccessful)
spA.Complete(); // else rollback bo prior to the beginning of this using block
}

Log(ctx, isSuccessful);

ts.Complete();
}
}

Чи є такий спосіб зробити щось подібне до цього чи щось інше, що чудово грає з EF4? (ми використовуємо власні сутності POCO з самовідстеженням)

Відповіді:

0 для відповіді № 1

Це не зовсім повна відповідь, але я підозрюю, що щось подібне може йти правильним шляхом. Моя проблема полягає в тому, що Я не зовсім впевнений, як отримати SqlTransaction, перебуваючи в TransactionScope.

/// <summary>
/// Makes a code block transactional in a way that can be partially rolled-back. This class cannot be inherited.
/// </summary>
/// <remarks>
/// This class makes use of SQL Server"s SAVEPOINT feature, and requires an existing transaction.
/// If using TransactionScope, utilize the DependentTransaction class to obtain the current Transaction that this class requires.
/// </remarks>
public sealed class TransactionSavePoint : IDisposable
{
public bool IsComplete { get; protected set; }
internal SqlTransaction Transaction { get; set; }
internal string SavePointName { get; set; }

private readonly List<ConnectionState> _validConnectionStates = new List<ConnectionState>
{
ConnectionState.Open
};

public TransactionSavePoint(SqlTransaction transaction, string savePointName)
{
IsComplete = false;
Transaction = transaction;
SavePointName = savePointName;

if (!_validConnectionStates.Contains(Transaction.Connection.State))
{
throw new ApplicationException("Invalid connection state: " + Transaction.Connection.State);
}

Transaction.Save(SavePointName);
}

/// <summary>
/// Indicates that all operations within the savepoint are completed successfully.
/// </summary>
public void Complete()
{
IsComplete = true;
}

/// <summary>
/// Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.
/// </summary>
public void Dispose()
{
if (!IsComplete)
{
Transaction.Rollback(SavePointName);
}
}
}

Це споживається як таке, дуже подібно до TransactionScope:

SqlTransaction myTransaction = Foo();

using (var tsp = new TransactionSavePoint(myTransaction , "SavePointName"))
{
try
{
DoStuff();
tsp.Complete
}
catch (Exception err)
{
LogError(err);
}
}