Конкурентный доступ: Optimistic vs Pessimistic Concurrency?

public class Product
{
    public int Id { get; set; }
    public string Name { get; set; } = "";
    public decimal Price { get; set; }
    public int Stock { get; set; }

    [Timestamp] public byte[] RowVersion { get; set; } = [];   // SQL Server: rowversion меняется автоматически
}

// PostgreSQL: системный столбец xmin как токен конкурентности
modelBuilder.Entity<Product>().Property<uint>("Version").IsRowVersion();   // Npgsql маппит на xmin

// Или ручной токен (любая СУБД): приложение само меняет значение
modelBuilder.Entity<Product>().Property(p => p.ConcurrencyStamp).IsConcurrencyToken();

try
{
    product.Stock -= qty;
    await db.SaveChangesAsync(ct);
}
catch (DbUpdateConcurrencyException ex)
{
    var entry = ex.Entries.Single();
    var dbValues = await entry.GetDatabaseValuesAsync(ct);
    if (dbValues is null) throw new NotFoundException("Товар удалён");

    // Стратегии:
    // 1. Клиент выигрывает — перезаписать: entry.OriginalValues.SetValues(dbValues); SaveChanges снова
    // 2. БД выигрывает — отбросить изменения: entry.CurrentValues.SetValues(dbValues)
    // 3. Слияние / сообщить пользователю (чаще всего в UI)
    throw new ConflictException("Товар изменён другим пользователем. Обновите страницу.");   // → 409
}

app.MapPut("/products/{id}", async (int id, UpdateProduct dto, [FromHeader(Name = "If-Match")] string? ifMatch, ShopDbContext db) =>
{
    var product = await db.Products.FindAsync(id);
    if (product is null) return Results.NotFound();
    if (ifMatch is null) return Results.StatusCode(428);                              // Precondition Required

    db.Entry(product).Property(p => p.RowVersion).OriginalValue = Convert.FromBase64String(ifMatch.Trim('"'));
    product.Price = dto.Price;
    try { await db.SaveChangesAsync(); }
    catch (DbUpdateConcurrencyException) { return Results.StatusCode(412); }       // Precondition Failed
    return Results.NoContent();
});

await using var tx = await db.Database.BeginTransactionAsync(ct);

var account = await db.Accounts
    .FromSql($"SELECT * FROM accounts WHERE id = {accountId} FOR UPDATE")   // PostgreSQL; SQL Server: WITH (UPDLOCK, ROWLOCK)
    .SingleAsync(ct);                                                        // другие FOR UPDATE по этой строке будут ждать

account.Withdraw(amount);
await db.SaveChangesAsync(ct);
await tx.CommitAsync(ct);                                                    // блокировка снята

-- Каждый воркер берёт свою задачу, не ожидая чужих блокировок
UPDATE jobs SET status = 'processing', locked_by = @worker
WHERE id = (
    SELECT id FROM jobs
    WHERE status = 'pending'
    ORDER BY created_at
    FOR UPDATE SKIP LOCKED
    LIMIT 1
)
RETURNING *;

// Вместо загрузки товара и проверки остатка в C#:
int updated = await db.Products
    .Where(p => p.Id == productId && p.Stock >= qty)
    .ExecuteUpdateAsync(s => s.SetProperty(p => p.Stock, p => p.Stock - qty), ct);

if (updated == 0) throw new OutOfStockException();   // не хватило — никто не ушёл в минус