在Go语言中使用*sql.DB对象在一个事务中运行多个函数的惯用方法

package main

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

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

func main() {
	db, err := sql.Open("mysql", "user:password@tcp(localhost:3306)/database")
	if err != nil {
		log.Fatal(err)
	}
	defer db.Close()

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

	// 定义多个函数，每个函数执行一个数据库操作
	// 这些函数可以是你自己定义的，根据具体需求进行编写
	functions := []func(*sql.Tx) error{
		insertData,
		updateData,
		deleteData,
	}

	// 依次执行每个函数
	for _, fn := range functions {
		err := fn(tx)
		if err != nil {
			// 发生错误时回滚事务
			tx.Rollback()
			log.Fatal(err)
		}
	}

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

	fmt.Println("事务执行成功")
}

// 示例函数：向数据库插入数据
func insertData(tx *sql.Tx) error {
	_, err := tx.Exec("INSERT INTO table_name (column1, column2) VALUES (?, ?)", "value1", "value2")
	if err != nil {
		return err
	}
	return nil
}

// 示例函数：更新数据库数据
func updateData(tx *sql.Tx) error {
	_, err := tx.Exec("UPDATE table_name SET column1 = ? WHERE column2 = ?", "new_value", "condition")
	if err != nil {
		return err
	}
	return nil
}

// 示例函数：从数据库删除数据
func deleteData(tx *sql.Tx) error {
	_, err := tx.Exec("DELETE FROM table_name WHERE column = ?", "value")
	if err != nil {
		return err
	}
	return nil
}