Перейти к основному содержанию
Неофициальный Бета-перевод

Эта страница переведена PageTurner AI (бета). Не одобрена официально проектом. Нашли ошибку? Сообщить о проблеме →

Транзакции

Создание и использование транзакций​

Транзакции создаются с помощью DataSource или EntityManager. Примеры:

await myDataSource.transaction(async (transactionalEntityManager) => {
    // execute queries using transactionalEntityManager
})

или

await myDataSource.manager.transaction(async (transactionalEntityManager) => {
    // execute queries using transactionalEntityManager
})

Всё, что должно выполняться в транзакции, необходимо поместить в колбэк:

await myDataSource.manager.transaction(async (transactionalEntityManager) => {
    await transactionalEntityManager.save(users)
    await transactionalEntityManager.save(photos)
    // ...
})

Ключевое ограничение при работе в транзакции — ВСЕГДА используйте предоставленный экземпляр менеджера сущностей (в примере это transactionalEntityManager). НЕ ИСПОЛЬЗУЙТЕ ГЛОБАЛЬНЫЙ МЕНЕДЖЕР СУЩНОСТЕЙ. ВСЕ операции ДОЛЖНЫ выполняться через предоставленный транзакционный менеджер сущностей.

Указание уровня изоляции​

Уровень изоляции транзакции можно задать через первый параметр:

await myDataSource.manager.transaction(
    "SERIALIZABLE",
    (transactionalEntityManager) => {},
)

Поддерживаемые уровни изоляции​

Реализации уровней изоляции не являются универсальными для всех баз данных. Каждый драйвер объявляет поддерживаемые уровни, и TypeORM выбросит ошибку при запросе неподдерживаемого уровня.

CockroachDB

  • READ COMMITTED — requires the cluster setting sql.txn.read_committed_isolation.enabled, which is enabled by default in recent versions
  • REPEATABLE READ — requires the cluster setting sql.txn.repeatable_read_isolation.enabled, which is disabled by default (introduced in v24.3.0)
  • SERIALIZABLE (default)

CockroachDB maps weaker SQL isolation requests to stronger levels. The fallback behavior depends on the corresponding cluster settings. For example, when you request READ UNCOMMITTED, READ COMMITTED or REPEATABLE READ via SQL (e.g. BEGIN TRANSACTION ISOLATION LEVEL READ UNCOMMITTED), CockroachDB accepts the syntax and may run the transaction at a stricter level instead:

  • READ COMMITTED → runs as:
    • SERIALIZABLE if sql.txn.read_committed_isolation.enabled is false and sql.txn.repeatable_read_isolation.enabled is false
    • REPEATABLE READ if sql.txn.repeatable_read_isolation.enabled is true and sql.txn.read_committed_isolation.enabled is false
  • READ UNCOMMITTED → runs as:
    • SERIALIZABLE if sql.txn.read_committed_isolation.enabled is false and sql.txn.repeatable_read_isolation.enabled is false
    • READ COMMITTED if sql.txn.read_committed_isolation.enabled is true
    • REPEATABLE READ if sql.txn.repeatable_read_isolation.enabled is true and sql.txn.read_committed_isolation.enabled is false
  • REPEATABLE READ → runs as SERIALIZABLE if sql.txn.repeatable_read_isolation.enabled is false
Learn more

Уровень изоляции по умолчанию​

Вы можете настроить уровень изоляции по умолчанию для всех транзакций, установив параметр isolationLevel в опциях DataSource:

const dataSource = new DataSource({
    type: "postgres",
    isolationLevel: "SERIALIZABLE",
    // ...
})

При установке этого параметра все транзакции, запущенные без явного указания уровня изоляции, будут использовать это значение. Явно указанный уровень в transaction() или startTransaction() переопределит значение по умолчанию.

Использование QueryRunner для управления состоянием подключения к БД​

QueryRunner предоставляет единое подключение к базе данных. Транзакции организуются через query runner. Каждая транзакция привязана к конкретному экземпляру query runner. Вы можете вручную создать экземпляр query runner для управления состоянием транзакции. Пример:

// create a new query runner
const queryRunner = dataSource.createQueryRunner()

// establish real database connection using our new query runner
await queryRunner.connect()

// now we can execute any queries on a query runner, for example:
await queryRunner.query("SELECT * FROM users")

// we can also access entity manager that works with connection created by a query runner:
const users = await queryRunner.manager.find(User)

// lets now open a new transaction:
await queryRunner.startTransaction()

try {
    // execute some operations on this transaction:
    await queryRunner.manager.save(user1)
    await queryRunner.manager.save(user2)
    await queryRunner.manager.save(photos)

    // commit transaction now:
    await queryRunner.commitTransaction()
} catch (err) {
    // since we have errors let's rollback changes we made
    await queryRunner.rollbackTransaction()
} finally {
    // you need to release query runner which is manually created:
    await queryRunner.release()
}

В QueryRunner доступны 3 метода управления транзакциями:

  • startTransaction - начинает новую транзакцию в экземпляре query runner.

  • commitTransaction - фиксирует все изменения, выполненные с помощью экземпляра query runner.

  • rollbackTransaction - откатывает все изменения, выполненные с помощью экземпляра query runner.

Подробнее о Query Runner.