【第13回】GoとMySQLをDockerで繋いでみよう

wget https://go.dev/dl/go1.23.4.linux-amd64.tar.gz

tar -C /usr/local -xzf go1.23.4.linux-amd64.tar.gz

code $HOME/.profile

export PATH=$PATH:/usr/local/go/bin

go version

package main

import "fmt"

func main() {
    fmt.Println("Hello, World!")
}

go run main.go

package main

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

var message string = "Hello, World!"
var number int = 100
var isTrue bool = true

var message = "Hello, World!"
var number = 100
var isTrue = true

message := "Hello, World!"
number := 100
isTrue := true

// 配列
numbers := [3]int{1, 2, 3}
fmt.Println(numbers) // [1 2 3]
fmt.Println(numbers[0]) // 1

// スライス
foods := []string{"apple", "banana", "orange"}

// 要素の追加
foods = append(foods, "grape")

fmt.Println(foods) // [apple banana orange grape]

prices := map[string]int{
    "apple":  100,
    "banana": 200,
    "orange": 150,
}

// bananaの値を取得
fmt.Println(prices["banana"]) // 200

func getValues() (int, int) {
 return 1, 2
}

a, b := getValues()
fmt.Println(a, b) // 1 2

// text.txtファイルを開く
file, err := os.Open("./text.txt")
if err != nil {
    fmt.Println("ファイルを開くことができませんでした") // エラーが発生した場合はerrはnilではない
    return
} else {
    fmt.Println("ファイルを開くことができました")
}

sample-go-mysql-connect-app
├── Dockerfile
├── docker-compose.yml
├── main.go
└── init.sql

# ベースイメージ
FROM golang:1.23

# ワーキングディレクトリの設定
WORKDIR /app

# モジュールファイルをコピーして依存関係をインストール
COPY go.mod go.sum ./
RUN go mod download

# ソースコードをコピーしてビルド
COPY . .
RUN go build -o main .

# アプリケーションを起動
CMD ["./main"]

version: '3.8'

services:
  mysql:
    image: mysql:8.4
    container_name: sample-go-mysql-connect-app-mysql
    restart: always
    environment:
      MYSQL_ROOT_PASSWORD: root
      MYSQL_DATABASE: testdb
      MYSQL_USER: testuser
      MYSQL_PASSWORD: testpassword
    ports:
      - "3306:3306"
    volumes:
      - mysql_data:/var/lib/mysql
      - ./init.sql:/docker-entrypoint-initdb.d/init.sql:ro

  app:
    build: .
    container_name: sample-go-mysql-connect-app
    ports:
      - "8080:8080"
    depends_on:
      - mysql
    environment:
      DB_HOST: mysql
      DB_USER: testuser
      DB_PASSWORD: testpassword
      DB_NAME: testdb

volumes:
  mysql_data:

package main

import (
 "database/sql" // データベースの操作
 "encoding/json" // JSONのエンコードとデコード
 "fmt"
 "log"
 "net/http" // HTTPでWebサーバーを立てる
 "os"

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

// 構造体を定義
type Item struct {
 ID   int    `json:"id"`
 Name string `json:"name"`
}

func main() {
 // 環境変数からDB接続情報を取得
 dbHost := os.Getenv("DB_HOST")
 dbUser := os.Getenv("DB_USER")
 dbPassword := os.Getenv("DB_PASSWORD")
 dbName := os.Getenv("DB_NAME")

 dsn := fmt.Sprintf("%s:%s@tcp(%s:3306)/%s", dbUser, dbPassword, dbHost, dbName)
 db, err := sql.Open("mysql", dsn)
 if err != nil {
  log.Fatalf("Failed to connect to database: %v", err)
 }
 defer db.Close()

 // itemsにGETリクエストがあった場合の処理
 http.HandleFunc("/items", func(w http.ResponseWriter, r *http.Request) {
  if r.Method != http.MethodGet {
   http.Error(w, "Method not allowed", http.StatusMethodNotAllowed)
   return
  }

  // データベースからデータを取得
  rows, err := db.Query("SELECT id, name FROM items")
  // エラーハンドリング
  if err != nil {
   http.Error(w, fmt.Sprintf("Database query failed: %v", err), http.StatusInternalServerError)
   return
  }
  defer rows.Close()

  // 取得したデータを格納するスライスを定義
  var items []Item
  for rows.Next() {
   var item Item
   if err := rows.Scan(&item.ID, &item.Name); err != nil {
    http.Error(w, fmt.Sprintf("Row scan failed: %v", err), http.StatusInternalServerError)
    return
   }
   // 取得したレコードをitemsに追加
   items = append(items, item)
  }

  // JSON形式でレスポンスを返す
  w.Header().Set("Content-Type", "application/json")
  if err := json.NewEncoder(w).Encode(items); err != nil {
   http.Error(w, fmt.Sprintf("JSON encoding failed: %v", err), http.StatusInternalServerError)
  }
 })

 // サーバーを起動
 log.Println("Server started on :8080")
 log.Fatal(http.ListenAndServe(":8080", nil))
}

go mod init sample-go-mysql-connect-app

go mod tidy

CREATE TABLE items (
    id INT AUTO_INCREMENT PRIMARY KEY,
    name VARCHAR(255) NOT NULL
);

INSERT INTO items (name) VALUES ('Item 1'), ('Item 2'), ('Item 3');

docker-compose up --build

[
    {
        "id": 1,
        "name": "Item 1"
    },
    {
        "id": 2,
        "name": "Item 2"
    },
    {
        "id": 3,
        "name": "Item 3"
    }
]

docker-compose down