微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

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

go官方仅提供了database package,database package下有两个包sqlsql/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)
 }
}


版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