快速入门：使用 Go 语言在 Azure Database for MySQL 中进行连接并查询数据

项目
04/12/2024

适用于：Azure Database for MySQL - 单一服务器

重要

Azure Database for MySQL 单一服务器即将停用。强烈建议升级到 Azure Database for MySQL 灵活服务器。有关如何迁移到 Azure Database for MySQL 灵活服务器的详细信息，请参阅 Azure Database for MySQL 单一服务器发生了什么情况？

本快速入门演示如何在 Windows、Ubuntu Linux 和 Apple macOS 平台中使用以 Go 语言编写的代码连接到 Azure Database for MySQL。同时还介绍了如何使用 SQL 语句在数据库中查询、插入、更新和删除数据。本主题假设你熟悉如何使用 Go 进行开发，但不太熟悉 Azure Database for MySQL 的用法。

先决条件

此快速入门使用以下任意指南中创建的资源作为起点：

重要

确保已使用 Azure 门户或 Azure CLI 将服务器的防火墙规则添加到连接的 IP 地址

安装 Go 和 MySQL 连接器

在自己的计算机上安装 Go 和适用于 MySQL 的 go-sql-driver。根据自己的平台执行相应部分中的步骤：

根据安装说明下载和安装用于 Microsoft Windows 的 Go。
从开始菜单启动命令提示符。
为项目创建一个文件夹，例如 mkdir %USERPROFILE%\go\src\mysqlgo。
将目录转到项目文件夹，例如 cd %USERPROFILE%\go\src\mysqlgo。
设置 GOPATH 的环境变量，使之指向源代码目录。 set GOPATH=%USERPROFILE%\go。
通过运行 go get github.com/go-sql-driver/mysql 命令安装用于 MySQL 的 go-sql-driver。

总起来说就是，安装 Go，然后在命令提示符处运行以下命令：
```
mkdir  %USERPROFILE%\go\src\mysqlgo
cd %USERPROFILE%\go\src\mysqlgo
set GOPATH=%USERPROFILE%\go
go get github.com/go-sql-driver/mysql
```

启动 Bash Shell。
通过运行 sudo apt-get install golang-go 来安装 Go。
在主目录中为项目创建一个文件夹，例如 mkdir -p ~/go/src/mysqlgo/。
将目录转到该文件夹，例如 cd ~/go/src/mysqlgo/。
设置 GOPATH 环境变量，使之指向有效的源目录，例如当前主目录的 Go 文件夹。在 Bash shell 中运行 export GOPATH=~/go，将 Go 目录添加为当前 Shell 会话的 GOPATH。

通过运行 go get github.com/go-sql-driver/mysql 命令安装用于 MySQL 的 go-sql-driver。

总起来说就是，运行以下 bash 命令：

sudo apt-get install golang-go git -y
mkdir -p ~/go/src/mysqlgo/
cd ~/go/src/mysqlgo/
export GOPATH=~/go/
go get github.com/go-sql-driver/mysql

下载 Go，然后根据与平台相对应的安装说明进行安装。
启动 Bash Shell。
在主目录中为项目创建一个文件夹，例如 mkdir -p ~/go/src/mysqlgo/。
将目录转到该文件夹，例如 cd ~/go/src/mysqlgo/。
设置 GOPATH 环境变量，使之指向有效的源目录，例如当前主目录的 Go 文件夹。在 Bash shell 中运行 export GOPATH=~/go，将 Go 目录添加为当前 Shell 会话的 GOPATH。
通过运行 go get github.com/go-sql-driver/mysql 命令安装用于 MySQL 的 go-sql-driver。

总起来说就是，安装 Go，然后运行以下 bash 命令：
```
mkdir -p ~/go/src/mysqlgo/
cd ~/go/src/mysqlgo/
export GOPATH=~/go/
go get github.com/go-sql-driver/mysql
```

获取连接信息

获取连接到 Azure Database for MySQL 所需的连接信息。需要完全限定的服务器名称和登录凭据。

登录到 Azure 门户。
在 Azure 门户的左侧菜单中，单击“所有资源”，然后搜索已创建的服务器（例如 mydemoserver）。
单击服务器名称。
从服务器的“概览”面板中记下“服务器名称”和“服务器管理员登录名”。如果忘记了密码，也可通过此面板来重置密码。

生成和运行 Go 代码

