package main
import (
"database/sql"
_ "github.com/go-sql-driver/mysql"
"log"
)
func main() {
//連接數據庫查詢
db, err := sql.Open("mysql", "root:xxx@tcp(xxx:3306)/my_test")
if err != nil {
log.Fatal(err.Error())
}
//最終關閉數據庫
defer db.Close()
mSql := "select * from user"
rows, err := db.Query(mSql)
if err != nil {
log.Fatal(err.Error())
}
//獲取列名
columns, _ := rows.Columns()
//定義一個切片,長度是字段的個數,切片里面的元素類型是sql.RawBytes
values := make([]sql.RawBytes, len(columns))
//定義一個切片,元素類型是interface{} 接口
scanArgs := make([]interface{}, len(values))
for i := range values {
//把sql.RawBytes類型的地址存進去了
scanArgs[i] = &values[i]
}
//獲取字段值
var result []map[string]string
for rows.Next() {
res := make(map[string]string)
rows.Scan(scanArgs...)
for i, col := range values {
res[columns[i]] = string(col)
}
result = append(result, res)
}
//遍歷結果
for _, r := range result {
for k, v := range r {
log.Printf("%s==%s", k, v)
}
}
rows.Close()
}
