## 執行數據庫事務接口
在處理數據庫連接服務時,測試相對困難。原因在于Go的鴨子模型導致在運行時模擬很不方便。我建議在使用數據庫時使用存儲接口,使用這樣的方式模擬數據庫事務接口同樣可行,在后續章節會討論這一點。本節將著眼于對數據庫事務的操作。
我們將改寫上一節的create和query文件,最終的輸出很類似,但是create和query操作將包含在事務中。
### 實踐
1. 建立 transaction.go:
```
package dbinterface
import "database/sql"
// DB是sql.DB或sql.Transaction滿足的接口
type DB 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
}
// Transaction可以執行任何 Query, Commit, Rollback, 和 Stmt 操作
type Transaction interface {
DB
Commit() error
Rollback() error
Stmt(stmt *sql.Stmt) *sql.Stmt
}
```
2. 建立 create.go:
```
package dbinterface
import _ "github.com/go-sql-driver/mysql"
// Create建立example表并填充數據
func Create(db DB) error {
// create the database
if _, err := db.Exec("CREATE TABLE example (name VARCHAR(20), created DATETIME)"); err != nil {
return err
}
if _, err := db.Exec(`INSERT INTO example (name, created) values ("Aaron", NOW())`); err != nil {
return err
}
return nil
}
```
3. 建立 exec.go:
```
package dbinterface
func Exec(db DB) error {
// 依然不推薦這么寫 因為沒有處理所返回的可能存在的錯誤
defer db.Exec("DROP TABLE example")
if err := Create(db); err != nil {
return err
}
if err := Query(db); err != nil {
return err
}
return nil
}
```
4. 建立 main.go:
```
package main
import (
"github.com/agtorre/go-cookbook/chapter5/database"
"github.com/agtorre/go-cookbook/chapter5/dbinterface"
_ "github.com/go-sql-driver/mysql"
)
func main() {
db, err := database.Setup()
if err != nil {
panic(err)
}
tx, err := db.Begin()
if err != nil {
panic(err)
}
defer tx.Rollback()
if err := dbinterface.Exec(db); err != nil {
panic(err)
}
if err := tx.Commit(); err != nil {
panic(err)
}
}
```
5. 這會輸出:
```
Results:
Name: Aaron
Created: 2017-02-16 20:00:00 +0000 UTC
```
### 說明
本節與上一節以非常相似的方式工作,演示了使用事務并生成適用于sql.DB連接和sql.Transaction對象的通用數據庫函數。我們會在第八章看到對這些模擬接口的測試使用。
* * * *
學識淺薄,錯誤在所難免。歡迎在群中就本書提出修改意見,以饗后來者,長風拜謝。
Golang中國(211938256)
beego實戰(258969317)
Go實踐(386056972)
- 前言
- 第一章 I/O和文件系統
- 常見 I/O 接口
- 使用bytes和strings包
- 操作文件夾和文件
- 使用CSV格式化數據
- 操作臨時文件
- 使用 text/template和HTML/templates包
- 第二章 命令行工具
- 解析命令行flag標識
- 解析命令行參數
- 讀取和設置環境變量
- 操作TOML,YAML和JSON配置文件
- 操做Unix系統下的pipe管道
- 處理信號量
- ANSI命令行著色
- 第三章 數據類型轉換和解析
- 數據類型和接口轉換
- 使用math包和math/big包處理數字類型
- 貨幣轉換和float64注意事項
- 使用指針和SQL Null類型進行編碼和解碼
- 對Go數據編碼和解碼
- Go中的結構體標簽和反射
- 通過閉包實現集合操作
- 第四章 錯誤處理
- 錯誤接口
- 使用第三方errors包
- 使用log包記錄錯誤
- 結構化日志記錄
- 使用context包進行日志記錄
- 使用包級全局變量
- 處理恐慌
- 第五章 數據存儲
- 使用database/sql包操作MySQL
- 執行數據庫事務接口
- SQL的連接池速率限制和超時
- 操作Redis
- 操作MongoDB
- 創建存儲接口以實現數據可移植性
- 第六章 Web客戶端和APIs
- 使用http.Client
- 調用REST API
- 并發操作客戶端請求
- 使用OAuth2
- 實現OAuth2令牌存儲接口
- 封裝http請求客戶端
- 理解GRPC的使用
- 第七章 網絡服務
- 處理Web請求
- 使用閉包進行狀態處理
- 請求參數驗證
- 內容渲染
- 使用中間件
- 構建反向代理
- 將GRPC導出為JSON API
- 第八章 測試
- 使用標準庫進行模擬
- 使用Mockgen包
- 使用表驅動測試
- 使用第三方測試工具
- 模糊測試
- 行為驅動測試
- 第九章 并發和并行
- 第十章 分布式系統
- 第十一章 響應式編程和數據流
- 第十二章 無服務器編程
- 第十三章 性能改進