GoでのObjectの操作について

Question

以下のようなデータ操作について

package model

import "time"

type Task struct {
	ID        int64     `json:"id"`
	Task      string    `json:"task"`
	CreatedAt time.Time `json:"createdAt"`
	UpdatedAt time.Time `json:"updatedAt"`
}

type TaskRepository struct {
	DB *sql.DB
}

func (tr *TaskRepository) All() (tasks []*model.Task, err error) {
	taskList := []*model.Task
	taskList, err = tr.DB.Query("SELECT * FROM t_task")

	if err != nil {
		log.Fatal(err)
	}
	defer taskList.Close()

	for taskList.Next() {
		var task model.Task

		err := taskList.Scan(&task)

		if err != nil {
			log.Fatal(err)
		}

		taskList = append(taskList, &task)
	}
	return taskList, nil
}

type []*model.Task is not an expression

taskList := []*model.Task
の部分の記述っぽいですが、lintは出ないものでよくわかりません。

代入や宣言の方法はあっていると思うのですが、、、
分かる方いましたら教えてください。

Answer 1

まず変数の宣言方法が間違っています。

taskList := []*model.Task

のエラーに関してはシンタックスが間違っています。上記の方法にならうならば

taskList := []*model.Task{}

いうように宣言する必要があります。ちなみにスライスの宣言は以下のようにするのがおすすめです。

var taskList []*model.Task

次に Query の戻り値は *sql.Rows 型です。これは []*model.Task 型ではないので以下の実装はコンパイルエラーになります。

taskList, err = tr.DB.Query("SELECT * FROM t_task")

おそらくやりたいこと(SQL の結果を []*model.Task 型のスライスに格納して return する)は以下のようになるのではないでしょうか？

func (tr *TaskRepository) All() (tasks []*model.Task, err error) {
	var taskList []*model.Task
	rows, err := tr.DB.Query("SELECT * FROM t_task")

	if err != nil {
		log.Fatal(err)
	}
	defer rows.Close()

	for rows.Next() {
		var task model.Task

		err := rows.Scan(&task)

		if err != nil {
			log.Fatal(err)
		}

		taskList = append(taskList, &task)
	}
	return taskList, nil
}

---

余談ですが、rows.Next() での呼び出し時にエラーが発生する場合があるので、以下の追加した部分のようにエラーをチェックするのを推奨します。

func (tr *TaskRepository) All() (tasks []*model.Task, err error) {
    var taskList []*model.Task
    rows, err := tr.DB.Query("SELECT * FROM t_task")

    if err != nil {
        log.Fatal(err)
    }
    defer rows.Close()

    for rows.Next() {
        var task model.Task

        err := rows.Scan(&task)

        if err != nil {
            log.Fatal(err)
        }

        taskList = append(taskList, &task)
    }
+   if err := rows.Err(); err != nil {
+       return nil, err
+   }
    return taskList, nil
}

少し古い資料にはなりますが Go database/sql tutorial Handling Errors の Errors From Iterating Resultsets にも同様の内容が記載されています。こちらは公式の Wiki のリンクに記載されている資料になります。

Comments

[kagepedia]

ありがとうございます。
エラーはなく動作することができました。

戻り値を処理すると、
&{0 0xc000010030 0 {0 0} [] map[] 0 0 0xc0000840c0 0xc00006c2a0 false map[] map[] 0 0 0 <nil> 0 0 0 0x1131ab0}
このような表示が出てきます。
アドレスが表示されているのでしょうか?

別ファイルでAll()関数を呼んでいますでいます。

[d_tutuz]

All() で tasks []*model.Task のスライスが帰ってくると思いますが、それを fmt.Println(tasks) などとしているのでしょうか？？

[kagepedia]

インターフェースを作成し
type TaskRepository interface {
All() ([]*model.Task, error)
}

アプリケーション層
type TaskApplication struct {
Repo repository.TaskRepository
}
func (ta *TaskApplication) All() (tasks []*model.Task, err error) {
tasks, err = ta.Repo.All()
return
}

コントローラー
type TaskController struct {
Ta application.TaskApplication
// Logger application.Logger
}
func (tc *TaskController) ServeHTTP(w http.ResponseWriter, r *http.Request) {
fmt.Fprint(w, "Hello World from TaskGo.\n")
// tc.Logger.LogAccess("%s %s %s\n", r.RemoteAddr, r.Method, r.URL)

taskList, _ := tc.Ta.All()
res, err := json.Marshal(&taskList)
fmt.Printf("%T", res)

if err != nil {
fmt.Println("n = nil, Invalid Error")
// log.Fatal("Error: %s", err)
// tc.Logger.LogError("%s", err)
}
w.Header().Set("Content-Type", "application/json")
w.WriteHeader(500)
fmt.Fprint(w, string(res))
}

ルーティング処理
var (
Tc = &controller.TaskController{}
)
func InitRouting() {
http.Handle("/task", Tc)
}

こんな感じの作りにしています。

[d_tutuz]

fmt.Printf("%T", res) の内容であれば、res の型([]byte)が表示されると思いますよ。
ちなみに上記の変数 res はバイトのスライスです。

[kagepedia]

ここでstring型にキャストしてるんですがダメなんですかね？
fmt.Fprint(w, string(res))

[d_tutuz]

特に問題ないかと思います。
ひとつひとつの挙動をデバッグ(printデバッグなど)で確認するのが早いと思いますよ

[kagepedia]

ありがとうございます！