Wenn Sie Webdienste schreiben, interagieren Sie wahrscheinlich mit einer Datenbank. Gelegentlich müssen Sie Änderungen vornehmen, die atomar angewendet werden müssen – entweder sind alle erfolgreich oder keine. Hier kommen Transaktionen ins Spiel. In diesem Artikel zeige ich Ihnen, wie Sie Transaktionen in Ihren Code implementieren, um Probleme mit undichten Abstraktionen zu vermeiden.
Ein häufiges Beispiel ist die Zahlungsabwicklung:
Normalerweise verfügt Ihre Anwendung über zwei Module, um die Geschäftslogik vom datenbankbezogenen Code zu trennen.
Dieses Modul übernimmt alle datenbankbezogenen Vorgänge, wie zum Beispiel SQL-Abfragen. Im Folgenden definieren wir zwei Funktionen:
import { Injectable } from '@nestjs/common';
import postgres from 'postgres';
@Injectable()
export class BillingRepository {
constructor(
private readonly db_connection: postgres.Sql,
) {}
async get_balance(customer_id: string): Promise<number | null> {
const rows = await this.db_connection`
SELECT amount FROM balances
WHERE customer_id=${customer_id}
`;
return (rows[0]?.amount) ?? null;
}
async set_balance(customer_id: string, amount: number): Promise<void> {
await this.db_connection`
UPDATE balances
SET amount=${amount}
WHERE customer_id=${customer_id}
`;
}
}
Das Servicemodul enthält Geschäftslogik, z. B. das Abrufen des Kontostands, seine Validierung und das Speichern des aktualisierten Kontostands.
import { Injectable } from '@nestjs/common';
import { BillingRepository } from 'src/billing/billing.repository';
@Injectable()
export class BillingService {
constructor(
private readonly billing_repository: BillingRepository,
) {}
async bill_customer(customer_id: string, amount: number) {
const balance = await this.billing_repository.get_balance(customer_id);
// The balance may change between the time of this check and the update.
if (balance === null || balance < amount) {
return new Error('Insufficient funds');
}
await this.billing_repository.set_balance(customer_id, balance - amount);
}
}
In der Funktion bill_customer rufen wir zunächst mit get_balance den Kontostand des Benutzers ab. Anschließend prüfen wir, ob das Guthaben ausreicht und aktualisieren es mit set_balance.
Das Problem mit dem obigen Code besteht darin, dass sich der Kontostand zwischen dem Abruf und der Aktualisierung ändern kann. Um dies zu vermeiden, müssen wir Transaktionen verwenden. Sie können dies auf zwei Arten lösen:
Stattdessen empfehle ich einen saubereren Ansatz.
Eine gute Möglichkeit, Transaktionen abzuwickeln, besteht darin, eine Funktion zu erstellen, die einen Rückruf in eine Transaktion einschließt. Diese Funktion stellt ein Sitzungsobjekt bereit, das keine unnötigen internen Details offenlegt und so undichte Abstraktionen verhindert. Das Sitzungsobjekt wird innerhalb der Transaktion an alle datenbankbezogenen Funktionen übergeben.
So können Sie es umsetzen:
import { Injectable } from '@nestjs/common';
import postgres, { TransactionSql } from 'postgres';
export type SessionObject = TransactionSql<Record<string, unknown>>;
@Injectable()
export class BillingRepository {
constructor(
private readonly db_connection: postgres.Sql,
) {}
async run_in_session<T>(cb: (sql: SessionObject) => T | Promise<T>) {
return await this.db_connection.begin((session) => cb(session));
}
async get_balance(
customer_id: string,
session: postgres.TransactionSql | postgres.Sql = this.db_connection
): Promise<number | null> {
const rows = await session`
SELECT amount FROM balances
WHERE customer_id=${customer_id}
`;
return (rows[0]?.amount) ?? null;
}
async set_balance(
customer_id: string,
amount: number,
session: postgres.TransactionSql | postgres.Sql = this.db_connection
): Promise<void> {
await session`
UPDATE balances
SET amount=${amount}
WHERE customer_id=${customer_id}
`;
}
}
In diesem Beispiel startet die Funktion run_in_session eine Transaktion und führt darin einen Rückruf aus. Der SessionObject-Typ abstrahiert die Datenbanksitzung, um den Verlust interner Details zu verhindern. Alle datenbankbezogenen Funktionen akzeptieren jetzt ein Sitzungsobjekt und stellen so sicher, dass sie an derselben Transaktion teilnehmen können.
Das Servicemodul wurde aktualisiert, um Transaktionen zu nutzen. So sieht es aus:
import { Injectable } from '@nestjs/common';
import postgres from 'postgres';
@Injectable()
export class BillingRepository {
constructor(
private readonly db_connection: postgres.Sql,
) {}
async get_balance(customer_id: string): Promise<number | null> {
const rows = await this.db_connection`
SELECT amount FROM balances
WHERE customer_id=${customer_id}
`;
return (rows[0]?.amount) ?? null;
}
async set_balance(customer_id: string, amount: number): Promise<void> {
await this.db_connection`
UPDATE balances
SET amount=${amount}
WHERE customer_id=${customer_id}
`;
}
}
In der Funktion bill_customer_transactional rufen wir run_in_session auf und übergeben einen Rückruf mit dem Sitzungsobjekt als Parameter. Anschließend übergeben wir diesen Parameter an jede Funktion des Repositorys, die wir aufrufen. Dadurch wird sichergestellt, dass sowohl get_balance als auch set_balance innerhalb derselben Transaktion ausgeführt werden. Wenn sich das Gleichgewicht zwischen den beiden Aufrufen ändert, schlägt die Transaktion fehl und die Datenintegrität bleibt erhalten.
Durch den effektiven Einsatz von Transaktionen wird sichergestellt, dass Ihre Datenbankvorgänge konsistent bleiben, insbesondere wenn mehrere Schritte erforderlich sind. Der von mir beschriebene Ansatz hilft Ihnen, Transaktionen zu verwalten, ohne dass Abstraktionen verloren gehen, und macht Ihren Code dadurch wartbarer. Versuchen Sie, dieses Muster in Ihrem nächsten Projekt zu implementieren, um Ihre Logik sauber und Ihre Daten sicher zu halten!
Danke fürs Lesen!
?Vergessen Sie nicht zu liken, wenn Ihnen der Artikel gefallen hat?
Kontakte
Wenn Ihnen dieser Artikel gefällt, zögern Sie nicht, sich auf LinkedIn zu vernetzen und mir auf Twitter zu folgen.
Abonnieren Sie meine Mailingliste: https://sergedevs.com
Unbedingt liken und folgen?
Das obige ist der detaillierte Inhalt vonSo schreiben Sie transaktionale Datenbankaufrufe in TypeScript. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!
