package main

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

func main() {
	// 初始化数据库配置
	g.Cfg().SetPath("config")
	g.DB().SetConfig(gdb.Config{
		LinkInfo: "root:password@tcp(127.0.0.1:3306)/test",
		Type:     "mysql",
	})

	// 在上下文中设置变量
	ctx := context.WithValue(context.Background(), "requestId", "123456")

	// 传递上下文变量进行数据库操作
	InsertUser(ctx, &User{
		Name: "Alice",
		Age:  25,
	})
}

type User struct {
	Id   int    `orm:"id,primary" json:"id"`
	Name string `orm:"name" json:"name"`
	Age  int    `orm:"age" json:"age"`
}

func InsertUser(ctx context.Context, user *User) {
	// 从上下文中获取变量
	requestId := ctx.Value("requestId")
	fmt.Println("Request ID:", requestId)

	// 进行数据库插入操作
	result, err := g.DB().Table("user").Data(user).Insert()
	if err != nil {
		fmt.Println("InsertUser error:", err)
	} else {
		lastInsertId, _ := result.LastInsertId()
		fmt.Println("New user ID:", lastInsertId)
	}
}