Golang查询SqlServer数据库

Go语言中查询SqlServer数据库

一、Go语言中查询MsSQL数据库：

// main.go

package main

import (

    "database/sql"

    "fmt"

    "log"

    "time"

    _ "github.com/denisenkom/go-mssqldb"

)

func main() {

    var isdebug = true

    var server = "localhost"

    var port = 1433

    var user = "sa"

    var password = "123456xx"

    var database = "MyTestDB"

    //连接字符串

    connString := fmt.Sprintf("server=%s;port%d;database=%s;user id=%s;password=%s", server, port, database, user, password)

    if isdebug {

        fmt.Println(connString)

    }

    //建立连接

    conn, err := sql.Open("mssql", connString)

    if err != nil {

        log.Fatal("Open Connection failed:", err.Error())

    }

    defer conn.Close()

    //产生查询语句的Statement

    stmt, err := conn.Prepare(`select * from [account_region]`)

    if err != nil {

        log.Fatal("Prepare failed:", err.Error())

    }

    defer stmt.Close()

    //通过Statement执行查询

    rows, err := stmt.Query()

    if err != nil {

        log.Fatal("Query failed:", err.Error())

    }

    //建立一个列数组

    cols, err := rows.Columns()

    var colsdata = make([]interface{}, len(cols))

    for i := 0; i < len(cols); i++ {

        colsdata[i] = new(interface{})

        fmt.Print(cols[i])

        fmt.Print("\t")

    }

    fmt.Println()

    //遍历每一行

    for rows.Next() {

        rows.Scan(colsdata...) //将查到的数据写入到这行中

        PrintRow(colsdata)    //打印此行

    }

    defer rows.Close()

}

//打印一行记录，传入一个行的所有列信息

func PrintRow(colsdata []interface{}) {

    for _, val := range colsdata {

        switch v := (*(val.(*interface{}))).(type) {

        case nil:

            fmt.Print("NULL")

        case bool:

            if v {

                fmt.Print("True")

            } else {

                fmt.Print("False")

            }

        case []byte:

            fmt.Print(string(v))

        case time.Time:

            fmt.Print(v.Format("2016-01-02 15:05:05.999"))

        default:

            fmt.Print(v)

        }

        fmt.Print("\t")

    }

    fmt.Println()

}

二、效果：

server=localhost;port1433;database=MyTestDB;user id=sa;password=123456xx

region_id    provider_id    region_name    billing_region_name    description   

1    5    us-east-1    US-EAST    AWS US EAST Data Center   

2    5    us-west-2    US_WEST_OREGON    AWS Oregon Data Center   

3    5    ap-southeast-1    ASIA_SIGN    AWS Singapore Data Center   

4    5    ap-southeast-2    ASIA_SYDENY    AWS Sydney Data Center   

5    5    ap-northeast-1    ASIA_TOKYO    AWS Tokyo Data Center   

6    5    eu-central-1    EU_FRANKFURT    AWS Frankfurt Data Center   

7    5    eu-west-1    EU_IRELAND    AWS Europe Data Center   

8    5    us-west-1    US_WEST_CA    AWS CA Data Center   

9    5    sa-east-1    SOUA_SAOP    AWS Sao Paulo Data Center   

10    5    ap-northeast-2    ASIA_SEOUL    AWS Seoul Data Center   

11    5    ap-south-1    ASIA_MUMBAI    AWS Mumbai Data Center   

12    2    Central US    US-CENTRAL    Azure Center US Data Center   

13    2    North Central US    US-NORTH-CENTRAL    Azure North US Data Center   

14    2    East US    US-EAST    Azure East US Data Center   

15    2    South Central US    US-SOUTH-CENTRAL    Azure South US Data Center   

16    2    West US    US-WEST    Azure West US Data Center   

17    2    North Europe    EUROPE-NORTH    Azure North Europe Data Center   

18    2    West Europe    EUROPE-WEST    Azure North Europe Data Center   

19    2    East Asia    ASIA-PACIFIC-EAST    Azure East Aisa Data Center   

20    2    Southeast Asia    ASIA-PACIFIC-SOUTHEAST    Azure Singapore Data Center   

21    2    Japan East    JAPAN-EAST    Azure East Japan Data Center   

22    2    Japan West    JAPAN-WEST    Azure West Japan Data Center   

23    2    Brazil South    BRAZIL-SOUTH    Azure Sao Paulo Data Center   

24    2    Australia East    AUSTRALIA-EAST    Azure East Australia Data Center   

25    2    Australia Southeast    AUSTRALIA-SOUTHEAST    Azure Southeast Australia Data Center   

26    2    East US 2    US-EAST-2    Azure East US Data Center 2   

27    2    US Gov Virginia    USGOV-VIRGINIA    Azure US Virginia Government Data Center   

28    2    US Gov Iowa    USGOV-IOWA    Azure US Iowa Government Data Center   

29    2    Canada Central    CANADA-CENTRAL    Azure Central Canada   

30    2    Canada East    CANADA-EAST    Azure East Canada   

31    2    Germany Central    GERMANY-CENTRAL    Azure Central Germany   

32    2    Germany Northeast    GERMANY-NORTHEAST    Azure Northeast Germany   

33    2    Korea Central    KOREA-CENTRAL    Azure Central Korea   

34    3    China North    CN-BEIJING    Azure Mooncake Beijing Data Center   

35    3    China East    CN-SHANGHAI    Azure Mooncake Shanghai Data Center   

36    4    cn-hangzhou    CN_HANGZHOU    Aliyun Hangzhou Data Center   

