《Go语言四十二章经》第三十九章 Mysql数据库

Go 提供了database/sql包用于对SQL数据库的访问，作为操作数据库的入口对象sql.DB，主要为我们提供了两个重要的功能：

sql.DB 通过数据库驱动为我们提供管理底层数据库连接的打开和关闭操作.
sql.DB 为我们管理数据库连接池

需要注意的是，sql.DB表示操作数据库的抽象访问接口, 而非一个数据库连接对象;它可以根据driver打开关闭数据库连接，管理连接池。正在使用的连接被标记为繁忙，用完后回到连接池等待下次使用。所以，如果你没有把连接释放回连接池，会导致过多连接使系统资源耗尽。

导入mysql数据库驱动

39.2 Mysql数据库操作

我们先建立表结构：


`cid` int(10) NOT NULL AUTO_INCREMENT, 
  `cname` varchar(60) NOT NULL, 
  `ename` varchar(100), 
  `cateimg` varchar(255), 
  `addtime` int(10) unsigned NOT NULL DEFAULT '0', 
  `publishtime` int(10) unsigned NOT NULL DEFAULT '0', 
  `scope` int(10) unsigned NOT NULL DEFAULT '10000', 
  `status` tinyint(1) unsigned NOT NULL DEFAULT '0', 
  PRIMARY KEY (`cid`), 
  UNIQUE  KEY catename (`cname`)
) ENGINE=InnoDB AUTO_INCREMENT=99 DEFAULT CHARSET=utf8 COLLATE=utf8_general_ci;

下面代码使用预编译的方式，来进行增删改查的操作，并通过事务来批量提交一批数据。预编译语句(PreparedStatement)提供了诸多好处，可以实现自定义参数的查询，通常来说，比手动拼接字符串 SQL 语句高效，可以防止SQL注入攻击。

每次db.Query操作后，都建议调用rows.Close()。因为 db.Query() 会从数据库连接池中获取一个连接，这个底层连接在结果集(rows)未关闭前会被标记为处于繁忙状态。当遍历读到最后一条记录时，会发生一个内部EOF错误，自动调用rows.Close(), 但如果提前退出循环，rows不会关闭，连接不会回到连接池中，连接也不会关闭，则此连接会一直被占用。因此通常我们使用 defer rows.Close() 来确保数据库连接可以正确放回到连接池中。

// 插入数据，sql预编译
func (dbw *DbWorker) insertData() {
    stmt,  _ := dbw.Db.Prepare(`INSERT INTO t_article_cate (cname, addtime, scope) VALUES (?, ?, ?)`)
    defer stmt.Close()
    ret,  err := stmt.Exec("栏目1",  time.Now().Unix(),  10)
    // 通过返回的ret可以进一步查询本次插入数据影响的行数
    // RowsAffected和最后插入的Id(如果数据库支持查询最后插入Id)
    if err != nil {
        return
    }
        fmt.Println("LastInsertId:",  LastInsertId)
    }
    if RowsAffected,  err := ret.RowsAffected(); nil == err {
        fmt.Println("RowsAffected:",  RowsAffected)
    }
}

删除数据：

修改数据：

// 修改数据，预编译
func (dbw *DbWorker) editData() {
    stmt,  err := dbw.Db.Prepare(`UPDATE t_article_cate SET scope=? WHERE cid=?`)
    ret,  err := stmt.Exec(111,  123)
    // 通过返回的ret可以进一步查询本次插入数据影响的行数RowsAffected和
// 最后插入的Id(如果数据库支持查询最后插入Id).
    if err != nil {
        fmt.Printf("insert data error: %v\n",  err)
        return
    }
    if RowsAffected,  err := ret.RowsAffected(); nil == err {
        fmt.Println("RowsAffected:",  RowsAffected)
    }
}

查询数据：

func (dbw *DbWorker) transaction() {
    tx,  err := dbw.Db.Begin()
    if err != nil {
        return
    }
    defer tx.Rollback()
    stmt,  err := tx.Prepare(`INSERT INTO t_article_cate (cname, addtime, scope) VALUES (?, ?, ?)`)
    if err != nil {
        fmt.Printf("insert data error: %v\n",  err)
        return
    }
    for i := 100; i < 110; i++ {
        cname := strings.Join([]string{"栏目-",  string(i)},  "-")
        _,  err = stmt.Exec(cname,  time.Now().Unix(),  i+20)
        if err != nil {
            fmt.Printf("insert data error: %v\n",  err)
            return
        }
    }
    err = tx.Commit()
    if err != nil {
        fmt.Printf("insert data error: %v\n",  err)
        return
    }
    stmt.Close()