文档教程【免费下载链接】build-web-application-with-golangA golang ebook intro how to build a web with golang项目地址https://gitcode.com/gh_mirrors/bu/build-web-application-with-golang点击查看免费下载database/sql 是 Go 标准库中面向关系型数据库的统一接口层。与 PHP 不同Go 官方并未内置任何具体数据库驱动而是通过database/sql与database/sql/driver定义了一整套标准接口由第三方开发者按接口规范实现具体驱动。本文以本项目Build Web Application with Golang第 5.1 节为骨架逐层拆解sql.Register、driver.Driver、driver.Conn、driver.Stmt、driver.Tx等核心接口的设计意图、使用约束与实现要点并结合仓库内真实的 MySQL / SQLite / PostgreSQL 驱动使用示例de/code/src/apps/ch.5.2/main.go、de/code/src/apps/ch.5.3/main.go、de/code/src/apps/ch.5.4/main.go验证这些接口在实际 Web 应用中的调用链。读完本文你将掌握 Go 数据库驱动的工作机理、连接池的实现方式以及如何基于标准接口编写可无缝迁移数据库的代码。一、设计哲学接口与驱动分离Go 官方的设计思路是不提供数据库驱动只定义标准接口。开发者可以依据database/sql/driver包中定义的接口来开发相应的数据库驱动。这样做有一个直接好处——只要代码是基于标准接口编写的以后需要迁移数据库时不需要修改任何业务代码只需要更换引入的驱动包即可。整个体系分为两层database/sql/driver面向驱动开发者的底层接口规定驱动必须实现的最小能力集database/sql面向应用开发者的高层封装提供Open、Prepare、Query、Exec、Begin等便捷方法并在内部建议性地实现一个连接池conn pool。仓库第 5 章开篇即点明了这一架构的定位Go 没有内置驱动支持任何数据库但定义了 database/sql 接口用户可基于驱动接口开发相应数据库驱动见 zh/05.0.md。二、sql.Register驱动的注册入口sql.Register是database/sql包中用于注册数据库驱动的函数。第三方驱动开发者都会实现init函数并在其中调用func Register(name string, driver driver.Driver)完成驱动名称 → 驱动实现的注册。以两个知名驱动为例原文给出了它们的注册方式// github.com/mattn/go-sqlite3 驱动 func init() { sql.Register(sqlite3, SQLiteDriver{}) } // github.com/mikespook/mymysql 驱动 // Driver automatically registered in database/sql var d Driver{proto: tcp, raddr: 127.0.0.1:3306} func init() { Register(SET NAMES utf8) sql.Register(mymysql, d) }在database/sql内部驱动通过一个 map 存储var drivers make(map[string]driver.Driver) drivers[name] driver因此可以同时注册多个数据库驱动只要名称不重复。这也是为什么一个应用中可以同时引入 MySQL、SQLite 等多个驱动——它们各自注册了不同的名称mysql、sqlite3、postgres等互不冲突。例如仓库的 ORM 示例 de/code/src/apps/ch.5.5/main.go 同时引入了database/sql与 sqlite3 驱动而 MySQL 示例 de/code/src/apps/ch.5.2/main.go 则注册的是mysql。2.1 空导入_ github.com/mattn/go-sqlite3的妙用在实际使用database/sql接口和第三方库时经常看到这样的写法import ( database/sql _ github.com/mattn/go-sqlite3 )新手常被这个_所迷惑。其实这正是 Go 设计的巧妙之处在变量赋值中_是忽略赋值结果的占位符在包导入中使用_含义是引入该包但不在当前代码中直接使用其中定义的函数、变量等资源。关键在于包的初始化机制本书 2.3 节流程和函数中介绍过init函数包在被引入时会自动调用其init函数以完成初始化。因此引入上面的数据库驱动包之后会自动触发init进而在init里完成驱动注册。这样我们就可以在接下来的代码中直接使用这个驱动了而无需在代码里显式引用驱动包中的任何符号。仓库中的示例代码全部遵循这一模式如 de/code/src/apps/ch.5.2/main.goimport ( database/sql fmt _ github.com/go-sql-driver/mysql )三、driver.Driver驱动的最顶层接口Driver是数据库驱动的接口它只定义了一个方法Open(name string)返回一个数据库的Conn接口type Driver interface { Open(name string) (Conn, error) }第三方驱动都会实现这个函数它解析name参数即 DSNData Source Name来获取相关数据库的连接信息解析完成后使用该信息初始化一个Conn并返回。关键约束返回的Conn只能用于一次 goroutine 操作不能把它应用到 Go 的多个 goroutine 中。如下代码会出现错误... go goroutineA (Conn) //执行查询操作 go goroutineB (Conn) //执行插入操作 ...这样的代码可能使 Go 无法确定某个操作究竟由哪个 goroutine 发起从而导致数据混乱——比如可能把 goroutineA 中执行的查询操作的结果返回给 goroutineB使 B 错误地把此结果当成自己执行的插入数据。这是driver层接口反复强调的核心约束请务必牢记。四、driver.Conn单 goroutine 内的连接Conn是数据库连接的接口定义定义了连接生命周期内的三个核心方法type Conn interface { Prepare(query string) (Stmt, error) Close() error Begin() (Tx, error) }同样这个Conn只能应用在一个 goroutine 里面不能用在多个 goroutine 中。Prepare返回与当前连接相关的执行 SQL 语句的准备状态Stmt可以进行查询、删除等操作Close关闭当前的连接释放连接拥有的资源等清理工作。因为驱动实现了database/sql里面建议的 conn pool所以你不需要再去自行实现缓存 conn自行缓存反而容易引起问题Begin返回一个代表事务处理的Tx通过它可以进行查询、更新等操作或者对事务进行回滚、递交。五、driver.Stmt预编译语句状态Stmt是一种准备好的状态和Conn相关联同样只能应用于一个 goroutine 中type Stmt interface { Close() error NumInput() int Exec(args []Value) (Result, error) Query(args []Value) (Rows, error) }Close关闭当前的语句状态但如果当前正在执行 queryquery 仍然有效并返回 rows 数据NumInput返回当前预留参数的个数。当返回值 0时数据库驱动会智能检查调用者传入的参数个数当驱动包不知道预留参数的时候返回 -1Exec执行 Prepare 准备好的 SQL传入参数执行 update/insert 等操作返回Result数据Query执行 Prepare 准备好的 SQL传入需要的参数执行 select 操作返回Rows结果集。预编译Prepared Statement也是防 SQL 注入的重要机制参数以?MySQL/SQLite或$1PostgreSQL占位符传递驱动负责将参数与 SQL 分离处理。仓库示例 de/code/src/apps/ch.5.4/main.go 展示了 PostgreSQL 的$1/$2/$3占位符风格而 MySQL/SQLite 示例则使用?占位符可见具体占位符语法由各驱动决定但接口层面统一。六、driver.Tx事务的两步操作事务处理一般就两个过程递交Commit或回滚Rollback。数据库驱动里面也只需要实现这两个函数type Tx interface { Commit() error Rollback() error }一个函数用来递交事务一个用来回滚事务。database/sql层的db.Begin()会返回一个符合该接口的事务对象业务代码通过tx.Commit()或tx.Rollback()控制事务的最终结果。七、driver.ExecerConn 的可选优化接口Execer是一个Conn可选择实现的接口type Execer interface { Exec(query string, args []Value) (Result, error) }如果这个接口没有定义那么在调用DB.Exec时会走通用路径首先调用Prepare返回Stmt然后执行Stmt的Exec最后关闭Stmt。实现该接口的驱动则可以跳过 Prepare 步骤直接执行从而减少一次往返获得性能上的优化。八、driver.Result写操作的结果Result是执行 Update/Insert 等操作返回的结果接口定义type Result interface { LastInsertId() (int64, error) RowsAffected() (int64, error) }LastInsertId返回由数据库执行插入操作得到的自增 ID 号RowsAffected返回执行 Update/Insert 等操作影响的数据条目数。实际使用中这两者正是业务代码最关心的写操作反馈。仓库的 CRUD 示例清晰地展示了其用法de/code/src/apps/ch.5.2/main.gores, err : stmt.Exec(astaxie, software developement, 2012-12-09) checkErr(err) id, err : res.LastInsertId() // 插入后拿到自增 ID checkErr(err)以及更新/删除后统计受影响行数res, err stmt.Exec(astaxieupdate, id) checkErr(err) affect, err : res.RowsAffected() checkErr(err) fmt.Println(affect, row(s) changed)九、driver.Rows查询结果集迭代器Rows是执行查询返回的结果集接口定义type Rows interface { Columns() []string Close() error Next(dest []Value) error }Columns返回查询数据库表的字段信息。注意这个返回的 slice 与SQL 查询中选出的字段一一对应而不是返回整个表的所有字段Close用来关闭 Rows 迭代器Next用来返回下一条数据把数据赋值给dest。dest里面的元素必须是driver.Value的值除了 string返回的数据里面所有的 string 都必须要转换成[]byte。如果最后没有数据了Next函数最后返回io.EOF。上层database/sql的rows.Next()rows.Scan(dest...)正是建立在driver.Rows.Next之上的。仓库示例展示了完整的遍历模式rows, err : db.Query(SELECT * FROM userinfo) checkErr(err) for rows.Next() { var uid int var username, department, created string err rows.Scan(uid, username, department, created) checkErr(err) fmt.Printf(%3v | %6v | %6v | %6v\n, uid, username, department, created) }十、driver.RowsAffectedResult 的便捷实现RowsAffected其实就是一个int64的别名但它实现了Result接口用于底层表示Resulttype RowsAffected int64 func (RowsAffected) LastInsertId() (int64, error) func (v RowsAffected) RowsAffected() (int64, error)驱动实现 Exec 时可以直接返回RowsAffected(n)作为Result其中n为受影响的行数无需自行构造完整的 Result 类型LastInsertId则返回错误如ErrLastInsertId表示该驱动不提供自增 ID 信息。十一、driver.Value驱动数据的统一载体Value其实就是一个空接口它可以容纳任何的数据type Value interface{}但驱动必须能够操作的Value是有限集合Value要么是nil要么是下面任意一种int64 float64 bool []byte string [*] 除了 Rows.Next 返回的不能是 string time.Time这个受限集合保证了驱动层与上层类型转换的可预期性整数统一为int64、浮点统一为float64、时间统一为time.Time从而屏蔽了各数据库底层类型的差异。十二、driver.ValueConverter 与 driver.Valuer双向类型转换ValueConverter接口定义了如何把一个普通的值转化成driver.Valuetype ValueConverter interface { ConvertValue(v interface{}) (Value, error) }在开发的数据库驱动包里面实现这个接口的函数在很多地方会使用到。ValueConverter有很多好处转化driver.Value到数据库表相应的字段例如int64的数据如何转化成数据库表uint16字段把数据库查询结果转化成driver.Value值在 scan 函数里面如何把driver.Value值转化成用户定义的值。Valuer接口则定义了返回一个driver.Value的方式type Valuer interface { Value() (Value, error) }很多类型都实现了这个Value方法用于自身与driver.Value的相互转化。两者方向相反Valuer负责业务类型 → driver.Value写库方向ValueConverter负责driver.Value ↔ 数据库/业务类型读库与参数转换方向。十三、database/sql 高层封装与简易连接池database/sql在database/sql/driver提供的接口基础上定义了一些更高阶的方法用以简化数据库操作同时内部还建议性地实现一个 conn pooltype DB struct { driver driver.Driver dsn string mu sync.Mutex // protects freeConn and closed freeConn []driver.Conn closed bool }可以看到Open函数返回的是DB对象里面有一个freeConn它就是那个简易的连接池。它的实现相当简单或者说简陋当执行db.prepare→db.prepareDC的时候会defer dc.releaseConn然后调用db.putConn也就是把这个连接放入连接池每次调用db.conn的时候会先判断freeConn的长度是否大于 0大于 0说明有可以复用的 conn直接拿出来用不大于 0则创建一个 conn然后再返回之。sync.Mutex用于保护freeConn与closed字段保证多 goroutine 场景下连接池的并发安全——这一点也回应了前面Conn 只能单 goroutine 使用的约束database/sql通过连接池按需分配让每个 goroutine 在任意时刻持有的底层连接都是独占的。十四、面向应用开发者从接口到实战的完整链路理解了驱动接口再回头看应用层的调用一切就串起来了。database/sql对外暴露的高层 API 与底层接口的对应关系如下应用层 API底层驱动接口说明sql.Open(driverName, dsn)driver.Driver.Open按注册名找到驱动并建立连接db.Prepare(query)driver.Conn.Prepare预编译 SQLstmt.Exec(args...)driver.Stmt.Exec/driver.Execer.Exec写操作stmt.Query(args...)driver.Stmt.Query读操作rows.Scan(dest...)driver.Rows.Next/driver.ValueConverter结果集逐行扫描与类型转换db.Begin()driver.Conn.Begin开启事务tx.Commit()/tx.Rollback()driver.Tx事务递交/回滚仓库中的三个 CRUD 示例完整演示了这条链路在不同数据库上的落地MySQLde/code/src/apps/ch.5.2/main.goDSN 形如user:password/test?charsetutf8占位符为?SQLitede/code/src/apps/ch.5.3/main.goDSN 直接是数据库文件路径./foo.dbPostgreSQLde/code/src/apps/ch.5.4/main.goDSN 形如user... password... dbname... sslmodedisable占位符为$1。三个示例的 CRUD 流程结构几乎一致这正是标准接口带来的可迁移性的直观体现业务代码只依赖database/sql更换驱动即可切换数据库。MySQL 驱动与 DSN 格式的更多细节可继续阅读本书下一节 使用 MySQL 数据库。十五、总结一个驱动只要实现了driver.Driver、driver.Conn、driver.Stmt、driver.Tx以及driver.Result、driver.Rows等接口就能完成增删查改等基本操作剩下的就是与相应数据库进行数据交互等细节问题。database/sql在其上提供的高层 API 与连接池则让应用开发者无需关心连接复用与 goroutine 隔离的底层细节。需要特别注意的是贯穿始终的单 goroutine 约束Conn、Stmt、Tx、Rows等驱动层对象都只允许在单个 goroutine 中使用并发安全由database/sql层的连接池机制来保障。理解了这一点你就能在编写高并发 Web 应用时正确使用 database/sql也能在需要时读懂甚至编写自己的数据库驱动。本节的进一步延伸事务与 ORM 实践可参见 5.5 使用 ORM 库操作数据库非关系型数据库的使用见 5.6 NOSQL 数据库操作回到本教程主线可返回 第 5 章 访问数据库 或 目录。赞分享文档教程【免费下载链接】build-web-application-with-golangA golang ebook intro how to build a web with golang项目地址https://gitcode.com/gh_mirrors/bu/build-web-application-with-golang点击查看免费下载相关推荐如何快速掌握Go SQLite3数据库驱动从入门到精通的完整指南如何快速掌握Go SQLite3数据库驱动从入门到精通的完整指南 go sqlite3是一个符合Go语言内置database/sql接口的SQLite3数据库数据库嵌入式数据库从零理解 Go 数据库驱动接口database/sql 与 database/sql/driver 全解析Build Web Application with Golang从零理解 Go 数据库驱动接口database/sql 与 database/sql/driver 全解析Build Web Application wit文档教程深入解析 Go 的 database/sql 接口从驱动注册到连接池的完整设计深入解析 Go 的 database/sql 接口从驱动注册到连接池的完整设计 导读 本文以开源电子书《Build Web Application with文档教程创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考