> Для чего используется SELECT FOR UPDATE? (Go)

Короткий ответ

SELECT FOR UPDATE используется для блокировки выбранных строк на время транзакции. Это механизм пессимистичной блокировки, который предотвращает конкурентные изменения данных другими транзакциями до завершения текущей. В Go с PostgreSQL это часто применяется для реализации атомарных операций, когда нужно прочитать состояние и обновить его без гонок. Блокировка снимается при COMMIT или ROLLBACK.

Подробное объяснение

SELECT FOR UPDATE - это SQL-конструкция, которая добавляет к обычному SELECT блокировку на уровне строк. Когда транзакция выполняет такой запрос, выбранные строки блокируются для записи другими транзакциями. Другие транзакции могут читать эти строки (в режиме READ COMMITTED), но не могут их изменять или удалять, пока блокировка не будет снята.

Основные сценарии использования:

• Атомарные операции "прочитал-обновил": например, уменьшение остатка на складе, где нужно сначала проверить наличие, затем изменить количество.
• Защита от lost update: когда две транзакции читают одно значение, модифицируют его и записывают - без блокировки одна перезапишет другую.
• Реализация очередей или распределённых счётчиков на уровне БД.

Важные нюансы:

• Блокировка действует только в рамках транзакции. Вне транзакции SELECT FOR UPDATE не имеет смысла (в PostgreSQL он выполняется в неявной транзакции и сразу снимается).
• В PostgreSQL блокировка снимается при COMMIT или ROLLBACK, но не при закрытии курсора.
• FOR UPDATE блокирует только строки, которые реально выбраны. Если в запросе есть JOIN, блокируются строки всех таблиц, участвующих в выборке (если не указать OF table_name).
• Существуют модификации: FOR NO KEY UPDATE, FOR SHARE, FOR KEY SHARE - они дают более слабые блокировки и позволяют больше конкурентности.

В Go с драйвером pgx или database/sql это работает через обычный SQL-запрос внутри транзакции. Важно правильно управлять транзакцией: открыть её, выполнить SELECT FOR UPDATE, затем обновить данные и закоммитить. Если транзакция долгая, блокировка может привести к дедлокам или деградации производительности.

На практике

В Go-приложениях SELECT FOR UPDATE обычно используется в сервисах, где важна консистентность данных: платежи, заказы, бронирования. Например, при списании средств с баланса:

1. Открываем транзакцию.
2. Выполняем SELECT balance FROM accounts WHERE id = $1 FOR UPDATE.
3. Проверяем, что средств достаточно.
4. Обновляем баланс.
5. COMMIT.

Если две горутины (или два инстанса сервиса) одновременно попытаются списать средства с одного счёта, вторая будет ждать завершения первой транзакции. Это гарантирует, что баланс не уйдёт в минус.

Важно помнить про таймауты и retry-логику: если транзакция долго держит блокировку, другие могут получить ошибку deadlock detected или просто ждать слишком долго. В Go стоит использовать context.WithTimeout для транзакций.

Пример кода

GO
func Withdraw(ctx context.Context, db *sql.DB, accountID int64, amount int64) error {
    tx, err := db.BeginTx(ctx, nil)
    if err != nil {
        return err
    }
    defer tx.Rollback()

    var balance int64
    err = tx.QueryRowContext(ctx,
        "SELECT balance FROM accounts WHERE id = $1 FOR UPDATE", accountID,
    ).Scan(&balance)
    if err != nil {
        return err
    }

    if balance < amount {
        return errors.New("insufficient funds")
    }

    _, err = tx.ExecContext(ctx,
        "UPDATE accounts SET balance = balance - $1 WHERE id = $2", amount, accountID,
    )
    if err != nil {
        return err
    }

    return tx.Commit()
}

Как отвечать на собеседовании

Начни с краткого определения: SELECT FOR UPDATE - это пессимистичная блокировка строк в транзакции. Затем объясни, зачем она нужна: предотвращение гонок при операциях "прочитал-изменил-записал". Приведи пример из практики - списание средств или резервирование товара.

Упомяни, что блокировка снимается при COMMIT/ROLLBACK, и что она работает только внутри транзакции. Хорошо добавить про альтернативы: оптимистичные блокировки (версионирование) или атомарные UPDATE-запросы, когда они возможны.

Если спросят про производительность, скажи: FOR UPDATE снижает конкурентность, поэтому его стоит применять только там, где без него нельзя гарантировать консистентность. В высоконагруженных системах часто предпочитают оптимистичные блокировки или очереди.

Что проверяет интервьюер

Интервьюер оценивает:

• Понимание транзакций и уровней изоляции.
• Знание разницы между пессимистичной и оптимистичной блокировкой.
• Умение применять FOR UPDATE в реальном коде, а не только знать синтаксис.
• Понимание trade-off: блокировки vs производительность, риск дедлоков.
• Способность объяснить, когда FOR UPDATE - правильный выбор, а когда лучше использовать другие подходы.

Типичные ошибки

• Использование SELECT FOR UPDATE без транзакции - блокировка не работает.
• Забывают про defer tx.Rollback() в Go - при ошибке транзакция остаётся открытой.
• Блокируют слишком много строк (например, через JOIN без OF), что снижает конкурентность.
• Не учитывают возможность дедлока при нескольких блокировках в разном порядке.
• Используют FOR UPDATE там, где достаточно атомарного UPDATE ... WHERE balance >= amount - это проще и быстрее.
• Не обрабатывают ошибку sql.ErrNoRows при отсутствии строки - это приводит к панике или некорректной логике.