Golang에서 트랜잭션을 사용하는 방법은 무엇입니까?-Golang-php.cn

Golang에서 트랜잭션을 사용하는 방법은 무엇입니까?

WBOY

풀어 주다： 2024-06-04 12:13:56

원래의

877명이 탐색했습니다.

Go에서는 트랜잭션 작업에 Tx 유형을 사용할 수 있습니다. 트랜잭션을 시작하려면 db.Begin()을 사용하세요. 트랜잭션 블록에서는 쿼리, 업데이트 등의 데이터베이스 작업이 수행됩니다. 성공적으로 실행된 후 tx.Commit()을 사용하여 트랜잭션을 커밋합니다. 실제로 트랜잭션은 재고 업데이트 및 동시에 주문 생성과 같은 동시 작업의 일관성을 보장합니다.

如何在 Golang 中使用事务？

Go에서 트랜잭션을 어떻게 사용하나요?

Go에서 트랜잭션은 모두 성공하거나 모두 실패하는 원자적 작업의 모음입니다. 이는 특히 여러 동시 작업으로 인해 데이터가 손상될 수 있는 상황에서 데이터베이스 작업의 무결성을 보장하는 데 사용됩니다.

Go의 트랜잭션은 database/sql의 Tx 유형으로 표시됩니다. 트랜잭션을 시작하려면 다음을 수행하세요. 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
}

로그인 후 복사

트랜잭션 블록에서는 모든 데이터베이스 작업을 수행할 수 있습니다. 예를 들어 다음 코드는 테이블에서 레코드를 선택하고 새 값으로 업데이트합니다.