在尝试使用buffalo-pop/pop/popmw Transaction
中间件时,我没有成功写入数据库。不返回任何错误,调试输出显示 SQL 语句,但不会提交更新和插入。
处理程序如下所示:
func MyHandler(c buffalo.Context) error {
tx, ok := c.Value("tx").(*pop.Connection)
if !ok {
return errors.New("no transaction found")
}
f := models.File{
Name: "file.txt",
}
if err := tx.Create(&f); err != nil {
return err
}
return nil
}
应用去:
func App() *buffalo.App {
...
app.GET("/myhandler", MyHandler)
app.Use(popmw.Transaction(models.DB))
...
}
如果我使用 DB, _ := pop.Connect("development")
进行连接,它可以正常工作。我还观察到,每次命中此处理程序时,表上的自动增量值都会发生变化。
在实际应用中,我们无法调用 c.Render
来报告响应代码,因为我们使用 gqlgen
作为 http 处理程序。它看起来像这样:
func GQLHandler(c buffalo.Context) error {
h := handler.GraphQL(gqlgen.NewExecutableSchema(gqlgen.Config{Resolvers: &gqlgen.Resolver{}}))
newCtx := context.WithValue(c.Request().Context(), "BuffaloContext", c)
h.ServeHTTP(c.Response(), c.Request().WithContext(newCtx))
return nil
}
Buffalo 的 Pop 中间件的一个功能是将操作和下面的中间件包装在数据库事务中的堆栈中。以下是从 Pop 中间件自动提交的条件:
- 如果执行中间件和操作时没有错误,则提交;响应状态为 2xx 或 3xx。
- 否则回滚。
来自布法罗与流行音乐的整合。
因此,请确保在您的操作或堆栈的中间件中没有返回错误;并且生成的响应状态为 200 左右或 300 左右。
如果 Buffalo 没有通过调用 c.Render
收到响应代码,则事务中间件会将请求视为不成功。由于这个问题的上下文是使用 gqlgen 的 GraphQL,并且不能使用c.Render
,我发现显式关闭事务是有效的。像这样:
func GQLHandler(c buffalo.Context) error {
gqlSuccess := true
h := handler.GraphQL(gqlgen.NewExecutableSchema(gqlgen.Config{Resolvers: &gqlgen.Resolver{}})),
handler.ErrorPresenter(
func(ctx context.Context, e error) *gqlerror.Error {
gqlSuccess = false
return graphql.DefaultErrorPresenter(ctx, e)
}))
newCtx := context.WithValue(c.Request().Context(), "BuffaloContext", c)
h.ServeHTTP(c.Response(), c.Request().WithContext(newCtx))
if !gqlSuccess {
return nil
}
tx, ok := c.Value("tx").(*pop.Connection)
if !ok {
return errors.New("no transaction found")
}
return tx.TX.Commit()
}