Início / dba / Perguntas / 106368
Accepted
msgisme
Asked: 2015-07-09 09:42:11 +0800 CST

CLR/C# equivalente a XACT_STATE()

  • 772

Estou transferindo um conjunto de procedimentos armazenados T-SQL para C#/CLR. No T-SQL, usamos XACT_STATE() para determinar se um erro requer a reversão para um ponto de salvamento ou a reversão total da transação.

Não consigo encontrar uma verificação equivalente da transação usando os objetos System.Data.SqlClient.SqlTransactionou .System.Transactions.TransactionScope

Alguém sabe como verificar o estado da transação em C#/CLR?

sql-server transaction

2 respostas

  1. Best Answer

    XACT_STATE()não é algo que SqlClienttenha uma visão especial, muito parecido com o nível de transação . Então, basta consultá-lo com SqlCommand.

    // If you already have an open connection...
public int GetXactState (SqlConnection connection)
{   
    using (SqlCommand command = new SqlCommand("Select XACT_STATE();", connection)) {
        return (int)command.ExecuteScalar();
    }
}
    • 3

  2. Sim você pode. No entanto, isso depende das partes internas do assembly System.Data.SqlClient e, portanto, eu não o recomendaria. Se for realmente necessário, eu reavaliaria se o CLR é realmente a maneira correta de fazer o que você está tentando fazer.

    O SqlTransaction é, na verdade, apenas uma classe wrapper em torno da classe SqlInternalTransaction . A classe SqlInternalTransaction já rastreia o estado da transação para você (se não o fizesse, como o SqlClient saberia se deveria reverter ou não?)

    Você precisará usar a reflexão para obter a instância do SqlInternalTransaction , o que, novamente, eu não recomendaria fazer em um procedimento CLR, pois isso pode ser muito caro em termos de desempenho - especialmente se for chamado várias vezes.

    Dito isto, aqui está como você faz isso.

    public enum TransactionState
{
    Pending = 0,
    Active = 1,
    Aborted = 2,
    Committed = 3,
    Unknown = 4,
}

public static class SqlExtensions
{
    public static TransactionState GetXactState(this SqlTransaction transaction)
    {
        BindingFlags bindingFlags = BindingFlags.Public | BindingFlags.NonPublic | BindingFlags.Instance;

        PropertyInfo property = transaction.GetType().GetProperties(bindingFlags).FirstOrDefault(x => x.Name.Equals("InternalTransaction", StringComparison.OrdinalIgnoreCase);
        if (property == null)
            return TransactionState.Unknown;

        object internalTransaction = property.GetValue(transaction);

        FieldInfo transactionState = property.PropertyType.GetField("_transactionState", bindingFlags);
        if (property == null)
            return TransactionState.Unknown;

        return (TransactionState)Enum.Parse(typeof(TransactionState), Convert.ToString(transactionState.GetValue(internalTransaction)), true);
    }
}

class Program
{
    static void Main(string[] args)
    {
        SqlTransaction x = null;

        // use transaction etc.. here.

        TransactionState state = x.GetXactState();
    }
}
    • 2

relate perguntas