5.1 go-sql-driver/mysql

Go使用SQL与类SQL数据库的惯例是通过标准库database/sql。这是一个对关系型数据库的通用抽象，它提供了标准的、轻量的、面向行的接口。Go本身不提供具体数据库驱动，只提供驱动接口和管理，要使用数据库，除了database/sql包本身，还需要引入想使用的特定数据库驱动。

现推荐一个我在项目中用到的驱动：

https://github.com/go-sql-driver/mysql

特征

  • 轻巧快速
  • Native Go实现。没有C-bindings，只是纯粹的Go
  • 通过TCP / IPv4，TCP / IPv6，Unix域套接字或自定义协议进行连接
  • 自动处理断开的连接
  • 自动连接池（通过database / sql包）
  • 支持大于16MB的查询
  • 全力sql.RawBytes支持。
  • LONG DATA准备好的报表中的智能处理
  • LOAD DATA LOCAL INFILE通过文件白名单和io.Reader支持提供安全支持
  • 可选的time.Time解析
  • 可选的占位符插值

要求

  • 去1.8或更高。我们的目标是支持Go的3个最新版本。
  • MySQL（4.1 +），MariaDB，Percona Server，Google CloudSQL或Sphinx（2.2.3+）

安装

使用shell中的go工具将包简单地安装到$ GOPATH：

  1. $ go get -u github.com/go-sql-driver/mysql

确保Git已安装在您的计算机和系统中PATH。

用法

使用sql.Open方法会创建一个数据库连接池db。这个db不是数据库连接，它是一个连接池，只有当真正数据库通信的时候才创建连接。例如这里的db.Ping的操作。db.SetMaxIdleConns(20)和db.SetMaxOpenConns(20)分别设置数据库的空闲连接和最大打开连接，即向Mysql服务端发出的所有连接的最大数目。

注意：sql.DB对象是为了长连接而设计的，不要频繁Open()和Close()数据库。而应该为每个待访问的数据库创建一个sql.DB示例，并在用完前一直保留它。需要时可将其作为参数传递，或注册为全局对象。

如果没有按照database/sql设计的意图，不把sql.DB当成长期对象来用而频繁开关启停，就可能遭遇各式各样的错误：无法复用和共享连接，耗尽网络资源，由于TCP连接保持在TIME_WAIT状态而间断性的失败等

示例：

  1. package main
  3. import (
  4.    "database/sql"
  5.    _ "github.com/go-sql-driver/mysql"
  6.    "log"
  7. )
  9. func main() {
  11.    db, err := sql.Open("mysql", "root:123456@tcp(127.0.0.1:3306)/testdb?charset=utf8mb4&parseTime=true")
  12.    defer db.Close()
  13.    if err != nil {
  14.       log.Fatalln(err)
  15.    }
  16.    //用于设置闲置的连接数。如果 <= 0, 则没有空闲连接会被保留
  17.    db.SetMaxIdleConns(0)
  18.    //用于设置最大打开的连接数,默认值为0表示不限制。
  19.    db.SetMaxOpenConns(30)
  20.    if err := db.Ping(); err != nil {
  21.       log.Fatalln(err)
  22.    }
  24. }

测试表

  1. CREATE TABLE `user` (
  2.   `id` int(10) NOT NULL COMMENT '主键',
  3.   `name` varchar(100) NOT NULL DEFAULT '' COMMENT '名字',
  4.   `ctime` int(11) NOT NULL DEFAULT '0' COMMENT '创建时间'
  5. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;

示例：

  1. package main
  3. import (
  4.    "database/sql"
  5.    "fmt"
  6.    _ "github.com/go-sql-driver/mysql"
  7.    "log"
  8.    "time"
  9. )
  11. var db *sql.DB
  13. func main() {
  14.    var err error
  15.    db, err = sql.Open("mysql", "root:123456@tcp(127.0.0.1:3306)/testdb?charset=utf8mb4&parseTime=true&&loc=Local")
  16.    //parseTime是查询结果是否自动解析为时间。
  17.    //loc是MySQL的时区设置。
  18.    defer db.Close()
  19.    if err != nil {
  20.       log.Fatalln(err)
  21.    }
  22.    //用于设置闲置的连接数。如果 <= 0, 则没有空闲连接会被保留
  23.    db.SetMaxIdleConns(0)
  24.    //用于设置最大打开的连接数,默认值为0表示不限制。
  25.    db.SetMaxOpenConns(30)
  26.    if err := db.Ping(); err != nil {
  27.       log.Fatalln(err)
  28.    }
  29.    //插入
  30.    insert()
  31.    //更新
  32.    update()
  33.    //查询
  34.    query()
  35.    //删除
  36.    delete()
  37. }
  38. func insert() {
  39.    tx, err := db.Begin()
  40.    if err != nil {
  41.       return
  42.    }
  43.    ctime := time.Now().Unix()
  44.    defer tx.Rollback()
  45.    stmt, err := tx.Prepare("INSERT INTO user (name,ctime) VALUES (?,?)")
  46.    if err != nil {
  47.       return
  48.    }
  49.    rs, err := stmt.Exec("李四", ctime)
  50.    if err != nil {
  51.       return
  52.    }
  53.    err = tx.Commit()
  54.    if err != nil {
  55.       return
  56.    }
  57.    id, err := rs.LastInsertId()
  58.    fmt.Println(id)
  59.    defer stmt.Close() //runs here!
  60.    return
  61. }
  62. func update() {
  63.    tx, err := db.Begin()
  64.    if err != nil {
  65.       return
  66.    }
  67.    defer tx.Rollback()
  68.    stmt, err := tx.Prepare("UPDATE user SET name=?  WHERE id=?")
  69.    if err != nil {
  70.       return
  71.    }
  72.    _, err = stmt.Exec("zhangsan", 1)
  73.    if err != nil {
  74.       return
  75.    }
  76.    err = tx.Commit()
  77.    if err != nil {
  78.       return
  79.    }
  80.    defer stmt.Close()
  81.    return
  82. }
  83. func query() {
  84.    rows, err := db.Query("SELECT id,name,ctime FROM user  ")
  85.    defer rows.Close()
  86.    if err != nil {
  87.       return
  88.    }
  89.    for rows.Next() {
  90.       var id, ctime int64
  91.       var name string
  92.       rows.Scan(&id, &name, &ctime)
  93.       fmt.Println(id, name, ctime)
  94.    }
  95.    if err = rows.Err(); err != nil {
  96.       return
  97.    }
  98.    return
  99. }
  100. func delete() {
  101.    tx, err := db.Begin()
  102.    if err != nil {
  103.       return
  104.    }
  105.    defer tx.Rollback()
  106.    stmt, err := tx.Prepare("DELETE FROM user  WHERE id=?")
  107.    if err != nil {
  108.       return
  109.    }
  110.    _, err = stmt.Exec(1)
  111.    if err != nil {
  112.       return
  113.    }
  114.    err = tx.Commit()
  115.    if err != nil {
  116.       return
  117.    }
  118.    defer stmt.Close()
  119.    return
  120. }

links