go-sql-driver包实现mysql不定字段查询

go-sql-driver包是一个第三方包下载地址http://github.com/go-sql-driver/mysql 下面直接上代码

package main
import (
    "database/sql"
    "fmt"
    _ "github.com/go-sql-driver/mysql"
)
func main() {
    //连接数据库
    db, err := sql.Open("mysql", "root:@tcp(localhost:3306)/go?charset=utf8")
    if err != nil {
        fmt.Println("连接数据库失败", err.Error())
        return
    }
    defer db.Close()
    //查询数据库
    query, err := db.Query("select * from go_user")
    if err != nil {
        fmt.Println("查询数据库失败", err.Error())
        return
    }
    defer query.Close()
    //读出查询出的列字段名
    cols, _ := query.Columns()
    //values是每个列的值，这里获取到byte里
    values := make([][]byte, len(cols))
    //query.Scan的参数，因为每次查询出来的列是不定长的，用len(cols)定住当次查询的长度
    scans := make([]interface{}, len(cols))
    //让每一行数据都填充到[][]byte里面
    for i := range values {
        scans[i] = &values[i]
    }
    //最后得到的map
    results := make(map[int]map[string]string)    //当然也可以用鸭子类型 results := make(map[int]interface{})
    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 := cols[k]
            row[key] = string(v)
        }
        results[i] = row //装入结果集中
        i++
    }
    //查询出来的数组
    for k, v := range results {
        fmt.Println(k, v)
    }
    db.Close() //用完关闭
}

参考： https://my.oschina.net/tongjh/blog/333050

go-sql-driver包实现mysql不定字段查询

微信号：腾讯云折扣返现

技术讨论QQ群： 863102326

作者: catherine

搜索

标签

go-sql-driver包 实现mysql不定字段查询

微信号：腾讯云折扣返现

技术讨论QQ群： 863102326

作者: catherine

搜索

标签

go-sql-driver包实现mysql不定字段查询