MENU
  1. ホーム
  2. Go
  3. Go言語のdatabase/sqlパッケージ入門：基本的な使い方を解説

Go言語のdatabase/sqlパッケージ入門：基本的な使い方を解説

Go

Go言語でデータベース操作を行うためのプログラムを作成する際、database/sqlパッケージは欠かせないツールです。このパッケージは、データベースドライバーと連携して、様々なSQLデータベースとやり取りを行うための標準的なインターフェースを提供します。本記事では、database/sqlを活用したデータベース接続の基本を解説し、初学者でも簡単に取り組める具体的なコード例を交えながら進めていきます。この記事を読むことで、Go言語を使ったデータベース操作の基本が理解でき、実践的なスキルを身に付けられるでしょう。

目次

`database/sql`パッケージとは

Go言語のdatabase/sqlパッケージは、SQLデータベースと連携するための標準的なインターフェースを提供する組み込みライブラリです。このパッケージを利用することで、MySQL、PostgreSQL、SQLiteなど、さまざまなデータベースシステムに対して一貫した方法で接続し、クエリを実行することができます。

抽象化されたデータベース操作

database/sqlは、SQL文を直接記述して実行するための機能を提供しますが、特定のデータベースの実装に依存せずに動作するよう設計されています。そのため、database/sql自体はデータベースの詳細な操作を行わず、実際の処理は各データベースドライバーに委ねられます。

主な機能

  • データベース接続管理：接続プールを利用して効率的な接続管理を実現。
  • クエリの実行：SQL文を送信して、結果を取得または操作。
  • トランザクション：複数のクエリをまとめて実行し、一貫性を保つ処理を実現。
  • エラー処理：SQL操作中に発生したエラーをキャッチし、適切に対処。

データベースドライバーとの連携

database/sqlを使用するには、対象のデータベースに対応したドライバーをインポートする必要があります。たとえば、MySQLを使用する場合はgithub.com/go-sql-driver/mysqlパッケージを利用します。database/sqlが提供する抽象化されたインターフェースにより、異なるデータベース間でのコード変更を最小限に抑えることが可能です。

このように、database/sqlパッケージは、Go言語を用いたデータベース操作を効率的かつ汎用的に行うための基盤となります。

データベース接続の基本

Go言語でdatabase/sqlパッケージを使用してデータベースに接続する際、接続設定の正確さと適切な管理が重要です。ここでは、データベース接続の基本手順について説明します。

接続に必要な情報

データベースに接続するためには、以下の情報が必要です：

  • データベースの種類：MySQL、PostgreSQL、SQLiteなど。
  • 接続文字列：接続に必要な情報を含む文字列（例：ユーザー名、パスワード、ホスト名、ポート番号、データベース名）。
  • データベースドライバー：Goでそのデータベースに接続するためのライブラリ。

接続手順

  1. ドライバーのインポート
    データベースに対応したドライバーをインポートします。以下はMySQLの例です：
   import (
       "database/sql"
       _ "github.com/go-sql-driver/mysql"
   )

_は、このドライバーを利用するために必要な初期化を行うだけで、明示的には使用しないことを示します。

  1. sql.Openで接続を作成
    sql.Open関数を使用して接続オブジェクトを作成します：
   db, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/dbname")
   if err != nil {
       log.Fatal(err)
   }
  • 第一引数：データベースドライバー名（例：mysql）。
  • 第二引数：接続文字列。
  1. 接続の検証
    実際に接続が確立できるか検証します：
   if err := db.Ping(); err != nil {
       log.Fatal(err)
   }

接続文字列の書き方

データベースの種類に応じて接続文字列の形式が異なります。以下はMySQLの例です：

"user:password@tcp(host:port)/dbname"

たとえば、ローカルホストでポート3306を使い、データベース名がtestdbの場合：

db, err := sql.Open("mysql", "root:secret@tcp(127.0.0.1:3306)/testdb")

注意点

  • 接続プール：sql.Openで作成される接続は接続プールを管理します。不要になったら必ずdb.Close()を呼び出してリソースを解放してください。
  • セキュリティ：接続文字列にハードコードした認証情報を含めるのは避け、環境変数や設定ファイルを利用しましょう。

