[Go] echo, GORMを使ったREST API実装についての質問

Question

Go初心者です。
勉強のために Echo GORMを使ったAPIを作っています。

ただいま usersテーブル に入っているレコードをパラメータで送られたきた id から一つ特定して取得する処理を書いています。 Railsでいう users_contoroller の showアクションのような処理を作りたいです。
しかし、１回目のGETでは成功するクエリが2回目以降失敗してしまい困っています。(下記で説明)
どなたか解決策をご教授頂けますと幸いですm(_ _)m

ディレクトリ構造は以下のようになります

.
|-- controllers
|   `-- users.go
|-- db
|   `-- connect.go
|-- main.go
`-- models
    `-- user.go

各ファイルのは以下のようになっています。

↓ main.go

package main

import (
	"github.com/labstack/echo"
	"github.com/labstack/echo/middleware"
	"echo_first/controllers"
)

func main() {
	e := echo.New()
	e.Use(middleware.Logger())
	e.Use(middleware.Recover())

	// ルーティング
	e.GET("user/:id", users_controller.Show())

	// サーバー起動
	e.Logger.Fatal(e.Start(":3000"))
}

↓ models/user.go

package model

type User struct {
	Id int
	Name string
	Birth_day int
}

↓ db/connect.go

package dbconnect

import (
  "github.com/jinzhu/gorm"
	_ "github.com/jinzhu/gorm/dialects/mysql"
	"fmt"
)

func Connect() *gorm.DB{
	db, err := gorm.Open("mysql", "hogeuser:@/hogehoge?charset=utf8&parseTime=True&loc=Local")

	if err != nil {
		fmt.Print("データベース接続に失敗しました。")
	}
	db.LogMode(true)
	return db
}

↓ conrollers/user.go

package users_controller

import (
	"github.com/labstack/echo"
	"net/http"
	"fmt"
	"echo_first/models"
	"echo_first/db"
)


func Show() echo.HandlerFunc{
	db := dbconnect.Connect()
	user := new(model.User)
	return func(c echo.Context) error{
		user_id := c.Param("id")
		result := db.First(&user, "id = ?", user_id)
		if result.RecordNotFound() {
			fmt.Println("レコードが見つかりません")
		}
		return c.JSON(http.StatusOK, result)
	}
}

サーバーを起動立ち上げ１回目のGETリクエスト user/1では以下のようにデータを取得できます。

[25.45ms]  SELECT * FROM `users`  WHERE (id = '1') ORDER BY `users`.`id` ASC LIMIT 1  
[1 rows affected or returned ]

しかし２回目のGETリクエスト user/2ではSQLがおかしく、データを取得できません。

[29.71ms]  SELECT * FROM `users`  WHERE `users`.`id` = 1 AND ((id = '2')) ORDER BY `users`.`id` ASC LIMIT 1  
[0 rows affected or returned ] 
レコードが見つかりません

データベースのコネクションの問題なのか、GORMのクエリの問題なのか分からず躓いてしまいました。
データベースのコネクションの問題の場合はどこで db.Closeするのか分かりません...。リクエストの度にデータベースに接続して Closeする？？のでしょうか。。
どなたかご教授お願い致します（ ; ; ）

Comments

[退会済みユーザー]

gormだったらgorm.Open()とすると思うんですがdbconnectとは何ですか？
echo特有のwrapperか何かでしょうか。

[退会済みユーザー]

> REAR API
とは何ですか？

[退会済みユーザー]

> gormだったらgorm.Open()とすると思うんですがdbconnectとは何ですか？
db/connect.goを見て理解しました。
失礼しました。

[tailer]

dbへの接続をファイル分割したかったので dbconnectパッケージを作って, その中の Connect関数でgorm.Open()を使っています。

> REAR API
とは何ですか？
こちらはtypoでした。ご指摘ありがとうございます

Answer 1

とりあえずCloseは必要だと思います。

func Show() echo.HandlerFunc{
    db := dbconnect.Connect()
+   defer db.Close()
    user := new(model.User)
    return func(c echo.Context) error{
        user_id := c.Param("id")
        result := db.First(&user, "id = ?", user_id)
        if result.RecordNotFound() {
            fmt.Println("レコードが見つかりません")
        }
        return c.JSON(http.StatusOK, result)
    }
}

---

func Show() echo.HandlerFunc{
    return func(c echo.Context) error {
        db := dbconnect.Connect()
        defer db.Close()
        user := new(model.User)
        user_id := c.Param("id")
        result := db.First(&user, "id = ?", user_id)
        if result.RecordNotFound() {
            fmt.Println("レコードが見つかりません")
        }
        return c.JSON(http.StatusOK, result)
    }
}

ではこうしてはどうでしょう。

Comments

[tailer]

ご回答ありがとうございます。
`defer db.Close()`をご指摘の場所に入れた場合はデータが取得できず想定通りの動作はしません...

以下がログになります。
```
____ __
/ __/___/ / ___
/ _// __/ _ / _ \
/___/\__/_//_/\___/ v4.1.10
High performance, minimalist Go web framework
https://echo.labstack.com
____________________________________O/_______
O\
⇨ http server started on [::]:3000

[2019-09-16 15:16:41] sql: database is closed
[2019-09-16 15:16:41] [0.13ms] SELECT * FROM `users` WHERE (id = '2') ORDER BY `users`.`id` ASC LIMIT 1
[0 rows affected or returned ]
```

deferが設定された関数の実行タイミングは returnの直前となっているため、`db.First(&user, "id = ?", user_id)`が実行される前にdb.Closeされているのが原因かと思います。
どこかでdb.Closeするのかが難しいですね...（ ; ; ）

[tailer]

回答ありがとうございます。
こちらで期待通りのSQLが発行され、上手く動作できました！本当に助かりましたm(_ _)m

厚かましいですが最後に一つ質問させてください。
db.Openとdb.Closeはhttpリクエストの度に行うという認識で良いのでしょうか？

[退会済みユーザー]

場合によります。
リクエスト毎にコネクションを張って切るのが最もシンプルな形であるとはいえると思います。
よりパフォーマンスを気にするということであればコネクションプールについて調べれば良いと思います。

[退会済みユーザー]

後者の場合でもdb.Close()は必ず必要なのでそこは間違えないようにしてください。

[tailer]

勉強になりました。ありがとうございました！