Go语言数据库操作如何处理事务_运维文库_资讯中心

发布时间:2026-04-29 06:56:35

阅读量:4

在Go语言中，处理数据库操作事务通常需要使用database/sql包和相应的数据库驱动。以下是一个简单的示例，展示了如何使用Go语言处理事务：

首先，确保已经安装了适当的数据库驱动。例如，如果你使用的是MySQL数据库，可以安装go-sql-driver/mysql驱动：

go get -u github.com/go-sql-driver/mysql

然后，编写一个简单的程序来处理事务：

package main

import (
	"database/sql"
	"fmt"
	"log"

	_ "github.com/go-sql-driver/mysql"
)

func main() {
	// 连接到数据库
	db, err := sql.Open("mysql", "username:password@tcp(localhost:3306)/dbname")
	if err != nil {
		log.Fatal(err)
	}
	defer db.Close()

	// 开始事务
	tx, err := db.Begin()
	if err != nil {
		log.Fatal(err)
	}

	// 准备SQL语句
	stmt, err := tx.Prepare("INSERT INTO users(name, age) VALUES (?, ?)")
	if err != nil {
		log.Fatal(err)
	}
	defer stmt.Close()

	// 执行SQL语句
	_, err = stmt.Exec("John Doe", 30)
	if err != nil {
		// 如果出现错误，回滚事务
		tx.Rollback()
		log.Fatal(err)
	}

	// 提交事务
	err = tx.Commit()
	if err != nil {
		log.Fatal(err)
	}

	fmt.Println("Transaction committed successfully")
}