これでGo言語を用いたデータベース接続の基礎が理解できます。次のステップでは、実際にSQLクエリを実行する方法について解説します。

クエリの実行方法

Go言語のdatabase/sqlパッケージを使用してSQLクエリを実行する方法について説明します。このセクションでは、クエリの種類（データ操作とデータ取得）に応じた基本的な手順を解説します。

クエリの種類

  1. データ操作クエリ（INSERT、UPDATE、DELETEなど）
    データの追加、更新、削除を行うクエリ。
  2. データ取得クエリ（SELECT）
    データを取得して処理するクエリ。

データ操作クエリの実行

データ操作クエリを実行する場合、Execメソッドを使用します。このメソッドはクエリの実行結果をsql.Resultオブジェクトで返します。

result, err := db.Exec("INSERT INTO users (name, age) VALUES (?, ?)", "Alice", 30)
if err != nil {
    log.Fatal(err)
}
  • ?プレースホルダーを使用してパラメータを安全に設定します。
  • パラメータは、Execの後の引数として渡します。

実行結果の取得

以下のようにして、影響を受けた行数や挿入された行のIDを取得できます。

rowsAffected, _ := result.RowsAffected()
lastInsertId, _ := result.LastInsertId()
fmt.Printf("Rows affected: %d, Last Insert ID: %d\n", rowsAffected, lastInsertId)

データ取得クエリの実行

データを取得するクエリには、QueryまたはQueryRowメソッドを使用します。

複数行の取得：`Query`

複数の行を取得するには、Queryメソッドを使用して結果を反復処理します。

rows, err := db.Query("SELECT id, name, age FROM users WHERE age > ?", 25)
if err != nil {
    log.Fatal(err)
}
defer rows.Close()

for rows.Next() {
    var id int
    var name string
    var age int
    if err := rows.Scan(&id, &name, &age); err != nil {
        log.Fatal(err)
    }
    fmt.Printf("ID: %d, Name: %s, Age: %d\n", id, name, age)
}
if err := rows.Err(); err != nil {
    log.Fatal(err)
}

単一行の取得：`QueryRow`

結果が1行であることが確実な場合は、QueryRowを使用します。

var name string
var age int
err := db.QueryRow("SELECT name, age FROM users WHERE id = ?", 1).Scan(&name, &age)
if err != nil {
    if err == sql.ErrNoRows {
        fmt.Println("No rows found")
    } else {
        log.Fatal(err)
    }
} else {
    fmt.Printf("Name: %s, Age: %d\n", name, age)
}

注意点

  • SQLインジェクション対策：クエリのパラメータには?プレースホルダーを使用し、外部入力を直接埋め込まないようにしましょう。
  • リソースの解放：クエリの結果を扱う際は、defer rows.Close()を忘れないようにしてください。
  • エラー処理：クエリの実行時と結果取得時の両方でエラー処理を行いましょう。

以上の方法で、Go言語を使ったデータ操作と取得の基本的なクエリ実行が可能になります。次は、クエリ結果の取得とデータ処理について詳しく説明します。

結果の取得と処理

SQLクエリを実行した後、結果を適切に取得して処理することが重要です。Go言語のdatabase/sqlパッケージでは、結果を安全かつ効率的に扱うための方法が用意されています。このセクションでは、クエリ結果の取得と処理について詳しく解説します。

クエリ結果の基本的な取得方法

SQLクエリの結果を取得する際には、以下の二つの方法を使用します：

  1. 複数行の結果を取得：Queryメソッドを使用。
  2. 単一行の結果を取得：QueryRowメソッドを使用。

複数行の結果を取得して処理する

Queryメソッドを使用すると、複数行の結果を取得できます。取得した行を反復処理することで、データを順に処理します。

rows, err := db.Query("SELECT id, name, age FROM users WHERE age > ?", 25)
if err != nil {
    log.Fatal(err)
}
defer rows.Close() // 必ずクエリ結果をクローズ

for rows.Next() {
    var id int
    var name string
    var age int
    if err := rows.Scan(&id, &name, &age); err != nil {
        log.Fatal(err)
    }
    fmt.Printf("ID: %d, Name: %s, Age: %d\n", id, name, age)
}

