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()
}
总结
如果觉得编程之家网站内容还不错，欢迎将编程之家网站推荐给程序员好友。
本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。
如您喜欢交流学习经验，点击链接加入交流1群：1065694478(已满)交流2群：163560250