若要编写 Golang 代码，可以使用简单的文本编辑器，例如 Microsoft Windows 中的记事本、Ubuntu 中的 vi 或 Nano，或者 macOS 中的 TextEdit。如果偏好功能更丰富的交互式开发环境 (IDE)，可尝试 Jetbrains 推出的 Gogland、Microsoft 推出的 Visual Studio Code，或者 Atom。
将以下部分中的 Go 代码粘贴到文本文件中，再使用文件扩展名 %USERPROFILE%\go\src\mysqlgo\createtable.go.go 将这些文件保存到项目文件夹中（例如 Windows 路径或 Linux 路径~/go/src/mysqlgo/createtable.go）。
在代码中找到 HOST、DATABASE、USER 和 PASSWORD 常量，然后将示例值替换为自己的值。
启动命令提示符或 Bash shell。将目录转到项目文件夹。例如，在 Windows 上使用 cd %USERPROFILE%\go\src\mysqlgo\。在 Linux 上使用 cd ~/go/src/mysqlgo/。提到的某些 IDE 编辑器提供不需 shell 命令的调试和运行时功能。
通过键入命令 go run createtable.go 来运行代码，编译并运行应用程序。
另外，若要将代码内建到本机应用程序中，请键入命令 go build createtable.go，再启动 createtable.exe 来运行该应用程序。

进行连接，创建表，然后插入数据

通过以下代码连接到服务器，创建一个表，然后使用 INSERT SQL 语句加载数据。

代码导入三个包：sql 包、适用于 mysql 的 go sql driver（充当与 Azure Database for MySQL 通信所需的驱动程序），以及 fmt 包（适用于在命令行中列显的输入和输出）。

代码通过调用 sql.Open() 方法来连接到 Azure Database for MySQL，并使用 db.Ping() 方法来检查连接。将始终使用数据库句柄来存储数据库服务器的连接池。代码多次调用 Exec() 方法来运行多个 DDL 命令。代码还使用 Prepare() 和 Exec() 来运行准备的语句，通过不同的参数插入三行。每次都会使用自定义 checkError() 方法来检查是否发生错误，以及是否死机退出。

将 host、database、user、password 常量替换为自己的值。

package main

import (
	"database/sql"
	"fmt"

	_ "github.com/go-sql-driver/mysql"
)

const (
	host     = "mydemoserver.mysql.database.chinacloudapi.cn"
	database = "quickstartdb"
	user     = "myadmin@mydemoserver"
	password = "yourpassword"
)

func checkError(err error) {
	if err != nil {
		panic(err)
	}
}

func main() {

	// Initialize connection string.
	var connectionString = fmt.Sprintf("%s:%s@tcp(%s:3306)/%s?allowNativePasswords=true", user, password, host, database)

	// Initialize connection object.
	db, err := sql.Open("mysql", connectionString)
	checkError(err)
	defer db.Close()

	err = db.Ping()
	checkError(err)
	fmt.Println("Successfully created connection to database.")

	// Drop previous table of same name if one exists.
	_, err = db.Exec("DROP TABLE IF EXISTS inventory;")
	checkError(err)
	fmt.Println("Finished dropping table (if existed).")

	// Create table.
	_, err = db.Exec("CREATE TABLE inventory (id serial PRIMARY KEY, name VARCHAR(50), quantity INTEGER);")
	checkError(err)
	fmt.Println("Finished creating table.")

	// Insert some data into table.
	sqlStatement, err := db.Prepare("INSERT INTO inventory (name, quantity) VALUES (?, ?);")
	res, err := sqlStatement.Exec("banana", 150)
	checkError(err)
	rowCount, err := res.RowsAffected()
	fmt.Printf("Inserted %d row(s) of data.\n", rowCount)

	res, err = sqlStatement.Exec("orange", 154)
	checkError(err)
	rowCount, err = res.RowsAffected()
	fmt.Printf("Inserted %d row(s) of data.\n", rowCount)

	res, err = sqlStatement.Exec("apple", 100)
	checkError(err)
	rowCount, err = res.RowsAffected()
	fmt.Printf("Inserted %d row(s) of data.\n", rowCount)
	fmt.Println("Done.")
}

读取数据

使用以下代码进行连接，并使用 SELECT SQL 语句读取数据。

代码通过调用 sql.Open() 方法来连接到 Azure Database for MySQL，并使用 db.Ping() 方法来检查连接。将始终使用数据库句柄来存储数据库服务器的连接池。代码调用 Query() 方法来运行 select 命令。接下来，代码运行 Next() 来循环访问结果集，再运行 Scan() 来分析列值，将值保存到变量中。每次都会使用自定义 checkError() 方法来检查是否发生错误，以及是否死机退出。

将 host、database、user、password 常量替换为自己的值。

package main

import (
	"database/sql"
	"fmt"

	_ "github.com/go-sql-driver/mysql"
)

const (
	host     = "mydemoserver.mysql.database.chinacloudapi.cn"
	database = "quickstartdb"
	user     = "myadmin@mydemoserver"
	password = "yourpassword"
)