if err := rows.Err(); err != nil { // 反復中のエラーをチェック
    log.Fatal(err)
}

重要なポイント

  • rows.Scanの使用：各行のデータを変数にマッピングします。
  • defer rows.Close()：データベース接続を閉じてリソースを解放します。
  • エラー処理：rows.Errで反復処理中に発生したエラーをチェックします。

単一行の結果を取得して処理する

結果が1行だけであることが確実な場合は、QueryRowメソッドを使用します。このメソッドは単一の結果を返すため、効率的にデータを取得できます。

var name string
var age int
err := db.QueryRow("SELECT name, age FROM users WHERE id = ?", 1).Scan(&name, &age)
if err != nil {
    if err == sql.ErrNoRows {
        fmt.Println("No matching record found")
    } else {
        log.Fatal(err)
    }
} else {
    fmt.Printf("Name: %s, Age: %d\n", name, age)
}

重要なポイント

  • sql.ErrNoRowsの処理：該当する行がない場合に返されるエラーを適切に処理します。
  • Scanの使用：QueryRowの結果を変数に格納します。

複雑な結果の処理

カスタム構造体を使用して、複数列のデータを効率的に処理することも可能です。

type User struct {
    ID   int
    Name string
    Age  int
}

var users []User
rows, err := db.Query("SELECT id, name, age FROM users")
if err != nil {
    log.Fatal(err)
}
defer rows.Close()

for rows.Next() {
    var user User
    if err := rows.Scan(&user.ID, &user.Name, &user.Age); err != nil {
        log.Fatal(err)
    }
    users = append(users, user)
}
fmt.Println(users)

注意点

  • リソース管理：rows.Close()を忘れると、接続が開放されずリソースリークの原因になります。
  • エラー処理：クエリ実行後とrows.Next処理中の両方でエラーをチェックしてください。
  • カスタム構造体の活用：複雑なデータを扱う場合、構造体を使用してコードの可読性を高めましょう。

これらの方法を使えば、Go言語を使ったデータベースの結果取得と処理がスムーズに行えます。次は、エラー処理の基本について説明します。

エラー処理の基本

Go言語でdatabase/sqlパッケージを使用する際、適切なエラー処理は安全で信頼性の高いアプリケーションを構築するために欠かせません。このセクションでは、データベース操作中に発生する可能性のあるエラーを管理する方法を解説します。

エラー処理の基本原則

  1. すべてのエラーを検出する
    データベース接続、クエリ実行、結果取得のすべての段階でエラーを確認します。
  2. エラーの特定
    エラーの種類に応じて適切な対応を行います。特定のエラーについては特別な処理を行うこともできます。
  3. 詳細なエラーメッセージを記録する
    エラー内容をログに記録し、デバッグやユーザー通知に役立てます。

接続エラーの処理

データベースへの接続中にエラーが発生する場合があります。以下のように接続時のエラーを確認します。

db, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/dbname")
if err != nil {
    log.Fatalf("Failed to connect to database: %v", err)
}

if err := db.Ping(); err != nil {
    log.Fatalf("Unable to establish connection: %v", err)
}
  • sql.Openでは、接続文字列の構文エラーを確認。
  • db.Pingで、データベースが実際に利用可能であるかを検証。

クエリ実行時のエラー処理

クエリ実行中のエラーは、特に入力内容やクエリの構文に依存します。エラーを適切に確認し、ログやエラーメッセージとして記録します。

result, err := db.Exec("INSERT INTO users (name, age) VALUES (?, ?)", "Alice", 30)
if err != nil {
    log.Printf("Error executing query: %v", err)
    return
}
  • クエリに誤りがある場合、errに詳細情報が格納されます。

結果取得時のエラー処理

結果を処理する際にもエラーが発生する可能性があります。たとえば、データが存在しない場合や型の不一致がある場合です。

var name string
var age int
err := db.QueryRow("SELECT name, age FROM users WHERE id = ?", 1).Scan(&name, &age)
if err != nil {
    if err == sql.ErrNoRows {
        fmt.Println("No matching record found")
    } else {
        log.Printf("Error retrieving data: %v", err)
    }
}
  • sql.ErrNoRowsをチェックして、該当するデータがないケースを処理します。

