package main

import (
	"fmt"
	"github.com/gogf/gf/frame/g"
	"github.com/gogf/gf/database/gdb"
)

func main() {
	db := g.DB()

	// 开始事务
	tx, err := db.Begin()
	if err != nil {
		fmt.Println("事务开始失败:", err)
		return
	}

	// 插入操作
	_, err = tx.Table("user").Data(g.Map{"name": "Alice", "age": 25}).Insert()
	if err != nil {
		// 发生错误，回滚事务
		tx.Rollback()
		fmt.Println("插入数据失败:", err)
		return
	}

	// 更新操作
	_, err = tx.Table("user").Data(g.Map{"age": 26}).Where("name", "Alice").Update()
	if err != nil {
		// 发生错误，回滚事务
		tx.Rollback()
		fmt.Println("更新数据失败:", err)
		return
	}

	// 提交事务
	err = tx.Commit()
	if err != nil {
		// 提交失败，回滚事务
		tx.Rollback()
		fmt.Println("事务提交失败:", err)
		return
	}

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