Транзакція: Переказ 1000 ₴ з рахунку А на рахунок Б

Крок 1: UPDATE Accounts SET Balance = Balance - 1000 WHERE Id = 'A'
Крок 2: UPDATE Accounts SET Balance = Balance + 1000 WHERE Id = 'B'

Без транзакції:
  ✅ Крок 1 виконано (Balance_A = 4000)
  ❌ Крок 2 не виконано (помилка мережі)
  Результат: 1000 ₴ зникло! Balance_A = 4000, Balance_B = 2000 (було 5000 + 2000 = 7000, стало 6000)

З транзакцією:
  ✅ Крок 1 виконано (у тимчасовому стані)
  ❌ Крок 2 не виконано → ROLLBACK
  Результат: Balance_A = 5000, Balance_B = 2000 (все як було)

using System;
using Microsoft.Data.SqlClient;

string connectionString = "Server=localhost;Database=BankDb;Trusted_Connection=True;TrustServerCertificate=True;";
using SqlConnection connection = new SqlConnection(connectionString);
connection.Open();

// 1. Починаємо транзакцію
SqlTransaction transaction = connection.BeginTransaction();

try
{
    // 2. Прив'язуємо команди до транзакції
    using SqlCommand debitCmd = new SqlCommand(
        "UPDATE Accounts SET Balance = Balance - @Amount WHERE Id = @AccountId",
        connection,
        transaction); // ← третій параметр — транзакція!

    debitCmd.Parameters.Add("@Amount", SqlDbType.Decimal).Value = 1000m;
    debitCmd.Parameters.Add("@AccountId", SqlDbType.Int).Value = 1;

    int debitRows = debitCmd.ExecuteNonQuery();
    if (debitRows == 0)
        throw new InvalidOperationException("Рахунок відправника не знайдено.");

    // 3. Друга операція — зарахування
    using SqlCommand creditCmd = new SqlCommand(
        "UPDATE Accounts SET Balance = Balance + @Amount WHERE Id = @AccountId",
        connection,
        transaction);

    creditCmd.Parameters.Add("@Amount", SqlDbType.Decimal).Value = 1000m;
    creditCmd.Parameters.Add("@AccountId", SqlDbType.Int).Value = 2;

    int creditRows = creditCmd.ExecuteNonQuery();
    if (creditRows == 0)
        throw new InvalidOperationException("Рахунок отримувача не знайдено.");

    // 4. Все OK — фіксуємо транзакцію
    transaction.Commit();
    Console.WriteLine("✅ Переказ успішно завершено!");
}
catch (Exception ex)
{
    // 5. Помилка — відкочуємо ВСЕ
    Console.WriteLine($"❌ Помилка: {ex.Message}");

    try
    {
        transaction.Rollback();
        Console.WriteLine("↩️ Транзакцію відкочено.");
    }
    catch (Exception rollbackEx)
    {
        // Rollback теж може впасти (наприклад, з'єднання розірвано)
        Console.WriteLine($"⚠️ Помилка при rollback: {rollbackEx.Message}");
    }
}

using System;
using Microsoft.Data.SqlClient;

string connectionString = "Server=localhost;Database=BankDb;Trusted_Connection=True;TrustServerCertificate=True;";
using SqlConnection connection = new SqlConnection(connectionString);
connection.Open();

// using автоматично rollback-нє, якщо не було Commit()
using SqlTransaction transaction = connection.BeginTransaction();

using SqlCommand debitCmd = new SqlCommand(
    "UPDATE Accounts SET Balance = Balance - @Amount WHERE Id = @AccountId",
    connection, transaction);
debitCmd.Parameters.Add("@Amount", SqlDbType.Decimal).Value = 1000m;
debitCmd.Parameters.Add("@AccountId", SqlDbType.Int).Value = 1;
debitCmd.ExecuteNonQuery();

using SqlCommand creditCmd = new SqlCommand(
    "UPDATE Accounts SET Balance = Balance + @Amount WHERE Id = @AccountId",
    connection, transaction);