トランザクションでのエラー処理

トランザクション内でエラーが発生した場合、ロールバックを行ってデータの整合性を保ちます。

tx, err := db.Begin()
if err != nil {
    log.Fatalf("Error starting transaction: %v", err)
}

_, err = tx.Exec("UPDATE accounts SET balance = balance - ? WHERE id = ?", 100, 1)
if err != nil {
    tx.Rollback() // エラー時はロールバック
    log.Printf("Transaction rolled back: %v", err)
    return
}

if err := tx.Commit(); err != nil {
    log.Fatalf("Error committing transaction: %v", err)
}

エラー処理のベストプラクティス

  1. エラー内容を明確に記録
    エラーが発生した箇所、内容、影響を詳細にログに記録します。
  2. 適切なエラーハンドリング
    ユーザーに表示するエラーメッセージは、データベース内部の情報を含まないように注意します。
  3. リソースの解放を確実に行う
    エラーが発生しても、接続やクエリ結果のリソース解放を忘れないようにします。

これらの方法を組み合わせることで、安全で信頼性の高いデータベース操作が可能になります。次は、トランザクションを活用したデータベース操作について解説します。

トランザクションの利用方法

トランザクションは、データベース操作の一貫性を保つために複数のSQLクエリをまとめて実行する仕組みです。database/sqlパッケージでは、トランザクションを利用して安全で効率的なデータ操作を行うことができます。このセクションでは、トランザクションの基本概念と実装方法を解説します。

トランザクションとは

トランザクションは以下の特性を持つ処理単位を指します（ACID特性）：

  1. Atomicity（原子性）：すべての操作が完全に実行されるか、全く実行されないかのどちらか。
  2. Consistency（一貫性）：データベースの状態が一貫性のある状態を保つ。
  3. Isolation（分離性）：他のトランザクションからの影響を受けない。
  4. Durability（耐久性）：トランザクションの結果が永続的に保存される。

トランザクションの基本操作

database/sqlでトランザクションを使用する場合、以下の手順で実装します：

  1. トランザクションの開始
  2. SQLクエリの実行
  3. 成功時にコミット、失敗時にロールバック

トランザクションの開始

トランザクションはdb.Beginメソッドを使用して開始します。このメソッドは*sql.Tx（トランザクションオブジェクト）を返します。

tx, err := db.Begin()
if err != nil {
    log.Fatalf("Error starting transaction: %v", err)
}

トランザクション内でのクエリ実行

トランザクション内では、ExecやQueryをtxオブジェクトで実行します。

_, err = tx.Exec("UPDATE accounts SET balance = balance - ? WHERE id = ?", 100, 1)
if err != nil {
    tx.Rollback() // エラー時はロールバック
    log.Printf("Transaction rolled back: %v", err)
    return
}

_, err = tx.Exec("UPDATE accounts SET balance = balance + ? WHERE id = ?", 100, 2)
if err != nil {
    tx.Rollback() // エラー時はロールバック
    log.Printf("Transaction rolled back: %v", err)
    return
}

コミットとロールバック

すべてのクエリが正常に実行された場合はCommitを呼びます。一方、エラーが発生した場合はRollbackを呼び、トランザクション内の変更を無効にします。

if err := tx.Commit(); err != nil {
    log.Fatalf("Error committing transaction: %v", err)
}

エラー時：

if err := tx.Rollback(); err != nil {
    log.Printf("Error rolling back transaction: %v", err)
}

具体例：送金システム

以下は、あるユーザーから別のユーザーへ送金するトランザクションの例です。

