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

// main.go
package mainimport ("database/sql""fmt""log""time"_ "github.com/denisenkom/go-mssqldb"
)func main() {var isdebug = truevar server = "localhost"var port = 1433var 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()//产生查询语句的Statementstmt, 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 mainimport ("database/sql""fmt""log"_ "github.com/denisenkom/go-mssqldb"
)type AccessRegion struct {region_id           int64provider_id         int64region_name         stringsub_region_names    stringbilling_region_name stringdescription         string
}func main() {var server = "localhost"var port = 1433var 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 mainimport ("database/sql""fmt""log"_ "github.com/alexbrainman/odbc"
)type AccessRegion struct {region_id           int64provider_id         int64region_name         stringsub_region_names    stringbilling_region_name stringdescription         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 mainimport ("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
}

Go语言中查询SqlServer数据库相关推荐

  1. NHibernate中,查询SqlServer数据库多个实体对象

    关于datetime类型使用:  Oracle:  "and tb.EffectiveDate >= to_date(?,'yyyy-mm')" Sql:  "an ...

  2. 如何在jsp中连接SQLserver数据库

    分享如何在jsp中连接SQLserver数据库(我这里用的是eclipse连接SqlServer2014) 前提:需要先把sqljdbc4.jar的包放在web-inf的lib包下(负责安装包,点击l ...

  3. ASP.NET中连接Sqlserver数据库时提示:未能加载文件或程序集“Microsoft.SqlServer.Management.Sdk.Sfc

    场景 在Visual Studio 2013中连接 SqlServer数据库时提示: 未能加载文件或程序集"Microsoft.SqlServer.Management.Sdk.Sfc 注: ...

  4. php如何查询数据库,如何在php中查询mysql数据库数据

    如何在php中查询mysql数据库数据 发布时间:2020-07-21 09:23:55 来源:亿速云 阅读:81 作者:Leah 本篇文章给大家分享的是有关如何在php中查询mysql数据库数据,小 ...

  5. vfp读取oracle 图片,在VFP中读取SQL-Server数据库Image字段

    001: FUNCTION ReadImageFromSQL 002: *-- 传递参数:员工工号,是否使用本地临时照片文件 003: LPARAMETERS tcPerCode,tlUseLocal ...

  6. mysql查询动态表名的数据类型_Mysql中查询某个数据库中所有表的字段信息

    前言 有时候,需要在数据库中查询一些字段的具体信息,而这些字段又存在于不同的表中,那么我们如何来查询呢? 在每一个数据库链接的information_schema数据库中,存在这样一张表--COLUM ...

  7. C/C++语言ODBC连接SqlServer数据库

    C/C++连接SqlServer数据库 C或C++语言ODBC方式连接SqlServer数据库,需要先正确配置数据源才能连接. VC6.0连接到数据库 VC2013连接到数据库 数据库创建一数据表 u ...

  8. SQL数据库语言基础之SqlServer数据库原理与设计课程期末复习-条件查询实例练习【学生表、选课表、家庭作业表】

    文章目录 1.简单查询 2.查询在1999年出生的学生学号.姓名.出生日期 3.三次作业成绩都在60分以上的学生学号.课程号 4.查询姓张学生学号.姓名和专业班级 5.查询03级的男生信息 6.查询没 ...

  9. 查询Sqlserver数据库死锁的一个存储过程

    使用sqlserver作为数据库的应用系统,都避免不了有时候会产生死锁, 死锁出现以后,维护人员或者开发人员大多只会通过sp_who来查找死锁的进程,然后用sp_kill杀掉.利用sp_who_loc ...

最新文章

  1. Service与AIDL详解
  2. 口语学习Day3:今天聊聊菜单
  3. imitativesimulate
  4. c++ static 静态变量初始化
  5. weex css单位,Weex系列(7) ——踩坑填坑的总总
  6. 一步步编写操作系统 44 用c语言编写内核1
  7. Android系统(133)---Google Play Store无法搜索应用或提示应用不兼容,此类问题该如何定位及分析
  8. 如何组合来自多个SQL表的结果(提示:有三种方式)
  9. python下载谷歌地图瓦片_python获取bing地图发布自己的TMS服务(一)下载瓦片
  10. 交叉火力dsp手机调音软件_万能dsp调音软件全集
  11. DSP2812之定时器0
  12. 初识powerpoint的计算机教案,初识ppt教案.doc
  13. 实现 | 朴素贝叶斯模型算法研究与实例分析
  14. ps人像美白磨皮教程,ps如何修人像美白磨
  15. 配置 Eureka Server 集群
  16. php计算素数,质数素数计算器
  17. python怎么自动生成文档_用 Python 自动生成 Word 文档
  18. 最有前景的RPO数字化趋势来到了,工作系统是怎么逆袭的?
  19. 进击吧!Pythonista(6/100)
  20. Xmind8Update7安装与Xmind8Update7破解

热门文章

  1. Qt Creator浏览项目内容
  2. QML使用数据来模拟天气预报
  3. C++类的组合和前向引用
  4. 实现权限控制_Spring自定义注解+AOP实现权限控制
  5. Sqoop(三)将关系型数据库中的数据导入到HDFS(包括hive,hbase中)
  6. CXF配置,ant文件说明及运行,运行cxf中带的项目
  7. Python dataframe列拆分多行与统计
  8. 异常处理python要求输入的为英文_python(异常处理)
  9. 深入浅出设计模式原则之开闭原则(OCP)
  10. 如何解决连接不上us.archive.ubuntu.com