Zum Hauptinhalt springen
Inoffizielle Beta-Übersetzung

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

Transaktionen

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 der Isolationsstufe​

Die Isolationsstufe kann durch Angabe als ersten Parameter festgelegt werden:

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

Unterstützte Isolationsstufen​

Die Implementierung von Isolationsstufen ist nicht einheitlich für alle Datenbanken. Jeder Treiber deklariert, welche Stufen er unterstützt, und TypeORM wirft einen Fehler, wenn Du eine nicht unterstützte Stufe anforderst.

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

Standard-Isolationsstufe​

Du kannst eine Standard-Isolationsstufe für alle Transaktionen konfigurieren, indem du isolationLevel in den DataSource-Optionen setzt:

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

Wenn diese gesetzt ist, verwenden alle Transaktionen ohne explizite Isolationsstufe diesen Standardwert. Eine explizite Isolationsstufe, die an transaction() oder startTransaction() übergeben wird, überschreibt den Standard.

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.

Weitere Informationen zum Query Runner.