func transferFunds(db *sql.DB, fromID, toID int, amount float64) error {
    tx, err := db.Begin()
    if err != nil {
        return fmt.Errorf("error starting transaction: %w", err)
    }

    // 減算クエリ
    _, err = tx.Exec("UPDATE accounts SET balance = balance - ? WHERE id = ?", amount, fromID)
    if err != nil {
        tx.Rollback()
        return fmt.Errorf("error debiting account: %w", err)
    }

    // 加算クエリ
    _, err = tx.Exec("UPDATE accounts SET balance = balance + ? WHERE id = ?", amount, toID)
    if err != nil {
        tx.Rollback()
        return fmt.Errorf("error crediting account: %w", err)
    }

    // コミット
    if err := tx.Commit(); err != nil {
        return fmt.Errorf("error committing transaction: %w", err)
    }

    return nil
}

注意点

  • エラー処理：クエリ実行ごとにエラーをチェックし、エラーが発生した場合は必ずRollbackを呼びます。
  • 長時間のトランザクションを避ける：トランザクションが長時間続くと、デッドロックの原因になります。
  • データの整合性：トランザクションを正しく使用することで、一貫性を保ちます。

トランザクションを活用することで、安全で信頼性の高いデータベース操作を実現できます。次は、応用例として複数クエリの実行方法を解説します。

応用例：複数クエリの実行

database/sqlパッケージを使用すると、複数のSQLクエリを効率的かつ安全に実行することができます。このセクションでは、複数クエリを連続的に実行する方法と、その際の注意点を解説します。

複数クエリの基本

複数のSQLクエリを実行する際には、以下の方法を用います：

  1. 逐次実行：クエリを順番に実行し、それぞれの結果を処理。
  2. トランザクションの活用：すべてのクエリを一つのトランザクション内で実行。

逐次実行

逐次実行では、それぞれのクエリを個別にExecまたはQueryで実行します。この方法はクエリ間の関連が薄い場合に適しています。

// クエリ1: 新しいユーザーの挿入
_, err := db.Exec("INSERT INTO users (name, age) VALUES (?, ?)", "Alice", 30)
if err != nil {
    log.Fatalf("Error executing query 1: %v", err)
}

// クエリ2: ユーザー情報の更新
_, err = db.Exec("UPDATE users SET age = ? WHERE name = ?", 31, "Alice")
if err != nil {
    log.Fatalf("Error executing query 2: %v", err)
}

注意点

  • 各クエリの後に必ずエラーを確認します。
  • クエリ間の関連性がある場合は、トランザクションを利用する方が適切です。

トランザクションを使用した複数クエリの実行

関連する複数のクエリを一括で処理する場合、トランザクションを利用します。これにより、一貫性が確保され、エラー発生時に全体をロールバックできます。

tx, err := db.Begin()
if err != nil {
    log.Fatalf("Error starting transaction: %v", err)
}

// クエリ1: ユーザーの挿入
_, err = tx.Exec("INSERT INTO users (name, age) VALUES (?, ?)", "Bob", 25)
if err != nil {
    tx.Rollback()
    log.Fatalf("Error executing query 1: %v", err)
}

// クエリ2: ユーザーの年齢更新
_, err = tx.Exec("UPDATE users SET age = ? WHERE name = ?", 26, "Bob")
if err != nil {
    tx.Rollback()
    log.Fatalf("Error executing query 2: %v", err)
}

// コミット
if err := tx.Commit(); err != nil {
    log.Fatalf("Error committing transaction: %v", err)
}

メリット

  • 一貫性の確保：全てのクエリが成功した場合にのみデータベースに反映されます。
  • エラー時の安全性：一部のクエリが失敗した場合、変更を取り消してデータの整合性を保ちます。

バッチ処理の応用

複数クエリを動的に生成して一括実行することも可能です。以下は、配列のデータを挿入する例です。

users := []struct {
    Name string
    Age  int
}{
    {"Charlie", 20},
    {"Diana", 22},
    {"Edward", 24},
}

tx, err := db.Begin()
if err != nil {
    log.Fatalf("Error starting transaction: %v", err)
}

for _, user := range users {
    _, err := tx.Exec("INSERT INTO users (name, age) VALUES (?, ?)", user.Name, user.Age)
    if err != nil {
        tx.Rollback()
        log.Fatalf("Error inserting user %s: %v", user.Name, err)
    }
}

if err := tx.Commit(); err != nil {
    log.Fatalf("Error committing batch insert: %v", err)
}

