go语言六——连接mysql

ciaos · · 1122 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

转自:Golang连接Mysql

 

首先go-driver-sql的mysql版本,我通过

go get code.google.com/p/go-mysql-driver/mysql

安装失败,貌似是git版本不够新的缘故,不过用不着这么麻烦,直接去github下载源代码即可,解压到/usr/local/go/src/pkg/mysql目录

package main

// 导入sql包, 跟java.sql类似的
import "database/sql"
import _ "mysql"
import "encoding/json"
import "fmt"

// 定义一个结构体, 需要大写开头哦, 字段名也需要大写开头哦, 否则json模块会识别不了
// 结构体成员仅大写开头外界才能访问
type User struct {
    User      string    `json:"user"`
    Password string `json:"password"`
    Host   string `json:"host"`
}

// 一如既往的main方法
func main() {
    // 格式有点怪, @tcp 是指网络协议(难道支持udp?), 然后是域名和端口
    db, e := sql.Open("mysql", "root:pwd@tcp(localhost:3306)/mysql?charset=utf8")
    if e != nil { //如果连接出错,e将不是nil的
        fmt.Println("ERROR?")
        return
    }
    // 提醒一句, 运行到这里, 并不代表数据库连接是完全OK的, 因为发送第一条SQL才会校验密码 汗~!
    _, e2 := db.Query("select 1")//生产环境去掉这句,不然会有内存泄漏
    if e2 == nil {
        fmt.Println("DB OK")
        rows, e := db.Query("select user,password,host from mysql.user")
        if e != nil {
            fmt.Print("query error!!%v\n", e)
            return
        }
        if rows == nil {
            fmt.Println("Rows is nil")
            return
        }
        for rows.Next() { //跟java的ResultSet一样,需要先next读取
            user := new(User)
            // rows貌似只支持Scan方法 继续汗~! 当然,可以通过GetColumns()来得到字段顺序
            row_err := rows.Scan(&user.User,&user.Password, &user.Host)
            if row_err != nil {
                fmt.Println("Row error!!")
                return
            }
            b, _ := json.Marshal(user)
            fmt.Println(string(b)) // 这里没有判断错误, 呵呵, 一般都不会有错吧
        }
        fmt.Println("Done")
    } else {
        fmt.Println(e)
    }
}

本文来自:ITEYE博客

感谢作者:ciaos

查看原文:go语言六——连接mysql

1122 次点击  
加入收藏 微博
上一篇:google go语言
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传