设计 Golang 的事务 API

在设计 Golang 事务 API 时，面临的主要挑战是如何平衡事务管理与遵循干净架构的原则。本文探讨了三种潜在的方法：函数式方法、将事务作为存储库或作为值。每个方法都有其优缺点，例如函数式方法难以处理跨存储库的事务，而将事务作为值则需要在每个存储库方法中显式处理事务。本文最终建议将事务视为存储库实现中的内部引用，这符合干净架构的原则，并允许在单个事务中保留用户和图像数据。

我正在尝试使用 go 遵循清洁架构。该应用程序是一个简单的图像管理应用程序。

我想知道如何最好地设计我的存储库层的界面。我不想将所有存储库方法组合到一个大接口中，就像我发现的一些示例一样，我认为在 go 中小接口通常是首选。我认为有关管理图像的用例代码不需要知道存储库还存储用户。所以我想要 userreader、userwriter 和 imagereader 和 imagewriter。复杂的是代码需要是事务性的。关于事务管理属于清洁架构的问题存在一些争议，但我认为用例层需要能够控制事务。我认为，属于单个事务的是业务规则，而不是技术细节。

现在的问题是，如何构建接口？

函数式方法

因此，在这种方法中，我打开一个事务，运行提供的函数，如果没有错误则提交。

type userrepository interface {
    func readtransaction(txfn func (userreader) error) error
    func writetransaction(txfn func (userwriter) error) error
}

type imagerepository interface {
    func readtransaction(txfn func (imagereader) error) error
    func writetransaction(txfn func (imagewriter) error) error
}

问题：不，我无法在单个事务中轻松编写用户和图像，我必须为此创建一个额外的 userimagerepository 接口，并提供单独的实现。

交易作为存储库

type imagerepository interface {
    func writer() imagereadwriter
    func reader() imagereader
}

我认为这与函数式方法非常相似。它不能解决多个存储库组合使用的问题，但至少可以通过编写一个简单的包装器来实现。

实现可能如下所示：

type boltdbrepository struct {}
type boltdbtransaction struct { *bolt.tx }
func (tx *boltdbtransaction) writeimage(i usecase.image) error
func (tx *boltdbtransaction) writeuser(i usecase.user) error
....

不幸的是，如果我实现这样的事务方法：

func (r *boltdbrepository) writer() *boltdbtransaction
func (r *boltdbrepository) reader() *boltdbtransaction

因为这没有实现 imagerepository 接口，所以我需要一个简单的包装器

type imagerepository struct { *boltdbrepository }
func (ir *imagerepository) writer() usecase.imagereadwriter
func (ir *imagerepository) reader() usecase.imagereader

交易作为价值

type imagereader interface {
    func writeimage(tx transaction, i image) error
}

type transaction interface { 
    func commit() error
}

type repository interface {
    func begintransaction() (transaction, error)
}

存储库实现看起来像这样

type BoltDBRepository struct {}
type BoltDBTransaction struct { *bolt.Tx }

// implement ImageWriter
func (repo *BoltDBRepository) WriteImage(tx usecase.Transaction, img usecase.Image) error {
  boltTx := tx.(*BoltDBTransaction)
  ...
}

问题：虽然这可行，但我必须在每个存储库方法的开头键入断言，这看起来有点乏味。

所以这些是我可以想出的方法。哪个最合适，或者有更好的解决方案吗？

解决方案

存储库是保存数据的位置的表示，也是一个架构元素。

事务是解决非功能性需求（原子操作）的技术细节，因此必须像架构元素中的内部引用或私有函数一样使用它。

在这种情况下，如果您的存储库编写如下：

type userrepository interface {
    func keep(userdata) error
    func find(uuid) userdata
}

type imagerepository interface {
    func keep(imagedata) error
    func find(uuid) imagedata
}

事务方法是一个实现细节，因此您可以创建 userrepository 和 imagerepository 的“实现”，将其用作内部引用。

type userrepositoryimpl struct {
    tx transaction
}

func (r userrepository) func keep(userdata) error { return r.tx.on(...)} 
func (r userrepository) func find(uuid) userdata { return r.tx.withresult(...)}

通过这种方式，您也可以将用户和图像保留在单个事务中。

例如，如果客户端引用了 userrepository 和 imagerepository，并且它负责 userdata 和 imagedata 并且还希望将这两个数据保留在单个事务中，则：

//open transaction and set in participants
tx := openTransaction()
ur := NewUserRepository(tx)
ir := NewImageRepository(tx)
//keep user and image datas
err0 := ur.Keep(userData)
err1 := ir.Keep(imageData)
//decision
if err0 != nil || err1 != nil {
  tx.Rollback()
  return
}
tx.Commit()

这是干净、客观的，并且在洋葱架构、ddd 和 3 层架构（martin fowler）中工作得很好！

在洋葱架构中：

• 实体：用户和图像（无业务规则）
• 用例：存储库接口（应用规则：保留用户和图像）
• 控制者：a/n
• db/api：客户端、tx、存储库实现

终于介绍完啦！小伙伴们，这篇关于《设计 Golang 的事务 API》的介绍应该让你收获多多了吧！欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识，快来关注吧！