快速入门：使用 Go 语言连接到 Azure Database for PostgreSQL 并查询其中的数据 - 单一服务器

项目
08/09/2024

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

重要

Azure Database for PostgreSQL - 单一服务器即将停用。我们强烈建议升级到 Azure Database for PostgreSQL 灵活服务器。有关迁移到 Azure Database for PostgreSQL 灵活服务器的详细信息，请参阅 Azure Database for PostgreSQL 单一服务器的最新动态。

本快速入门演示如何使用以 Go 语言 (golang) 编写的代码连接到 Azure Database for PostgreSQL。同时还介绍了如何使用 SQL 语句在数据库中查询、插入、更新和删除数据。本文假设你熟悉如何使用 Go 进行开发，但不熟悉如何使用 Azure Database for PostgreSQL。

先决条件

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

安装 Go 和 pq 连接器

在自己的计算机上安装 Go 和纯 Go 语言 Postgres 驱动程序 (pq)。根据自己的平台执行相应步骤：

Windows

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

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

Linux (Ubuntu)

启动 Bash Shell。
通过运行 sudo apt-get install golang-go 来安装 Go。
在主目录中为项目创建一个文件夹，例如 mkdir -p ~/go/src/postgresqlgo/。
将目录转到该文件夹，例如 cd ~/go/src/postgresqlgo/。
设置 GOPATH 环境变量，使之指向有效的源目录，例如当前主目录的 Go 文件夹。在 Bash Shell 中运行 export GOPATH=~/go，将 Go 目录添加为当前 Shell 会话的 GOPATH。
通过运行 go get github.com/lib/pq 命令安装纯 Go 语言 Postgres 驱动程序 (pq)。

总起来说就是，运行以下 bash 命令：
```
sudo apt-get install golang-go
mkdir -p ~/go/src/postgresqlgo/
cd ~/go/src/postgresqlgo/
export GOPATH=~/go/
go get github.com/lib/pq
```

Apple macOS

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

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

获取连接信息

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

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

生成和运行 Go 代码

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

进行连接并创建表

使用以下代码进行连接，使用 CREATE TABLE SQL 语句创建表，然后使用 INSERT INTO SQL 语句将行添加到表中。

代码将导入三个包：sql 包、pq 包（充当与 PostgreSQL 服务器通信所需的驱动程序）以及 fmt 包（用于命令行中的打印输入和输出）。

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

将 HOST、DATABASE、USER 和 PASSWORD 参数替换为你自己的值。

package main

import (
	"database/sql"
	"fmt"
	_ "github.com/lib/pq"
)

const (
	// Initialize connection constants.
	HOST     = "mydemoserver.postgres.database.chinacloudapi.cn"
	DATABASE = "mypgsqldb"
	USER     = "mylogin@mydemoserver"
	PASSWORD = "<server_admin_password>"
)

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

func main() {
	// Initialize connection string.
	var connectionString string = fmt.Sprintf("host=%s user=%s password=%s dbname=%s sslmode=require", HOST, USER, PASSWORD, DATABASE)

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

	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.
	sql_statement := "INSERT INTO inventory (name, quantity) VALUES ($1, $2);"
	_, err = db.Exec(sql_statement, "banana", 150)
	checkError(err)
	_, err = db.Exec(sql_statement, "orange", 154)
	checkError(err)
	_, err = db.Exec(sql_statement, "apple", 100)
	checkError(err)
	fmt.Println("Inserted 3 rows of data")
}

读取数据

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

代码将导入三个包：sql 包、pq 包（充当与 PostgreSQL 服务器通信所需的驱动程序）以及 fmt 包（用于命令行中的打印输入和输出）。

代码通过调用 sql.Open() 方法来连接到 Azure Database for PostgreSQL 数据库，并使用 db.Ping() 方法来检查连接。将始终使用数据库句柄来存储数据库服务器的连接池。 select 查询通过调用方法 db.Query() 来运行，生成的行保留在类型为行的变量中。代码使用 rows.Scan() 方法来读取当前行中的列数据值，并使用迭代器 rows.Next() 来循环访问相关行，直到再也没有行存在。每行的列值列显到控制台。每次都将使用自定义 checkError() 方法检查是否发生错误，以及是否在发生错误时死机退出。

将 HOST、DATABASE、USER 和 PASSWORD 参数替换为你自己的值。

package main

import (
	"database/sql"
	"fmt"
	_ "github.com/lib/pq"
)

