Краткое руководство. Использование языка Go для подключения и запроса данных в База данных Azure для PostgreSQL — отдельный сервер

Статья
03/30/2023

Область применения: отдельный сервер Базы данных Azure для PostgreSQL

Внимание

База данных Azure для PostgreSQL — одиночный сервер находится на пути выхода на пенсию. Настоятельно рекомендуется выполнить обновление до База данных Azure для PostgreSQL — гибкий сервер. Дополнительные сведения о миграции на База данных Azure для PostgreSQL — гибкий сервер см. в статье "Что происходит с одним сервером База данных Azure для PostgreSQL?".

В этом кратком руководстве описывается, как подключиться к базе данных Azure для PostgreSQL с помощью кода на языке Go (golang). Здесь также показано, как использовать инструкции SQL для запроса, вставки, обновления и удаления данных в базе данных. В этой статье предполагается, что у вас уже есть опыт разработки на Go, и вы только начали работу с базой данных Azure для PostgreSQL.

Необходимые компоненты

В качестве отправной точки в этом кратком руководстве используются ресурсы, созданные в соответствии со следующими материалами:

Установка Go и соединителя pq

Установите язык Go и драйвер Pure Go Postgres на своем компьютере. В зависимости от используемой платформы выполните соответствующие действия.

Windows

Скачайте и установите Go для Microsoft Windows согласно инструкциям по установке.
Запустите командную строку из меню "Пуск".
Создайте папку для проекта, например mkdir %USERPROFILE%\go\src\postgresqlgo.
Перейдите в папку проекта, например cd %USERPROFILE%\go\src\postgresqlgo.
В качестве значения для переменной среды GOPATH укажите путь к каталогу с исходным кодом. set GOPATH=%USERPROFILE%\go.
Установите драйвер Pure Go Postgres (pq) с помощью команды go get github.com/lib/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.
Установите Go, выполнив команду sudo apt-get install golang-go.
Создайте папку для проекта в корневом каталоге, например mkdir -p ~/go/src/postgresqlgo/.
Перейдите в другую папку, например cd ~/go/src/postgresqlgo/.
В качестве значения для переменной среды GOPATH укажите путь к действительному исходному каталогу, например к текущей папке Go в корневом каталоге. В оболочке Bash выполните команду export GOPATH=~/go, чтобы добавить каталог Go в качестве значения переменной GOPATH для текущего сеанса оболочки.
Установите драйвер Pure Go Postgres (pq) с помощью команды go get github.com/lib/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.
Создайте папку для проекта в корневом каталоге, например mkdir -p ~/go/src/postgresqlgo/.
Перейдите в другую папку, например cd ~/go/src/postgresqlgo/.
В качестве значения для переменной среды GOPATH укажите путь к действительному исходному каталогу, например к текущей папке Go в корневом каталоге. В оболочке Bash выполните команду export GOPATH=~/go, чтобы добавить каталог Go в качестве значения переменной GOPATH для текущего сеанса оболочки.
Установите драйвер Pure Go Postgres (pq) с помощью команды go get github.com/lib/pq.

Установите Go, а затем выполните следующие команды Bash:
```
mkdir -p ~/go/src/postgresqlgo/
cd ~/go/src/postgresqlgo/
export GOPATH=~/go/
go get github.com/lib/pq
```

Получение сведений о подключении

Получите сведения, необходимые для подключения к базе данных Azure.для PostgreSQL. Вам потребуется полное имя сервера и учетные данные для входа.

Войдите на портал Azure.
В меню слева на портале Azure выберите Все ресурсы и выполните поиск по имени созданного сервера (например, mydemoserver).
Выберите имя сервера.
Запишите имя сервера и имя для входа администратора сервера с панели сервера Обзор. Если вы забыли свой пароль, можно также сбросить пароль с помощью этой панели.

Сборка и выполнение кода Go