注意点

  • トランザクションの使用が推奨：関連性の高い複数クエリを扱う場合は、必ずトランザクションを利用してください。
  • 適切なエラー処理：逐次実行と同様、各クエリのエラーを必ず確認します。
  • パフォーマンスへの配慮：大量のクエリを処理する場合、接続プールの制約やデータベース負荷を考慮する必要があります。

これらの手法を用いることで、Go言語を使った複数クエリの効率的な処理が可能になります。次は、よくある問題とトラブルシューティングについて解説します。

よくある問題とトラブルシューティング

database/sqlパッケージを使用してデータベース操作を行う際、予期せぬ問題に直面することがあります。このセクションでは、よくある問題を挙げ、それらを解決するための方法を説明します。

よくある問題

1. データベース接続エラー

原因：

  • 接続文字列の形式が誤っている。
  • データベースが起動していない。
  • ファイアウォールやネットワーク設定の問題。

対処法：

  • 接続文字列の形式を確認し、正確なホスト、ポート、認証情報を指定します。
  • データベースが正しく起動しているか確認します。
  • ネットワーク設定を見直し、必要に応じてファイアウォールの設定を変更します。

コード例：

db, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/dbname")
if err != nil {
    log.Fatalf("Failed to connect to database: %v", err)
}
if err := db.Ping(); err != nil {
    log.Fatalf("Unable to reach database: %v", err)
}

2. クエリの構文エラー

原因：

  • SQL文の構文ミスやテーブル・カラム名の間違い。

対処法：

  • SQLクエリをデータベースのクライアントで事前にテストします。
  • プレースホルダーやクエリの書式を確認します。

コード例：

_, err := db.Exec("SELECT * FORM users WHERE id = ?", 1) // 構文ミス
if err != nil {
    log.Printf("Query execution error: %v", err)
}

3. SQLインジェクションのリスク

原因：

  • 外部入力を直接SQLクエリに埋め込む。

対処法：

  • プレースホルダー（?）を使用してクエリパラメータをバインドします。

コード例：

_, err := db.Exec("SELECT * FROM users WHERE name = ?", userInput) // 安全

4. トランザクションの競合やデッドロック

原因：

  • 複数のトランザクションが同じリソースを競合している。

対処法：

  • トランザクションのスコープを短くし、必要最小限のリソースをロックします。
  • 適切なトランザクション分離レベルを設定します。

トラブルシューティングの実践

エラーメッセージの確認

発生するエラーは、必ずerrで確認します。エラー内容をログに記録し、詳細を把握しましょう。

result, err := db.Exec("INSERT INTO users (name, age) VALUES (?, ?)", "Alice", 30)
if err != nil {
    log.Printf("Error executing query: %v", err)
    return
}

データベース接続の確認

ネットワーク接続や認証情報が原因で接続エラーが発生していないか確認します。

if err := db.Ping(); err != nil {
    log.Fatalf("Database connection failed: %v", err)
}

クエリのデバッグ

クエリの実行が期待通りに動作しているか、SQLクライアントを使用してテストします。また、EXPLAINを使用してクエリのパフォーマンスを検証します。

接続プールの調整

接続プールのサイズが適切でない場合、リソース不足や過負荷が発生します。設定を調整して効率を改善します。

db.SetMaxOpenConns(10) // 最大接続数
db.SetMaxIdleConns(5)  // 最大アイドル接続数

一般的なエラー一覧

エラーコード問題対処法
sql.ErrNoRows該当する行が見つからない条件を確認し、適切に処理する
context.DeadlineExceededクエリのタイムアウトクエリの時間を短縮、タイムアウトを延長
driver.ErrBadConn接続が切断された再接続処理を実装する

注意点

  • エラーが発生した際に具体的な情報をログに記録することで、トラブルシューティングが容易になります。
  • リソースの開放を確実に行い、接続のリークを防ぎましょう。
  • テスト環境で問題を再現し、本番環境での影響を最小限に抑えます。

これらの方法を活用すれば、database/sqlでの一般的な問題に効果的に対処できます。次は、演習問題を通じて実践的なスキルを深める方法を紹介します。

演習問題：簡単なデータベース操作の実装