creditCmd.Parameters.Add("@Amount", SqlDbType.Decimal).Value = 1000m;
creditCmd.Parameters.Add("@AccountId", SqlDbType.Int).Value = 2;
creditCmd.ExecuteNonQuery();

// Якщо дійшли сюди без винятків — фіксуємо
transaction.Commit();
Console.WriteLine("✅ Переказ завершено!");
// Якщо виникне виняток ДО Commit(), using викличе Dispose(),
// який автоматично виконає Rollback()

using Microsoft.Data.SqlClient;
using System.Data;

string connectionString = "Server=localhost;Database=ShopDb;Trusted_Connection=True;TrustServerCertificate=True;";
using SqlConnection connection = new SqlConnection(connectionString);
connection.Open();

// Рівень ізоляції задається при створенні транзакції
using SqlTransaction transaction = connection.BeginTransaction(IsolationLevel.Serializable);

using SqlCommand command = new SqlCommand(
    "SELECT Quantity FROM Products WHERE Id = @Id",
    connection, transaction);
command.Parameters.Add("@Id", SqlDbType.Int).Value = 1;

int quantity = Convert.ToInt32(command.ExecuteScalar());

if (quantity >= 5)
{
    using SqlCommand updateCmd = new SqlCommand(
        "UPDATE Products SET Quantity = Quantity - 5 WHERE Id = @Id",
        connection, transaction);
    updateCmd.Parameters.Add("@Id", SqlDbType.Int).Value = 1;
    updateCmd.ExecuteNonQuery();

    transaction.Commit();
    Console.WriteLine("✅ Товар зарезервовано.");
}
else
{
    transaction.Rollback();
    Console.WriteLine("❌ Недостатньо товару на складі.");
}

using System;
using Microsoft.Data.SqlClient;

string connectionString = "Server=localhost;Database=ShopDb;Trusted_Connection=True;TrustServerCertificate=True;";
using SqlConnection connection = new SqlConnection(connectionString);
connection.Open();

using SqlTransaction transaction = connection.BeginTransaction();

try
{
    // Крок 1: Створити замовлення (обов'язково)
    using SqlCommand orderCmd = new SqlCommand(
        @"INSERT INTO Orders (CustomerId, TotalAmount, CreatedAt)
          VALUES (@CustomerId, @Total, GETDATE());
          SELECT CAST(SCOPE_IDENTITY() AS INT);",
        connection, transaction);
    orderCmd.Parameters.Add("@CustomerId", SqlDbType.Int).Value = 1;
    orderCmd.Parameters.Add("@Total", SqlDbType.Decimal).Value = 5000m;
    int orderId = Convert.ToInt32(orderCmd.ExecuteScalar());
    Console.WriteLine($"Замовлення #{orderId} створено.");

    // Крок 2: Спробувати застосувати знижку (необов'язково)
    transaction.Save("BeforeDiscount"); // ← SAVEPOINT

    try
    {
        using SqlCommand discountCmd = new SqlCommand(
            @"UPDATE Orders SET TotalAmount = TotalAmount * 0.9
              WHERE Id = @OrderId AND TotalAmount > 3000",
            connection, transaction);
        discountCmd.Parameters.Add("@OrderId", SqlDbType.Int).Value = orderId;
        discountCmd.ExecuteNonQuery();

        // Перевіряємо, що знижка не зробила суму від'ємною (бізнес-правило)
        using SqlCommand checkCmd = new SqlCommand(
            "SELECT TotalAmount FROM Orders WHERE Id = @OrderId",
            connection, transaction);
        checkCmd.Parameters.Add("@OrderId", SqlDbType.Int).Value = orderId;
        decimal total = Convert.ToDecimal(checkCmd.ExecuteScalar());

        if (total < 100)
            throw new InvalidOperationException("Знижка занадто велика!");

        Console.WriteLine($"Знижку 10% застосовано. Нова сума: {total:C}");
    }
    catch (Exception ex)
    {
        // Відкочуємо ЛИШЕ знижку, замовлення залишається!
        Console.WriteLine($"⚠️ Не вдалося застосувати знижку: {ex.Message}");
        transaction.Rollback("BeforeDiscount"); // ← rollback до savepoint
    }

    // Крок 3: Зменшити кількість на складі (обов'язково)
    using SqlCommand stockCmd = new SqlCommand(
        "UPDATE Products SET Quantity = Quantity - 1 WHERE Id = @ProductId",
        connection, transaction);
    stockCmd.Parameters.Add("@ProductId", SqlDbType.Int).Value = 1;
    stockCmd.ExecuteNonQuery();

    // Фіксуємо всю транзакцію
    transaction.Commit();
    Console.WriteLine("✅ Замовлення оформлено!");
}
catch (Exception ex)
{
    Console.WriteLine($"❌ Критична помилка: {ex.Message}");
    transaction.Rollback(); // Повний rollback
}

