3

在尝试使用 buffalo-pop/pop/popmwTransaction中间件时，我没有成功写入数据库。没有返回任何错误，并且调试输出显示了 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
}

应用程序.go：

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
}
4

2 回答 2

4

Buffalo 的 Pop 中间件的功能之一是将操作和下面的中间件包装在数据库事务中的堆栈中。以下是 Pop 中间件自动提交的条件：

  • 如果执行中间件和操作没有错误，则提交；响应状态为 2xx 或 3xx。
  • 否则回滚。

来自Buffalo 与 Pop 的整合。

因此，请确保在您的操作或堆栈的中间件中没有返回错误；并且产生的响应状态是 200-ish 或 300-ish。

于 2019-11-21T22:17:37.357 回答
2

如果 Buffalo 通过调用 没有收到响应代码c.Render，则 Transaction 中间件将请求视为不成功。由于这个问题的上下文是使用 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()
}
于 2019-11-22T16:17:31.773 回答