const (
	// Initialize connection constants.
	HOST     = "mydemoserver.postgres.database.chinacloudapi.cn"
	DATABASE = "mypgsqldb"
	USER     = "mylogin@mydemoserver"
	PASSWORD = "<server_admin_password>"
)

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

func main() {

	// Initialize connection string.
	var connectionString string = fmt.Sprintf("host=%s user=%s password=%s dbname=%s sslmode=require", HOST, USER, PASSWORD, DATABASE)

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

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

	// Read rows from table.
	var id int
	var name string
	var quantity int

	sql_statement := "SELECT * from inventory;"
	rows, err := db.Query(sql_statement)
	checkError(err)
	defer rows.Close()

	for rows.Next() {
		switch err := rows.Scan(&id, &name, &quantity); err {
		case sql.ErrNoRows:
			fmt.Println("No rows were returned")
		case nil:
			fmt.Printf("Data row = (%d, %s, %d)\n", id, name, quantity)
		default:
			checkError(err)
		}
	}
}

更新数据

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

代码导入三个包：sql 包、pq 包（充当与 Postgres 服务器通信所需的驱动程序）以及 fmt 包（适用于在命令行中列显的输入和输出）。

代码通过调用 sql.Open() 方法来连接到 Azure Database for PostgreSQL 数据库，并使用 db.Ping() 方法来检查连接。将始终使用数据库句柄来存储数据库服务器的连接池。代码通过调用 Exec() 方法来运行 SQL 语句，以便更新表。使用自定义 checkError() 方法检查是否发生错误，以及是否在发生错误时死机退出。

将 HOST、DATABASE、USER 和 PASSWORD 参数替换为你自己的值。

package main

import (
  "database/sql"
  _ "github.com/lib/pq"
  "fmt"
)

const (
	// Initialize connection constants.
	HOST     = "mydemoserver.postgres.database.chinacloudapi.cn"
	DATABASE = "mypgsqldb"
	USER     = "mylogin@mydemoserver"
	PASSWORD = "<server_admin_password>"
)

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

func main() {

	// Initialize connection string.
	var connectionString string = 
		fmt.Sprintf("host=%s user=%s password=%s dbname=%s sslmode=require", HOST, USER, PASSWORD, DATABASE)

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

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

	// Modify some data in table.
	sql_statement := "UPDATE inventory SET quantity = $2 WHERE name = $1;"
	_, err = db.Exec(sql_statement, "banana", 200)
	checkError(err)
	fmt.Println("Updated 1 row of data")
}

删除数据

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

代码导入三个包：sql 包、pq 包（充当与 Postgres 服务器通信所需的驱动程序）以及 fmt 包（适用于在命令行中列显的输入和输出）。

代码通过调用 sql.Open() 方法来连接到 Azure Database for PostgreSQL 数据库，并使用 db.Ping() 方法来检查连接。将始终使用数据库句柄来存储数据库服务器的连接池。代码通过调用 Exec() 方法来运行 SQL 语句，以便从表中删除行。使用自定义 checkError() 方法检查是否发生错误，以及是否在发生错误时死机退出。

将 HOST、DATABASE、USER 和 PASSWORD 参数替换为你自己的值。

package main

import (
  "database/sql"
  _ "github.com/lib/pq"
  "fmt"
)

const (
	// Initialize connection constants.
	HOST     = "mydemoserver.postgres.database.chinacloudapi.cn"
	DATABASE = "mypgsqldb"
	USER     = "mylogin@mydemoserver"
	PASSWORD = "<server_admin_password>"
)

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

func main() {

	// Initialize connection string.
	var connectionString string = 
		fmt.Sprintf("host=%s user=%s password=%s dbname=%s sslmode=require", HOST, USER, PASSWORD, DATABASE)

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

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

	// Delete some data from table.
	sql_statement := "DELETE FROM inventory WHERE name = $1;"
	_, err = db.Exec(sql_statement, "orange")
	checkError(err)
	fmt.Println("Deleted 1 row of data")
}

清理资源

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

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

后续步骤

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

通过

快速入门：使用 Go 语言连接到 Azure Database for PostgreSQL 并查询其中的数据 - 单一服务器

先决条件

安装 Go 和 pq 连接器

Windows

Linux (Ubuntu)

Apple macOS

获取连接信息

生成和运行 Go 代码

进行连接并创建表

读取数据

更新数据

删除数据

清理资源

后续步骤

其他资源