func checkError(err error) {
	if err != nil {
		panic(err)
	}
}

func main() {

	// Initialize connection string.
	var connectionString = fmt.Sprintf("%s:%s@tcp(%s:3306)/%s?allowNativePasswords=true", user, password, host, database)

	// Initialize connection object.
	db, err := sql.Open("mysql", connectionString)
	checkError(err)
	defer db.Close()

	err = db.Ping()
	checkError(err)
	fmt.Println("Successfully created connection to database.")

	// Variables for printing column data when scanned.
	var (
		id       int
		name     string
		quantity int
	)

	// Read some data from the table.
	rows, err := db.Query("SELECT id, name, quantity from inventory;")
	checkError(err)
	defer rows.Close()
	fmt.Println("Reading data:")
	for rows.Next() {
		err := rows.Scan(&id, &name, &quantity)
		checkError(err)
		fmt.Printf("Data row = (%d, %s, %d)\n", id, name, quantity)
	}
	err = rows.Err()
	checkError(err)
	fmt.Println("Done.")
}

更新数据

使用以下代码进行连接，并使用 UPDATE SQL 语句更新数据。

代码通过调用 sql.Open() 方法来连接到 Azure Database for MySQL，并使用 db.Ping() 方法来检查连接。将始终使用数据库句柄来存储数据库服务器的连接池。代码调用 Exec() 方法来运行 update 命令。每次都会使用自定义 checkError() 方法来检查是否发生错误，以及是否死机退出。

将 host、database、user、password 常量替换为自己的值。

package main

import (
	"database/sql"
	"fmt"

	_ "github.com/go-sql-driver/mysql"
)

const (
	host     = "mydemoserver.mysql.database.chinacloudapi.cn"
	database = "quickstartdb"
	user     = "myadmin@mydemoserver"
	password = "yourpassword"
)

func checkError(err error) {
	if err != nil {
		panic(err)
	}
}

func main() {

	// Initialize connection string.
	var connectionString = fmt.Sprintf("%s:%s@tcp(%s:3306)/%s?allowNativePasswords=true", user, password, host, database)

	// Initialize connection object.
	db, err := sql.Open("mysql", connectionString)
	checkError(err)
	defer db.Close()

	err = db.Ping()
	checkError(err)
	fmt.Println("Successfully created connection to database.")

	// Modify some data in table.
	rows, err := db.Exec("UPDATE inventory SET quantity = ? WHERE name = ?", 200, "banana")
	checkError(err)
	rowCount, err := rows.RowsAffected()
	fmt.Printf("Updated %d row(s) of data.\n", rowCount)
	fmt.Println("Done.")
}

删除数据

使用以下代码进行连接，并使用 DELETE SQL 语句删除数据。

代码通过调用 sql.Open() 方法来连接到 Azure Database for MySQL，并使用 db.Ping() 方法来检查连接。将始终使用数据库句柄来存储数据库服务器的连接池。代码调用 Exec() 方法来运行 delete 命令。每次都会使用自定义 checkError() 方法来检查是否发生错误，以及是否死机退出。

将 host、database、user、password 常量替换为自己的值。

package main

import (
	"database/sql"
	"fmt"
	_ "github.com/go-sql-driver/mysql"
)

const (
	host     = "mydemoserver.mysql.database.chinacloudapi.cn"
	database = "quickstartdb"
	user     = "myadmin@mydemoserver"
	password = "yourpassword"
)

func checkError(err error) {
	if err != nil {
		panic(err)
	}
}

func main() {

	// Initialize connection string.
	var connectionString = fmt.Sprintf("%s:%s@tcp(%s:3306)/%s?allowNativePasswords=true", user, password, host, database)

	// Initialize connection object.
	db, err := sql.Open("mysql", connectionString)
	checkError(err)
	defer db.Close()

	err = db.Ping()
	checkError(err)
	fmt.Println("Successfully created connection to database.")

	// Modify some data in table.
	rows, err := db.Exec("DELETE FROM inventory WHERE name = ?", "orange")
	checkError(err)
	rowCount, err := rows.RowsAffected()
	fmt.Printf("Deleted %d row(s) of data.\n", rowCount)
	fmt.Println("Done.")
}

清理资源

若要清理本快速入门中使用的所有资源，请使用以下命令删除该资源组：

az group delete \
    --name $AZ_RESOURCE_GROUP \
    --yes

后续步骤

使用导出和导入功能迁移数据库

快速入门：使用 Go 语言在 Azure Database for MySQL 中进行连接并查询数据

先决条件

安装 Go 和 MySQL 连接器

获取连接信息

生成和运行 Go 代码

进行连接，创建表，然后插入数据

读取数据

更新数据

删除数据

清理资源

后续步骤

其他资源