企业级应用程序应用的广泛使用，SQL Server也成为了企业级应用程序中使用最广泛的数据库之一。而且，随着Go语言的流行，越来越多的开发人员希望在Go语言中使用SQL Server。在本文中，我们将介绍如何在Go语言中使用SQL Server，涉及到连接、查询、读取和写入数据等方面的完整指南。
连接到SQL Server数据库
要连接到SQL Server数据库，我们需要使用到 Microsoft提供的SQL Server驱动程序（即mssql）。这个驱动程序非常容易使用，因此让我们进行安装。
安装SQL Server驱动程序
要安装mssql驱动程序，我们需要在终端中运行以下命令：
|
1
|
go get github.com/denisenkom/go-mssqldb
|
这个命令将下载并安装mssql驱动程序。
连接到数据库
一旦驱动程序安装完成，我们就可以连接到SQL Server数据库了。连接需要我们提供数据库的服务器地址、数据库名称、用户名和密码。下面是一个连接的基本示例：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
|
package main
import (
"database/sql"
"fmt"
_ "github.com/denisenkom/go-mssqldb"
)
func main() {
server := "localhost\SQLEXPRESS"
port := 1433
user := "sa"
password := "password123"
database := "MyDatabase"
connString := fmt.Sprintf("server=%s;user id=%s;password=%s;port=%d;database=%s;",
server, user, password, port, database)
db, err := sql.Open("mssql", connString)
if err != nil {
panic(err)
}
defer db.Close()
// Connection successful. We can now start working with the database.
fmt.Println("Connection successful.")
}
|
在这个示例中，我们指定了数据库的服务器地址为“localhostSQLEXPRESS”，端口为1433，用户名为sa，密码为password123，数据名称为MyDatabase。连接字符串被格式化为“My example connection string” format。我们使用该字符串打开连接，并在连接成功之后提供了一个简单的消息作为确认。
查询数据
一旦连接成功，我们就可以开始使用SQL命令从数据库中查询数据了。我们可以使用 db.Query() 来执行查询语句，并使用 rows.Scan() 来扫描查询结果中的每行数据。下面是一个基本的查询示例：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
|
func main() {
server := "localhost\SQLEXPRESS"
port := 1433
user := "sa"
password := "password123"
database := "MyDatabase"
connString := fmt.Sprintf("server=%s;user id=%s;password=%s;port=%d;database=%s;",
server, user, password, port, database)
db, err := sql.Open("mssql", connString)
if err != nil {
panic(err)
}
defer db.Close()
// Query the database.
query := "SELECT Name, Email FROM Customers WHERE Country = 'USA'"
rows, err := db.Query(query)
if err != nil {
panic(err)
}
defer rows.Close()
// Scan the results.
for rows.Next() {
var name string
var email string
err = rows.Scan(&name, &email)
if err != nil {
panic(err)
}
fmt.Println(name, email)
}
}
|
在这个示例中，我们查询了名为“Customers ”的表，该表位于MyDatabase数据库中。我们只选择了名为“Name”和“Email”的列，其中“Country”列为“USA”的行。
当我们执行查询时，结果将会被存储在 query 变量中。然后，我们使用 db.Query() 执行查询。它返回一个结果集，我们使用 rows.Scan() 扫描该结果集。最后，我们循环遍历返回的结果，打印每一行的数据。
写入数据
在使用Go语言中的SQL Server时，写入新数据与读取数据非常相似。要写入数据，我们只需使用 db.Exec() 执行 INSERT、UPDATE 或 DELETE 语句。下面是一个基本的写入示例：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
|
func main() {
server := "localhost\SQLEXPRESS"
port := 1433
user := "sa"
password := "password123"
database := "MyDatabase"
connString := fmt.Sprintf("server=%s;user id=%s;password=%s;port=%d;database=%s;",
server, user, password, port, database)
db, err := sql.Open("mssql", connString)
if err != nil {
panic(err)
}
defer db.Close()
// Insert a new row.
statement := "INSERT INTO Customers (Name, Email, Country) VALUES (?, ?, ?)"
result, err := db.Exec(statement, "John Doe", "johndoe@example.com", "USA")
if err != nil {
panic(err)
}
rowsAffected, err := result.RowsAffected()
if err != nil {
panic(err)
}
// Write successful. Display the number of rows affected.
fmt.Printf("%d rows affected.
", rowsAffected)
}
|
在这个示例中，我们执行了一个INSERT语句向名为“Customers”的表中插入一行数据。我们指定了“John Doe”的名称，“johndoe@example.com”的电子邮件地址，还有“USA”的国家。我们使用 db.Exec() 来写入数据，并使用 fmt.Printf() 打印结果。
总结
在这篇文章中，我们介绍了如何在Go语言中使用SQL Server。我们了解了如何连接到数据库，执行查询和写入数据。我们也看到，Go语言使用SQL Server的过程非常简单，因此，SQL Server成为了企业级应用程序的首选数据存储解决方案之一。如果你是一名Go语言开发人员，并且你想在你的下一个项目中使用SQL Server，本文将为你提供非常有用的指南。
