简单讲解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 是一个*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)
}
}
您可能感兴趣的文章:
- MySQL中的integer 数据类型
- MySQL存储过程
- mysql中int、bigint、smallint 和 tinyint的区别与长度
- mysql load data 导出、导入 csv
- source命令执行SQL脚本文件
- MySQL创建用户及权限控制
- MySQL管理数据表
- linux下mysql添加用户
- mysql procedure
- mysql触发器
- MySQL 备份和恢复策略
- mac下安装mysql(转载)
- mysql 修改编码 Linux/Mac/Unix/通用(杜绝修改后无法启动的情况!)
- MySQL数据的导出、导入(mysql内部命令:mysqldump、mysql)
- mysql数据行转列
- Linux下修改MySQL编码的方法
- MySQL Server 日志
- MySQL 安全事宜
- MySQL 备份与恢复