go官方僅提供了database package，database package下有兩個包sql，sql/driver。這兩個包用來定義操作資料庫的介面，這就保證了無論使用哪種資料庫，他們的操作方式都是相同的。
    但go官方並沒有提供連線資料庫的driver，如果要操作資料庫，還需要第三方的driver 包，最常用的有：
    https://github.com/Go-SQL-Driver/MySQL支援database/sql，全部採用go寫。
    https://github.com/ziutek/mymysql 支援database/sql，也支援自定義的介面，全部採用go寫。
    推薦使用前者，因為前者的效率更高一點，二者效率的對比可參考benchmark測試結果：

https://github.com/go-sql-driver/sql-benchmark

    go連線其他主流資料庫的驅動介紹可參考：

    作業系統：Red Hat Enterprise Linux Server release 6.4 
    mysql版本：mysql-5.5.28
    安裝git客戶端(方便從github上獲取mysql驅動)

[[email protected] /]# yum install git

    獲取mysql驅動

[[email protected] /]# go get github.com/go-sql-driver/mysql
[[email protected]
 
 /]# ls
pkg  src 

    在當前目錄下可以看到多出兩個資料夾pkg和src，將src資料夾拷貝到go程式安裝目錄下或go工作環境下即可

[[email protected] /]# cp -r src /usr/local/go/

3 程式設計例項

package main

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

func main() {
        /*DSN資料來源名稱
          [username[:password]@][protocol[(address)]]/dbname[?param1=value1¶mN=valueN]
          
 
[email protected](/path/to/socket)/dbname
          user:[email protected](localhost:5555)/dbname?charset=utf8&autocommit=true
          user:[email protected]([de:ad:be:ef::ca:fe]:80)/dbname?charset=utf8mb4,utf8
          user:[email protected]/dbname
          無資料庫: user:[email protected]/
        */
        db, err := sql.Open("mysql", "jesse:[email protected](127.0.0.1:3306)/?charset=utf8") //第一個引數為驅動名  
        checkErr(err)
        db.Query("drop database if exists tmpdb")
        db.Query("create database tmpdb")
        //db.Query("use tmpdb")
        db.Query("create table tmpdb.tmptab(c1 int, c2 varchar(20), c3 varchar(20))")
        db.Query("insert into tmpdb.tmptab values(101, '姓名1', 'address1'), (102, '姓名2', 'address2'), (103, '姓名3', 'address3'), (104, '姓名4', 'address4')")
        //checkErr(err)
        query, err := db.Query("select * from tmpdb.tmptab")

        checkErr(err)
        v := reflect.ValueOf(query)
        fmt.Println(v)
        fmt.Println("--增加資料測試--")
        printResult(query)
        db.Query("delete from tmpdb.tmptab where c1 = 101")
        //checkErr(err)
        query2, _ := db.Query("select * from tmpdb.tmptab")
        fmt.Println("--刪除資料測試--")
        printResult(query2)
        db.Query("update tmpdb.tmptab set c3 = 'address4' where c1 = 103")
        //checkErr(err)
        query3, _ := db.Query("select * from tmpdb.tmptab")
        fmt.Println("--更新資料測試--")
        printResult(query3)
        db.Query("delete from tmpdb.tmptab")
        //checkErr(err)
        query4, _ := db.Query("select * from tmpdb.tmptab")
        fmt.Println("--清空資料測試--")
        printResult(query4)
        db.Query("drop table tmpdb.tmptab")
        db.Query("drop database tmpdb")
        //stmt, err := db.Prepare("create database tmpdb")
        db.Close()
}

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

func printResult(query *sql.Rows) {
        column, _ := query.Columns()              //讀出查詢出的列欄位名
        values := make([][]byte, len(column))     //values是每個列的值，這裡獲取到byte裡
        scans := make([]interface{}, len(column)) //因為每次查詢出來的列是不定長的，用len(column)定住當次查詢的長度
        for i := range values {                   //讓每一行資料都填充到[][]byte裡面
                scans[i] = &values[i]
        }
        results := make(map[int]map[string]string) //最後得到的map
        i := 0
        for query.Next() { //迴圈，讓遊標往下移動
                if err := query.Scan(scans...); err != nil { //query.Scan查詢出來的不定長值放到scans[i] = &values[i],也就是每行都放在values裡
                        fmt.Println(err)
                        return
                }
                row := make(map[string]string) //每行資料
                for k, v := range values {     //每行資料是放在values裡面，現在把它挪到row裡
                        key := column[k]
                        row[key] = string(v)
                }
                results[i] = row //裝入結果集中
                i++
        }
        for k, v := range results { //查詢出來的陣列
                fmt.Println(k, v)
        }
}

4 執行程式

    4.1 編譯執行

[[email protected] /]# go build MysqlGoTest.go
[[email protected] /]# ls
MysqlGoTest.go  MysqlGoTest
[[email protected] /]# ./MysqlGoTest

4.2 直接執行

[[email protected] /]# go run MysqlGoTest.go
<*sql.Rows Value>
--增加資料測試--
0 map[c1:101 c2:姓名1 c3:address1]
1 map[c1:102 c2:姓名2 c3:address2]
2 map[c1:103 c2:姓名3 c3:address3]
3 map[c1:104 c2:姓名4 c3:address4]
--刪除資料測試--
0 map[c1:102 c2:姓名2 c3:address2]
1 map[c1:103 c2:姓名3 c3:address3]
2 map[c1:104 c2:姓名4 c3:address4]
--更新資料測試--
0 map[c1:102 c2:姓名2 c3:address2]
1 map[c1:103 c2:姓名3 c3:address4]
2 map[c1:104 c2:姓名4 c3:address4]
--清空資料測試--

5 補充知識

    5.1 避免中文亂碼

    為確保程式寫入資料庫以及從資料庫讀出時不出現亂碼，需要做如下配置：
    go客戶端程式級別：
    go程式檔案設定編碼 utf8,如

db, err := sql.Open("mysql", "jesse:[email protected](127.0.0.1:3306)/?charset=utf8")

    mysql資料庫級別：
    設定MySQL資料庫客戶端及服務端配置為utf8 
    例如：
    在my.cnf配置檔案中配置

[mysql]  
default_character_set=utf8  
[mysqld]  
character-set-server=utf8  
collation-server=utf8_bin 

    5.2 go語言反射機制

    用途：可獲取物件資料型別

    很多語言都有反射機制。通過反射，我們可以知道一個未知對像的屬性，方法。

    在寫一個函式的時候，有時你需要另外一個物件或者類的某些屬性，方法，但這個程式不能認識所需要的物件或者類，這時便需要通過反射來操作了。通過反射，你變很方便的載入、探知、使用編譯期間完全未知的物件或者類了。

    所謂反射，也就是相當於物理的反射，你通過鏡子，可以看到自己的摸樣，函式通過反射，可以獲得想要的資訊。在golang的反射包reflect中，反射型別Type()和Value(),可以改變反射回來變數的值。例如獲取變數value的型別，可通過函式reflect.ValueOf()進行操作。

var value interface {} = &User{1,"Tom",12,"nan"}
v := reflect.ValueOf(value)
fmt.Println(v)

 
****************************************************************************************
    原文地址：http://blog.csdn.net/jesseyoung/article/details/40398321
    部落格主頁：http://blog.csdn.net/jesseyoung
****************************************************************************************