async Task ExecuteWithDeadlockRetryAsync(
    SqlConnection connection,
    Func<SqlTransaction, Task> operation,
    int maxRetries = 3)
{
    for (int attempt = 1; attempt <= maxRetries; attempt++)
    {
        using SqlTransaction transaction = connection.BeginTransaction();

        try
        {
            await operation(transaction);
            transaction.Commit();
            return; // Успіх — виходимо
        }
        catch (SqlException ex) when (ex.Number == 1205 && attempt < maxRetries)
        {
            // Deadlock — повторна спроба
            Console.WriteLine($"⚠️ Deadlock (спроба {attempt}/{maxRetries}). Повтор...");
            await Task.Delay(Random.Shared.Next(50, 200)); // Random delay
        }
        // Інші SqlException не перехоплюються — летять далі
    }

    throw new InvalidOperationException($"Операція не вдалася після {maxRetries} deadlock-ів.");
}

// Використання
await ExecuteWithDeadlockRetryAsync(connection, async (transaction) =>
{
    using SqlCommand cmd = new SqlCommand(
        "UPDATE Accounts SET Balance = Balance - 1000 WHERE Id = 1",
        connection, transaction);
    await cmd.ExecuteNonQueryAsync();

    using SqlCommand cmd2 = new SqlCommand(
        "UPDATE Accounts SET Balance = Balance + 1000 WHERE Id = 2",
        connection, transaction);
    await cmd2.ExecuteNonQueryAsync();
});

using System.Transactions;
using Microsoft.Data.SqlClient;

string cs1 = "Server=localhost;Database=BankDb;Trusted_Connection=True;TrustServerCertificate=True;";
string cs2 = "Server=localhost;Database=AuditDb;Trusted_Connection=True;TrustServerCertificate=True;";

// TransactionScope автоматично керує транзакціями
using (TransactionScope scope = new TransactionScope())
{
    // Операція 1: Переказ грошей (BankDb)
    using (SqlConnection conn1 = new SqlConnection(cs1))
    {
        conn1.Open();
        using SqlCommand cmd = new SqlCommand(
            "UPDATE Accounts SET Balance = Balance - 1000 WHERE Id = 1",
            conn1);
        cmd.ExecuteNonQuery();
    }

    // Операція 2: Запис в аудит (AuditDb) — ІНША база!
    using (SqlConnection conn2 = new SqlConnection(cs2))
    {
        conn2.Open();
        using SqlCommand cmd = new SqlCommand(
            "INSERT INTO AuditLog (Action, Details, CreatedAt) VALUES (@Act, @Det, GETDATE())",
            conn2);
        cmd.Parameters.AddWithValue("@Act", "Transfer");
        cmd.Parameters.AddWithValue("@Det", "1000 UAH from Account 1");
        cmd.ExecuteNonQuery();
    }

    // Фіксуємо ОБІ операції атомарно
    scope.Complete();
    Console.WriteLine("✅ Переказ та аудит завершені!");
}
// Якщо Complete() не викликано (виняток) — обидві операції rollback

using (var scope = new TransactionScope(
    TransactionScopeAsyncFlowOption.Enabled)) // ← Обов'язково для async
{
    using SqlConnection connection = new SqlConnection(connectionString);
    await connection.OpenAsync();

    using SqlCommand cmd = new SqlCommand("UPDATE ...", connection);
    await cmd.ExecuteNonQueryAsync();

    scope.Complete();
}