Transaktionen

Inoffizielle Beta-Übersetzung

Diese Seite wurde von PageTurner AI übersetzt (Beta). Nicht offiziell vom Projekt unterstützt. Fehler gefunden? Problem melden →

Erstellen und Verwenden von Transaktionen

Transaktionen werden mit DataSource oder EntityManager erstellt. Beispiele:

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

oder

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

Alles, was in einer Transaktion ausgeführt werden soll, muss innerhalb eines Callbacks erfolgen:

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

Die wichtigste Einschränkung bei Transaktionen ist: IMMER die bereitgestellte Entity Manager-Instanz verwenden – hier transactionalEntityManager. KEINESFALLS DEN GLOBALEN ENTITY MANAGER VERWENDEN. Alle Operationen MÜSSEN mit dem bereitgestellten transaktionalen Entity Manager ausgeführt werden.

Festlegen von Isolationsstufen

Die Isolationsstufe kann durch Angabe als ersten Parameter festgelegt werden:

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

Isolationsstufen werden nicht datenbankübergreifend einheitlich implementiert.

Folgende Datenbanktreiber unterstützen die Standard-Isolationsstufen (READ UNCOMMITTED, READ COMMITTED, REPEATABLE READ, SERIALIZABLE):

• MySQL

• Postgres

• SQL Server

SQLite verwendet standardmäßig SERIALIZABLE. Bei aktiviertem shared cache mode kann jedoch READ UNCOMMITTED genutzt werden.

Oracle unterstützt nur READ COMMITTED und SERIALIZABLE.

QueryRunner zur Steuerung einzelner Datenbankverbindungen

Ein QueryRunner stellt eine einzelne Datenbankverbindung bereit. Transaktionen werden über Query Runner organisiert. Pro Query Runner kann nur eine Transaktion aktiv sein. Sie können manuell eine Query Runner-Instanz erstellen und Transaktionen steuern: Beispiel:

// 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 bietet drei Transaktionssteuerungsmethoden:

• startTransaction - startet eine neue Transaktion innerhalb der Query Runner-Instanz.

• commitTransaction - committet alle Änderungen, die mit der Query Runner-Instanz durchgeführt wurden.

• rollbackTransaction - rollt alle Änderungen zurück, die mit der Query Runner-Instanz durchgeführt wurden.

Mehr Details unter Query Runner.