当前位置：首页 > news >正文

go-gf框架两个表以事务方式写入示例

news 2025/6/30 9:19:37

下面是对每一行代码的中文解释：

// 创建数据库连接对象
var tx gdb.TX

这行代码声明了一个名为tx的变量，类型为gdb.TX，表示数据库事务对象。

// 开启事务
if tx, err = g.DB().Ctx(ctx).Begin(ctx); err == nil {

这行代码通过在数据库连接（g.DB()）上调用Begin方法以给定的上下文（ctx）开始一个事务。如果没有错误（err == nil），则将返回的事务对象赋值给变量tx。

// 获取当前时间
CurrentTime := gtime.Now()

这行代码使用gtime.Now()函数获取当前时间，并将其赋值给变量CurrentTime。

// 写支付记录
_, err4 := dao.PayTradeOrder.Ctx(ctx).TX(tx).Insert(appdo.PayTradeOrder{// 支付记录字段...
})

这行代码将一个新的支付记录插入数据库。它使用dao.PayTradeOrder.Ctx(ctx).TX(tx)指定了上下文和事务对象，然后使用Insert方法将appdo.PayTradeOrder结构体的字段插入数据库。

// 写套餐订单记录
_, err5 := systemdao.UserBuySetMeal.Ctx(ctx).TX(tx).Insert(do.UserBuySetMeal{// 套餐订单记录字段...
})

这行代码将一条新的套餐订单记录插入数据库。它使用systemdao.UserBuySetMeal.Ctx(ctx).TX(tx)指定了上下文和事务对象，然后使用Insert方法将do.UserBuySetMeal结构体的字段插入数据库。

// 提交事务
if err := tx.Commit(); err != nil {// 处理提交事务错误liberr.ErrIsNil(context.Background(), errors.New("创建下单错误：提交事务失败"), "创建下单错误：提交事务失败")return
}

这行代码提交事务。如果提交事务发生错误，会通过liberr.ErrIsNil函数处理错误。

// 打印结果
fmt.Println("事务操作完成")

这行代码打印结果信息，输出"事务操作完成"。

} else {// 处理开启事务错误liberr.ErrIsNil(context.Background(), errors.New("创建下单错误：事务操作失败"), "创建下单错误：事务操作失败")
}

这行代码处理开启事务错误，通过liberr.ErrIsNil函数处理错误。

完整代码供参考

// 创建数据库连接对象var tx gdb.TX// 开启事务if tx, err = g.DB().Ctx(ctx).Begin(ctx); err == nil {// 获取当前时间CurrentTime := gtime.Now()// 写支付记录_, err4 := dao.PayTradeOrder.Ctx(ctx).TX(tx).Insert(appdo.PayTradeOrder{OrderNo:        "2023245231231",                         // 订单号//写入其他数据字段})if err4 != nil {// 回滚事务err := tx.Rollback()if err != nil {liberr.ErrIsNil(context.Background(), errors.New("创建下单错误：创建支付数据回滚事务错误"), "创建下单错误：创建支付数据回滚事务错误")return}// 处理错误liberr.ErrIsNil(context.Background(), errors.New("创建下单错误：创建支付数据错误"), "创建下单错误：创建支付数据错误")return}// 写套餐订单记录_, err5 := systemdao.UserBuySetMeal.Ctx(ctx).TX(tx).Insert(do.UserBuySetMeal{UserId:         userid,                                // 用户id//写入其他数据字段})if err5 != nil {// 回滚事务err := tx.Rollback()if err != nil {liberr.ErrIsNil(context.Background(), errors.New("创建下单错误：创建套餐订单回滚事务数据错误"), "创建下单错误：创建套餐订单回滚事务数据错误")return}// 处理错误liberr.ErrIsNil(context.Background(), errors.New("创建下单错误：创建套餐订单数据错误"), "创建下单错误：创建套餐订单数据错误")return}// 提交事务if err := tx.Commit(); err != nil {// 处理提交事务错误liberr.ErrIsNil(context.Background(), errors.New("创建下单错误：提交事务失败"), "创建下单错误：提交事务失败")return}// 打印结果fmt.Println("事务操作完成")} else {// 处理开启事务错误liberr.ErrIsNil(context.Background(), errors.New("创建下单错误：事务操作失败"), "创建下单错误：事务操作失败")}