37    4    cn-beijing    CN_BEIJING    Aliyun Beijing Data Center   

38    4    cn-shenzhen    CN_SHENZHEN    Aliyun Shenzhen Data Center   

39    4    cn-qingdao    CN_QINGDAO    Aliyun Qingdao Data Center   

40    4    cn-hongkong    HONGKONG    Aliyun Hong Kong Data Center   

41    4    us-silicon-valley    US-Silicon_Valley    Aliyun Silicon Valley Data Center   

三、使用实体实现的方法：

// main.go

package main

import (

    "database/sql"

    "fmt"

    "log"

    _ "github.com/denisenkom/go-mssqldb"

)

type AccessRegion struct {

    region_id          int64

    provider_id        int64

    region_name        string

    sub_region_names    string

    billing_region_name string

    description        string

}

func main() {

    var server = "localhost"

    var port = 1433

    var user = "sa"

    var password = "123456xxx"

    var database = "MyTestDB"

    //连接字符串

    connString := fmt.Sprintf("server=%s;port%d;database=%s;user id=%s;password=%s", server, port, database, user, password)

    //建立连接

    db, err := sql.Open("mssql", connString)

    if err != nil {

        log.Fatal("Open Connection failed:", err.Error())

    }

    defer db.Close()

    //通过连接对象执行查询

    rows, err := db.Query(`select * from [account_region]`)

    if err != nil {

        log.Fatal("Query failed:", err.Error())

    }

    defer rows.Close()

    var rowsData []*AccessRegion

    //遍历每一行

    for rows.Next() {

        var row = new(AccessRegion)

        rows.Scan(&row.region_id, &row.provider_id, &row.region_name, &row.billing_region_name, &row.description)

        rowsData = append(rowsData, row)

    }

    //打印数组

    for _, ar := range rowsData {

        fmt.Print(ar.region_id, "\t", ar.provider_id, "\t", ar.region_name, "\t", ar.billing_region_name, "\t", ar.description)

        fmt.Println()

    }

}

四、使用ODBC的实现方式

// main.go

package main

import (

    "database/sql"

    "fmt"

    "log"

    _ "github.com/alexbrainman/odbc"

)

type AccessRegion struct {

    region_id          int64

    provider_id        int64

    region_name        string

    sub_region_names    string

    billing_region_name string

    description        string

}

func main() {

    db, err := sql.Open("odbc", "driver={sql server};server=localhost;port=1433;uid=sa;pwd=123456xxx;database=MyTestDB")

    if err != nil {

        fmt.Printf(err.Error())

    }

    //通过连接对象执行查询

    rows, err := db.Query(`select * from [account_region]`)

    if err != nil {

        log.Fatal("Query failed:", err.Error())

    }

    defer rows.Close()

    var rowsData []*AccessRegion

    //遍历每一行

    for rows.Next() {

        var row = new(AccessRegion)

        rows.Scan(&row.region_id, &row.provider_id, &row.region_name, &row.billing_region_name, &row.description)

        rowsData = append(rowsData, row)

    }

    //打印数组

    for _, ar := range rowsData {

        fmt.Print(ar.region_id, "\t", ar.provider_id, "\t", ar.region_name, "\t", ar.billing_region_name, "\t", ar.description)

        fmt.Println()

    }

}

五、最终转为Map集合

// main.go

package main

import (

    "database/sql"

    "fmt"

    "log"

    _ "github.com/alexbrainman/odbc"

    "github.com/demdxx/gocast"

)

func main() {

    db, err := sql.Open("odbc", "driver={sql server};server=localhost;port=1433;uid=sa;pwd=123456xxx;database=MyTestDB")

    if err != nil {

        fmt.Printf(err.Error())

    }

    //通过连接对象执行查询

    rows, err := db.Query(`select * from [account_region]`)

    if err != nil {

        log.Fatal("Query failed:", err.Error())

    }

    defer rows.Close()

    //遍历每一行

    colNames, _ := rows.Columns()

    var cols = make([]interface{}, len(colNames))

    for i := 0; i < len(colNames); i++ {

        cols[i] = new(interface{})

    }

    var maps = make([]map[string]interface{}, 0)

    for rows.Next() {

        err := rows.Scan(cols...)

        if err != nil {

            log.Fatal(err.Error())

        }

        var rowMap = make(map[string]interface{})

        for i := 0; i < len(colNames); i++ {

            rowMap[colNames[i]] = convertRow(*(cols[i].(*interface{})))

        }

        maps = append(maps, rowMap)

    }

    //打印数组

    for _, rowMap := range maps {

        for k, v := range rowMap {

            fmt.Print(k, ":", v, "\t")

        }

        fmt.Println()

    }

}

func convertRow(row interface{}) interface{} {

    switch row.(type) {

    case int:

        return gocast.ToInt(row)

    case string:

        return gocast.ToString(row)

    case []byte:

        return gocast.ToString(row)

    case bool:

        return gocast.ToBool(row)

    }

    return row

}

©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 216,919评论 6赞 502
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 92,567评论 3赞 392
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 163,316评论 0赞 353
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 58,294评论 1赞 292
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 67,318评论 6赞 390
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 51,245评论 1赞 299
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 40,120评论 3赞 418
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 38,964评论 0赞 275
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 45,376评论 1赞 313
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,592评论 2赞 333
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,764评论 1赞 348
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 35,460评论 5赞 344
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 41,070评论 3赞 327
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,697评论 0赞 22
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,846评论 1赞 269
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 47,819评论 2赞 370
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 44,665评论 2赞 354

推荐阅读更多精彩内容