一个非侵入的Go事务管理库——工作原理

2020-07-09 00:00:00 函数数据库事务应用程序接口

在上一篇文章“一个非侵入的Go事务管理库——如何使用”中，我讲述了如何使用事务库。有些读者可能读过"清晰架构（Clean Architecture）的Go微服务: 事物管理" ，其中描述了事务管理系统的旧版本。那篇文章和本文之间会有一些重叠。因为大多数人可能还没有读过那篇文章或者即使读了也忘记了它的内容。因此为了照顾多数读者，本文还是从头开始（假设你没有读过前文）。如果你读过，那你可以直接跳过熟悉的部分。

好的事务库对于使用它的应用程序是透明的。在Go的“sql”库中，有两种类型的数据库链接，“sql.DB”和“sql.Tx”。当你不需要事务支持时，使用“sql.DB”;否则使用“sql.Tx”。为了让这两种不同场景共享相同的持久层代码，我们需要对数据库链接进行一个封装来同时支持这两种场景。我从"db transaction in golang" 里得到了这个想法。

数据库层的接口

数据库层是事务管理库中处理数据库访问的低层。应用程序不需要修改该层，只有事务管理库需要这样做。

数据库访问封装

下面是可同时支持事务和非事务操作的共享数据库访问接口，它在“gdbc.go”中定义。

// SqlGdbc (SQL Go database connection) is a wrapper for SQL database handler ( can be *sql.DB or *sql.Tx)
// It should be able to work with all SQL data that follows SQL standard.
type SqlGdbc interface {
    Exec(query string, args ...interface{}) (sql.Result, error)
    Prepare(query string) (*sql.Stmt, error)
    Query(query string, args ...interface{}) (*sql.Rows, error)
    QueryRow(query string, args ...interface{}) *sql.Row
    // If need transaction support, add this interface
    Transactioner
}

// Transactioner is the transaction interface for database handler
// It should only be applicable to SQL database
type Transactioner interface {
    // Rollback a transaction
    Rollback() error
    // Commit a transaction
    Commit() error
    // TxEnd commits a transaction if no errors, otherwise rollback
    // txFunc is the operations wrapped in a transaction
    TxEnd(txFunc func() error) error

}

相关文章