Go语言读写数据库

我用的驱动是：https://github.com/Go-SQL-Driver/MySQL

理由跟 https://github.com/astaxie/build-web-application-with-golang/blob/master/05.2.md 的一样。

比较新，更新维护的比较好；
完全支持database/sql接口
支持keepalive，保持长连接。

安装

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

数据库连接语句

import "database/sql"
import _ "github.com/go-sql-driver/mysql" 
db, e := sql.Open("mysql", "user:password@/dbname?charset=utf8")

代码例子：来自 https://github.com/astaxie/build-web-application-with-golang/blob/master/05.2.md

使用的数据表：

CREATE TABLE `userinfo` ( `uid` int(10) NOT NULL AUTO_INCREMENT, `username` varchar(64) DEFAULT NULL, `departname` varchar(64) DEFAULT NULL, `created` date DEFAULT NULL, PRIMARY KEY (`uid`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8 AUTO_INCREMENT=8 ;

代码：

package main

import(
    "database/sql"
    "fmt"
    _"github.com/go-sql-driver/mysql"
)

func main(){
    db,err:=sql.Open("mysql","root:root@tcp(localhost:8889)/ghj1976test?charset=utf8")
    checkErr(err)

    //插入数据
    stmt,err:=db.Prepare("INSERT userinfo SET username=?,departname=?,created=?")
    checkErr(err)

    res,err:=stmt.Exec("ghj1976","RD部门","2013-03-18")
    checkErr(err)

    res,err=stmt.Exec("astaxie","RD部门","2012-12-09")
    checkErr(err)

    id,err:=res.LastInsertId()
    checkErr(err)

    fmt.Println(id)

    //修改数据
    stmt,err=db.Prepare("update user info set username=? where uid=?")
    checkErr(err)

    res,err=stmt.Exec("astaxieupdate",id)
    checkErr(err)

    affect,err:=res.RowsAffected()
    checkErr(err)

    fmt.Println(affect)

    //搜索数据
    rows,err:=db.Query("SELECT * FROM userinfo")
    checkErr(err)

    for rows.Next(){
        var uid int
        var username string
        var department string
        var created string
        err=rows.Scan(&uid,&username,&department,&created)
        checkErr(err)
        fmt.Println(uid)
        fmt.Println(username)
        fmt.Println(department)
        fmt.Println(created)
    }

    //删除数据
    stmt,err=db.Prepare("delete from user info where uid=?")
    checkErr(err)

    res,err=stmt.Exec(id)
    checkErr(err)

    affect,err=res.RowsAffected()
    checkErr(err)

    fmt.Println(affect) 
    db.Close()
}

func checkErr(err error){
    if err!=nil{
        panic(err)
    }
}

db.Prepare()函数用来返回准备要执行的sql操作，然后返回准备完毕的执行状态。 db.Query()函数用来直接执行Sql返回Rows结果。 stmt.Exec()函数用来执行stmt准备好的SQL语句