简单讲解Go程序中使用MySQL的方法

go官方仅提供了database package，database package下有两个包sql，sql/driver。这两个包用来定义操作数据库的接口，这就保证了无论使用哪种数据库，他们的操作方式都是相同的。

但go官方并没有提供连接数据库的driver，如果要操作数据库，还需要第三方的driver 包，幸好，主流的数据库的driver都已经有了：https://code.google.com/p/go-wiki/wiki/SQLDrivers

其中，mysql有两个包，一个是mymysql，一个是go-sql-driver/mysql，两个package都是纯go实现。我选择了后者，因为后者的效率更高一点，benchmark在这里：https://github.com/go-sql-driver/sql-benchmark
sql包的用法简洁明了：
1、建立连接
首先是Open，

db, err := sql.Open(“mysql”, “user:password@/dbname”) 

db 是一个*sql.DB类型的指针，在后面的操作中，都要用到db
open之后，并没有与数据库建立实际的连接，与数据库建立实际的连接是通过Ping方法完成。此外，db应该在整个程序的生命周期中存在，也就是说，程序一启动，就通过Open获得db，直到程序结束，再Close db，而不是经常Open/Close。

err = db.Ping()

2、基本用法
DB的主要方法有：
Query 执行数据库的Query操作，例如一个Select语句，返回*Rows

QueryRow 执行数据库至多返回1行的Query操作，返回*Row

PrePare 准备一个数据库query操作，返回一个*Stmt，用于后续query或执行。这个Stmt可以被多次执行，或者并发执行

Exec 执行数不返回任何rows的据库语句，例如delete操作

3、简单实例

package main

import (

 "database/sql"

 "fmt"

 _ "github.com/go-sql-driver/mysql"

)
type User struct {

 id                 int

 username, password string

}
var sqldata map[interface{}]interface{}
func main() {

 var u User

 db, err := sql.Open("mysql", "root:@/test?charset=utf8")

 check(err)

 插入数据

 stmt, err := db.Prepare("INSERT user SET username=?,password=?")

 check(err)

 res, err := stmt.Exec("xiaowei", "xiaowei")

 check(err)

 id, err := res.LastInsertId()

 check(err)

 fmt.Println(id)

 //查询数据

 rows, err := db.Query("SELECT * FROM user")

 check(err)
 fmt.Println(rows.Columns())

 userinfo := make(map[interface{}]interface{})

 for rows.Next() {

  err := rows.Scan(&u.id, &u.username, &u.password)

  check(err)

  userinfo[u.id] = u

 }

 fmt.Println(userinfo)

}
func check(err error) {

 if err != nil {

  fmt.Println(err)

 }

}

声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：notice#nhooo.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。