クイックスタート:Golang を使用して Azure SQL Database または Azure SQL Managed Instance 内のデータベースに対してクエリを実行する

[アーティクル]
12/06/2023

適用対象: Azure SQL データベース Azure SQL Managed Instance

このクイックスタートでは、Golang プログラミング言語を使用して、go-mssqldb ドライバーで Azure SQL データベースまたは Azure SQL Managed Instance 内のデータベースに接続します。このサンプルでは、明示的な Transact-SQL (T-SQL) ステートメントを使用してデータを照会および変更します。 Golang は、シンプルで信頼性と効率性の高いソフトウェアを簡単に構築できるオープンソースプログラミング言語です。

前提条件

このクイックスタートを完了するには、次のものが必要です。

アクティブなサブスクリプションが含まれる Azure アカウント。無料でアカウントを作成できます。

Azure SQL データベースまたは Azure SQL Managed Instance のデータベース。データベースは、次のいずれかのクイックスタートを使って作成できます。

SQL Database	SQL Managed Instance	Azure VM 上の SQL Server
作成
ポータル	ポータル	ポータル
CLI	CLI
PowerShell	PowerShell	PowerShell
構成
サーバーレベルの IP ファイアウォール規則	VM からの接続
	オンプレミスからの接続	SQL Server インスタンスに接続する
データの読み込み
クイックスタートごとに読み込まれる `AdventureWorks2022`	WideWorldImporters を復元する	WideWorldImporters を復元する
	GitHub の BACPAC ファイルから `AdventureWorks2022` を復元またはインポートする	GitHub の BACPAC ファイルから `AdventureWorks2022` を復元またはインポートする

重要

この記事のスクリプトは、AdventureWorks2022 データベースを使用するように記述されています。 SQL Managed Instance の場合は、AdventureWorks2022 データベースをインスタンスデータベースにインポートするか、本記事のスクリプトを変更して Wide World Importers データベースを使用する必要があります。

インストールされている、お使いのオペレーションシステム用 Go およびそれに関連するソフトウェア
インストールされているオペレーティングシステムの最新バージョンの sqlcmd。
インストールされている、お使いのオペレーティングシステム用の Azure PowerShell Az モジュール。

サーバーの接続情報を取得する

データベースに接続するために必要な接続情報を取得します。後の手順で、完全修飾サーバー名またはホスト名、データベース名、およびログイン情報が必要になります。

Azure portal にサインインします。
[SQL Database] または [SQL Managed Instance] ページに移動します。
[概要] ページで、Azure SQL Database 内のデータベースの [サーバー名] の横にある完全修飾サーバー名、または Azure SQL Managed Instance または Azure VM 上の SQL Server の [ホスト] の横にある完全修飾サーバー名 (または IP アドレス) を確認します。サーバー名またはホスト名をコピーするには、名前をポイントして [コピー] アイコンを選択します。

注意

Azure VM 上の SQL Server の接続情報については、SQL Server インスタンスへの接続に関するページをご覧ください。

Golang プロジェクトと依存関係用の新しいフォルダーを作成する

ターミナルから、SqlServerSample という名前の新しいプロジェクトフォルダーを作成します。
```
mkdir SqlServerSample
```

サンプルデータの作成

CreateTestData.sql フォルダー内に、SqlServerSample という新しいテキストファイルを作成します。そのファイルに、次の T-SQL コードを貼り付けます。このコードは、スキーマとテーブルを作成し、数行を挿入します。

CREATE SCHEMA TestSchema;
GO

CREATE TABLE TestSchema.Employees (
    Id INT IDENTITY(1, 1) NOT NULL PRIMARY KEY,
    Name NVARCHAR(50),
    Location NVARCHAR(50)
);
GO

INSERT INTO TestSchema.Employees (Name, Location)
VALUES (N'Jared', N'Australia'),
    (N'Nikita', N'India'),
    (N'Astrid', N'Germany');
GO

SELECT * FROM TestSchema.Employees;
GO

コマンドプロンプトで、SqlServerSample に移動し、sqlcmd を使用してデータベースに接続し、新しく作成した Azure SQL スクリプトを実行します。サーバー、データベースを適切な値に置き換えてください。
```
az login
sqlcmd -S <your_server>.database.windows.net -G -d <your_database> -i ./CreateTestData.sql
```

データベースに対してクエリを実行するコードを挿入する

sample.go フォルダー内に SqlServerSample という名前のファイルを作成します。

そのファイルに、以下のコードを貼り付けます。サーバーおよびデータベースの値を追加します。この例では、Golang コンテキストメソッドを使用して、アクティブな接続があることを確認します。

package main

import (
    "github.com/microsoft/go-mssqldb/azuread"
    "database/sql"
    "context"
    "log"
    "fmt"
    "errors"
)

var db *sql.DB

var server = "<your_server.database.windows.net>"
var port = 1433
var database = "<your_database>"

