Wie verwende ich Transaktionen in Golang?

In Go können Sie den Tx-Typ für Transaktionsvorgänge verwenden. Um eine Transaktion zu starten, verwenden Sie db.Begin(). Im Transaktionsblock werden Datenbankoperationen wie Abfragen und Aktualisierungen durchgeführt. Verwenden Sie nach erfolgreicher Ausführung tx.Commit(), um die Transaktion festzuschreiben. In der Praxis stellen Transaktionen die Konsistenz für gleichzeitige Vorgänge sicher, z. B. das Aktualisieren des Lagerbestands und das gleichzeitige Erstellen von Bestellungen.

Wie verwende ich Transaktionen in Go?

In Go ist eine Transaktion eine Sammlung atomarer Operationen, die entweder alle erfolgreich sind oder alle fehlschlagen. Sie werden verwendet, um die Integrität von Datenbankvorgängen sicherzustellen, insbesondere in Situationen, in denen mehrere gleichzeitige Vorgänge zu Datenbeschädigungen führen könnten.

Transaktionen in Go werden durch den Typ Tx in database/sql dargestellt. Um eine Transaktion zu starten, gehen Sie wie folgt vor: database/sql 中的 Tx 类型表示。要开始一个事务，请执行以下操作：

tx, err := db.Begin()
if err != nil {
    return fmt.Errorf("failed to begin transaction: %w", err)
}

在事务块中，您可以执行任何数据库操作。例如，以下代码从表中选择一条记录并将其更新为新值：

var id, version int
if err := tx.QueryRow("SELECT id, version FROM example WHERE name = ?", "foo").Scan(&id, &version); err != nil {
    return fmt.Errorf("failed to select: %w", err)
}

result, err := tx.Exec("UPDATE example SET version = ? WHERE id = ? AND version = ?", version+1, id, version)
if err != nil {
    return fmt.Errorf("failed to update: %w", err)
}

在所有操作成功执行后，您可以使用 tx.Commit() 提交事务：

if err := tx.Commit(); err != nil {
    // 放弃事务
    if err := tx.Rollback(); err != nil {
        return fmt.Errorf("failed to rollback transaction: %w", err)
    }
    return fmt.Errorf("failed to commit transaction: %w", err)
}

实战案例

考虑一个网上商店的数据库，该数据库包括一个 products 表和一个 orders

func CreateOrder(db *sql.DB, productID int, quantity int) error {
    tx, err := db.Begin()
    if err != nil {
        return fmt.Errorf("failed to begin transaction: %w", err)
    }

    var stock int
    if err := tx.QueryRow("SELECT stock FROM products WHERE id = ?", productID).Scan(&stock); err != nil {
        return fmt.Errorf("failed to select: %w", err)
    }

    if stock < quantity {
        return tx.Rollback() // 放弃事务，因为没有足够的库存
    }

    if _, err := tx.Exec("UPDATE products SET stock = ? WHERE id = ?", stock-quantity, productID); err != nil {
        return fmt.Errorf("failed to update: %w", err)
    }

    if _, err := tx.Exec("INSERT INTO orders (product_id, quantity) VALUES (?, ?)", productID, quantity); err != nil {
        return fmt.Errorf("failed to insert: %w", err)
    }

    if err := tx.Commit(); err != nil {
        return fmt.Errorf("failed to commit transaction: %w", err)
    }

    return nil
}

Im Transaktionsblock können Sie jede Datenbankoperation ausführen. Der folgende Code wählt beispielsweise einen Datensatz aus der Tabelle aus und aktualisiert ihn mit einem neuen Wert:

rrreee
1. Nachdem alle Vorgänge erfolgreich ausgeführt wurden, können Sie tx.Commit() verwenden, um die Transaktion festzuschreiben :
rrreee

Praktischer Fall

2. Stellen Sie sich eine Online-Shop-Datenbank vor, die eine Produkte-Tabelle und eine Bestellungen-Tabelle enthält. Wir möchten eine Transaktion erstellen, um Folgendes zu tun:

Überprüfen Sie, ob ein Produkt über genügend Lagerbestand verfügt.

🎜Wenn Lagerbestand vorhanden ist, wird der Lagerbestand des Produkts abgezogen und eine Bestellung erstellt. 🎜🎜rrreee🎜Durch die Verwendung von Transaktionen stellen wir sicher, dass der Lagerbestand des Geschäfts immer korrekt ist, auch wenn mehrere gleichzeitige Bestellungen versuchen, den Lagerbestand desselben Produkts abzuziehen. 🎜

Das obige ist der detaillierte Inhalt vonWie verwende ich Transaktionen in Golang?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!