ここでは、これまで学んだdatabase/sqlパッケージの使い方を実践的に理解するための演習問題を提示します。以下の課題を解きながら、Go言語でのデータベース操作を深く学んでみましょう。

課題1：ユーザー情報の登録

新しいユーザーをデータベースに登録するプログラムを作成してください。

  • テーブル名：users
  • カラム：id (int, PRIMARY KEY), name (VARCHAR), age (INT)

要件

  1. ユーザー名と年齢を受け取り、データベースに保存する。
  2. INSERT文を使用してデータを挿入する。

ヒント

  • Execを使い、動的なプレースホルダーを使用する。
  • ユーザーIDは自動生成。
func insertUser(db *sql.DB, name string, age int) error {
    _, err := db.Exec("INSERT INTO users (name, age) VALUES (?, ?)", name, age)
    return err
}

課題2：ユーザー情報の検索

特定のユーザーIDに基づいて、名前と年齢を取得するプログラムを作成してください。

要件

  1. IDを指定してSELECT文を実行する。
  2. 結果がない場合は適切なメッセージを表示する。

ヒント

  • QueryRowとScanを使用。
func getUser(db *sql.DB, id int) (string, int, error) {
    var name string
    var age int
    err := db.QueryRow("SELECT name, age FROM users WHERE id = ?", id).Scan(&name, &age)
    if err == sql.ErrNoRows {
        fmt.Println("No user found with the given ID")
        return "", 0, nil
    }
    return name, age, err
}

課題3：ユーザー情報の更新

特定のユーザーの年齢を更新するプログラムを作成してください。

要件

  1. IDを指定して年齢を更新する。
  2. 更新後の影響行数を表示する。

ヒント

  • Execを使用してUPDATE文を実行。
func updateUserAge(db *sql.DB, id int, newAge int) error {
    result, err := db.Exec("UPDATE users SET age = ? WHERE id = ?", newAge, id)
    if err != nil {
        return err
    }
    rowsAffected, _ := result.RowsAffected()
    fmt.Printf("Rows updated: %d\n", rowsAffected)
    return nil
}

課題4：トランザクションでの一括操作

複数のユーザーを一度に追加する処理をトランザクションで実行してください。

要件

  1. 配列データを受け取り、すべてのユーザーをデータベースに挿入。
  2. 挿入中にエラーが発生した場合、トランザクションをロールバックする。

ヒント

  • Begin, Exec, Rollback, Commitを使用。
func addUsersInTransaction(db *sql.DB, users []struct{Name string; Age int}) error {
    tx, err := db.Begin()
    if err != nil {
        return err
    }

    for _, user := range users {
        _, err := tx.Exec("INSERT INTO users (name, age) VALUES (?, ?)", user.Name, user.Age)
        if err != nil {
            tx.Rollback()
            return err
        }
    }

    return tx.Commit()
}

課題5：エラー処理の追加

上記の課題に適切なエラー処理を追加してください。たとえば、接続エラーやデータベースクエリのエラーが発生した場合にログを出力する仕組みを実装します。

これらの演習問題を解くことで、database/sqlを使用したデータベース操作の基礎から応用までを実践的に学べます。ぜひ取り組んでみてください！次は記事全体のまとめです。

まとめ

本記事では、Go言語のdatabase/sqlパッケージを用いたデータベース接続の基本的な使い方を解説しました。database/sqlパッケージの役割から始まり、データベースへの接続、クエリの実行、結果の取得、トランザクションの利用、そしてエラー処理まで、実践的な知識を段階的に説明しました。

特に以下のポイントを押さえておくと、効率的で安全なデータベース操作が可能になります：

  • プレースホルダーを使用した安全なクエリの実行。
  • エラー処理の徹底とリソースの適切な管理。
  • トランザクションの活用によるデータの一貫性の確保。

また、演習問題を通じて、これらの知識を実際にコードに落とし込む力を養うことも重要です。これを機に、さらに高度なデータベース操作や複雑なクエリ処理に挑戦してみてください。Go言語とdatabase/sqlを使ったデータベース開発の基礎がしっかり身につくはずです。

Go
データベース接続 Go言語 database/sql

コメント

コメントする

目次