func main() {
    // Build connection string
    connString := fmt.Sprintf("server=%s;port=%d;database=%s;fedauth=ActiveDirectoryDefault;", server, port, database)

    var err error

    // Create connection pool
        db, err = sql.Open(azuread.DriverName, connString)
    if err != nil {
        log.Fatal("Error creating connection pool: ", err.Error())
    }
    ctx := context.Background()
    err = db.PingContext(ctx)
    if err != nil {
        log.Fatal(err.Error())
    }
    fmt.Printf("Connected!\n")

    // Create employee
    createID, err := CreateEmployee("Jake", "United States")
    if err != nil {
        log.Fatal("Error creating Employee: ", err.Error())
    }
    fmt.Printf("Inserted ID: %d successfully.\n", createID)

    // Read employees
    count, err := ReadEmployees()
    if err != nil {
        log.Fatal("Error reading Employees: ", err.Error())
    }
    fmt.Printf("Read %d row(s) successfully.\n", count)

    // Update from database
    updatedRows, err := UpdateEmployee("Jake", "Poland")
    if err != nil {
        log.Fatal("Error updating Employee: ", err.Error())
    }
    fmt.Printf("Updated %d row(s) successfully.\n", updatedRows)

    // Delete from database
    deletedRows, err := DeleteEmployee("Jake")
    if err != nil {
        log.Fatal("Error deleting Employee: ", err.Error())
    }
    fmt.Printf("Deleted %d row(s) successfully.\n", deletedRows)
}

// CreateEmployee inserts an employee record
func CreateEmployee(name string, location string) (int64, error) {
    ctx := context.Background()
    var err error

    if db == nil {
        err = errors.New("CreateEmployee: db is null")
        return -1, err
    }

    // Check if database is alive.
    err = db.PingContext(ctx)
    if err != nil {
        return -1, err
    }

    tsql := `
      INSERT INTO TestSchema.Employees (Name, Location) VALUES (@Name, @Location);
      select isNull(SCOPE_IDENTITY(), -1);
    `

    stmt, err := db.Prepare(tsql)
    if err != nil {
       return -1, err
    }
    defer stmt.Close()

    row := stmt.QueryRowContext(
        ctx,
        sql.Named("Name", name),
        sql.Named("Location", location))
    var newID int64
    err = row.Scan(&newID)
    if err != nil {
        return -1, err
    }

    return newID, nil
}

// ReadEmployees reads all employee records
func ReadEmployees() (int, error) {
    ctx := context.Background()

    // Check if database is alive.
    err := db.PingContext(ctx)
    if err != nil {
        return -1, err
    }

    tsql := fmt.Sprintf("SELECT Id, Name, Location FROM TestSchema.Employees;")

    // Execute query
    rows, err := db.QueryContext(ctx, tsql)
    if err != nil {
        return -1, err
    }

    defer rows.Close()

    var count int

    // Iterate through the result set.
    for rows.Next() {
        var name, location string
        var id int

        // Get values from row.
        err := rows.Scan(&id, &name, &location)
        if err != nil {
            return -1, err
        }

        fmt.Printf("ID: %d, Name: %s, Location: %s\n", id, name, location)
        count++
    }

    return count, nil
}

// UpdateEmployee updates an employee's information
func UpdateEmployee(name string, location string) (int64, error) {
    ctx := context.Background()

    // Check if database is alive.
    err := db.PingContext(ctx)
    if err != nil {
        return -1, err
    }

    tsql := fmt.Sprintf("UPDATE TestSchema.Employees SET Location = @Location WHERE Name = @Name")

    // Execute non-query with named parameters
    result, err := db.ExecContext(
        ctx,
        tsql,
        sql.Named("Location", location),
        sql.Named("Name", name))
    if err != nil {
        return -1, err
    }

    return result.RowsAffected()
}

// DeleteEmployee deletes an employee from the database
func DeleteEmployee(name string) (int64, error) {
    ctx := context.Background()

    // Check if database is alive.
    err := db.PingContext(ctx)
    if err != nil {
        return -1, err
    }

    tsql := fmt.Sprintf("DELETE FROM TestSchema.Employees WHERE Name = @Name;")

    // Execute non-query with named parameters
    result, err := db.ExecContext(ctx, tsql, sql.Named("Name", name))
    if err != nil {
        return -1, err
    }

    return result.RowsAffected()
}

Golang プロジェクトの依存関係を取得し、コードを実行する

コマンドプロンプトで SqlServerSample に移動し、次のコマンドを実行して、Go 用の SQL Server ドライバーをインストールします。
```
go mod init SqlServerSample
go mod tidy
```
コマンドプロンプトで、次のコマンドを実行します。
```
az login
go run sample.go
```

出力を検証します。

Connected!
Inserted ID: 4 successfully.
ID: 1, Name: Jared, Location: Australia
ID: 2, Name: Nikita, Location: India
ID: 3, Name: Astrid, Location: Germany
ID: 4, Name: Jake, Location: United States
Read 4 row(s) successfully.
Updated 1 row(s) successfully.
Deleted 1 row(s) successfully.

次の方法で共有

クイックスタート:Golang を使用して Azure SQL Database または Azure SQL Managed Instance 内のデータベースに対してクエリを実行する

前提条件

サーバーの接続情報を取得する

Golang プロジェクトと依存関係用の新しいフォルダーを作成する

サンプルデータの作成

データベースに対してクエリを実行するコードを挿入する

Golang プロジェクトの依存関係を取得し、コードを実行する

フィードバック

その他のリソース

次の方法で共有

クイック スタート:Golang を使用して Azure SQL Database または Azure SQL Managed Instance 内のデータベースに対してクエリを実行する

前提条件

サーバーの接続情報を取得する

Golang プロジェクトと依存関係用の新しいフォルダーを作成する

サンプル データの作成

データベースに対してクエリを実行するコードを挿入する

Golang プロジェクトの依存関係を取得し、コードを実行する

関連するコンテンツ

フィードバック

その他のリソース

クイックスタート:Golang を使用して Azure SQL Database または Azure SQL Managed Instance 内のデータベースに対してクエリを実行する

サンプルデータの作成