Для написания кода на Golang можно использовать обычный текстовый редактор, например Блокнот в Microsoft Windows, vi или Nano в Ubuntu, а также TextEdit в macOS. Если вы предпочитаете использовать полнофункциональную интегрированную среду разработки, попробуйте GoLand от JetBrains, Visual Studio Code от корпорации Майкрософт или Atom.
Вставьте код Golang из приведенных ниже разделов в текстовые файлы и сохраните их с расширением *.go в папке проекта, например %USERPROFILE%\go\src\postgresqlgo\createtable.go в Windows или ~/go/src/postgresqlgo/createtable.go в Linux.
Найдите константы HOST, DATABASE, USER и PASSWORD в коде и замените приведенные для примера значения своими собственными.
Запустите командную строку или оболочку Bash. Перейдите в папку проекта. В Windows это будет команда cd %USERPROFILE%\go\src\postgresqlgo\, а в Linux — cd ~/go/src/postgresqlgo/. Некоторые из упомянутых сред IDE позволяют выполнять отладку и использовать среду выполнения без применения команд оболочки.
Выполните код с помощью команды go run createtable.go, чтобы скомпилировать и запустить приложение.
Вы также можете создать код в собственном приложении. Для этого введите go build createtable.go, а затем выполните createtable.exe, чтобы запустить приложение.

Подключение и создание таблицы

Используйте приведенный ниже код для подключения и создайте таблицу с помощью инструкции SQL CREATE TABLE. Добавьте строки в таблицу, применив инструкцию SQL INSERT INTO.

Код импортирует три пакета: пакет sql, пакет pq как драйвер для обмена данными с сервером PostgreSQL и пакет fmt для вывода входных и выходных данных в командной строке.

Замените значения параметров HOST, DATABASE, USER и PASSWORD своими значениями.

package main

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

const (
	// Initialize connection constants.
	HOST     = "mydemoserver.postgres.database.azure.com"
	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")
}

Чтение данных

Используйте указанный ниже код с инструкцией SQL SELECT для подключения и чтения данных.

Код вызывает метод sql.Open() для подключения к базе данных Azure для PostgreSQL, а затем проверяет подключение с помощью метода db.Ping(). Дескриптор базы данных используется для всех компонентов. Он содержит пул подключений к серверу базы данных. Запрос выбора выполняется с помощью метода db.Query(), а итоговые строки сохраняются в переменной типа rows. Код считывает из столбцов значения данных в текущей строке с помощью метода rows.Scan(), а затем запускает цикл по строкам, используя итератор сrows.Next(), пока строк больше не останется. Значения столбцов каждой строки печатаются в консоли. Каждый раз, когда пользовательский метод проверка Error() используется для проверка, если произошла ошибка и паника, чтобы выйти, если произошла ошибка.

Замените значения параметров HOST, DATABASE, USER и PASSWORD своими значениями.

package main

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

const (
	// Initialize connection constants.
	HOST     = "mydemoserver.postgres.database.azure.com"
	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)
		}
	}
}

Обновление данных

Используйте указанный ниже код с инструкцией SQL UPDATE для подключения и обновления данных.

Код импортирует три пакета: пакет sql, пакет pq как драйвер для обмена данными с сервером Postgres и пакет fmt для вывода входных и выходных данных в командной строке.

Код вызывает метод sql.Open() для подключения к базе данных Azure для 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.azure.com"
	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")
}

Удаление данных

Используйте указанный ниже код с инструкцией SQL DELETE для подключения и удаления данных.

Код вызывает метод sql.Open() для подключения к базе данных Azure для 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.azure.com"
	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 для PostgreSQL — отдельный сервер

Необходимые компоненты

Установка Go и соединителя pq

Windows

Linux (Ubuntu)

Apple macOS

Получение сведений о подключении

Сборка и выполнение кода Go

Подключение и создание таблицы

Чтение данных

Обновление данных

Удаление данных

Очистка ресурсов

Следующие шаги

Дополнительные ресурсы