「Go言語」 PostgreSQLにデータを保存できません。

Question

はじめに

質問を見てくださりありがとう御座います。
現在、Go言語の練習として、クライアント側のフォームからJSONを送信、サーバー側（Go）で受け取って、データベース（PostgreSQL）で保存させようとしています。
JSONを受け取ってPostgreSQLに接続までは成功しているのですが、保存が出来ません。

下記のパニックが出てました。

http: panic serving 127.0.0.1:50371: runtime error: invalid memory address or nil pointer dereference

構造体

２つあります。Room と Post です。
Room has_many Post という関係性です。

ここでは、まずRoomだけを作成してみようということで実践していましたが、DBへの保存のところでエラーが出ています。

コード(質問用に整形しています)

// package, import 部分は省略しています。


// Room ・誰でも投稿できる ・has_many Post
type Room struct {
	ID        int       `json:"id"`
	Title     string    `json:"title"`
	Content   string    `json:"content"`
	CreatedAt time.Time `json:"created_at"`
	Posts     []Post    `json:"posts"`
}

var postgreSQL *sql.DB

func init() {
	postgreSQL, err := sql.Open("postgres", "user=user dbname=db password=pw sslmode=disable")
	if err != nil {
		panic(err)
	}
	defer postgreSQL.Close()

	err = postgreSQL.Ping()
	if err != nil {
		panic(err)
	}

// 接続成功する。
	fmt.Print("Successfully connected!\n")
}

// SQLRoomCreate [ Create a new room ]
func (room *Room) SQLRoomCreate() (err error) {
	fmt.Print("\nRoomCreate is Starting!!\n\n")
	statement := "insert into rooms (title, content) values ($1, $2) returning id, created_at"

// ここでエラーが発生している！！
	stmt, err := postgreSQL.Prepare(statement)
	if err != nil {
		return
	}
	defer stmt.Close()
	err = stmt.QueryRow(room.Title, room.Content).Scan(&room.ID, &room.CreatedAt)
	fmt.Print("RoomCreate is DONE")
	return
}

func roomCreate(w http.ResponseWriter, r *http.Request) {
	if r.Method != "POST" {
		fmt.Print("不正なメソッドです。\n")
		fmt.Printf("Method : \n%v\n", r.Method)
		w.WriteHeader(http.StatusBadRequest)
		return
	}

	if r.Header.Get("Content-Type") != "application/json" {
		fmt.Print("JSONではありません。\n")
		fmt.Printf("Response Header : \n%v\n", r.Header.Get("Content-Type"))
		w.WriteHeader(http.StatusBadRequest)
		return
	}

	//To allocate slice for request body
	length, err := strconv.Atoi(r.Header.Get("Content-Length"))
	if err != nil {
		fmt.Printf("Content-Length : \n%v\n", r.Header.Get("Content-Length"))
		fmt.Print("エラーが発生しました。\n")
		log.Fatal(err)
		w.WriteHeader(http.StatusInternalServerError)
		return
	}

	// Read メソッドが []byte を読み込むことになっている
	body := make([]byte, length)
	_, err = r.Body.Read(body)
	if err != nil && err != io.EOF {
		fmt.Print("エラーが発生しました。\n")
		log.Fatal(err)
		w.WriteHeader(http.StatusInternalServerError)
		return
	}

	// 受け取ったJSONを解析して構造体 Room にマッピング
	// []byteをlength 分だけパースする
	var room model.Room
	err = json.Unmarshal(body[:length], &room)
	if err != nil {
		fmt.Print("エラーが発生しました。\n")
		log.Fatal(err)
		w.WriteHeader(http.StatusInternalServerError)
		return
	}

	err = room.SQLRoomCreate()
	if err != nil {
		fmt.Printf("*\nERROR in room.go\n*\n")
		log.Fatal(err)
		w.WriteHeader(http.StatusInternalServerError)
		return
	}
	w.WriteHeader(http.StatusOK)
	http.Redirect(w, r, "/room", 302)
}

func main() {
	mux := http.NewServeMux()

	files := http.FileServer(http.Dir("assets"))
	mux.Handle("/static/", http.StripPrefix("/static/", files))

	mux.HandleFunc("/", homeIndex)
	mux.HandleFunc("/room/new", roomCreate)

	server := http.Server{
		Addr:    "127.0.0.1:8080",
		Handler: mux,
	}
	log.Fatal(server.ListenAndServe())
}

コード(回答を受けて編集ました)

指摘を受けた部分を試してみましたが、同じくエラーが出ています。

http: panic serving 127.0.0.1:59381: runtime error: invalid memory address or nil pointer dereference

ログを見たところ、SQLRoomCreateという関数のところでエラーがでていると思われます。誤っている箇所がないか確認していただきたいです。よろしくおねがいします！

// package, import 部分は省略しています。


// Room ・誰でも投稿できる ・has_many Post
type Room struct {
	ID        int       `json:"id"`
	Title     string    `json:"title"`
	Content   string    `json:"content"`
	CreatedAt time.Time `json:"created_at"`
	Posts     []Post    `json:"posts"`
}

var postgreSQL *sql.DB
// ここでDBへの接続情報入力
const (
	host     = "localhost"
	port     = 8080
	user     = "user"
	password = "pw"
	dbname   = "database"
)

func init() {
	// 変数に入れました。
	psqlInfo := fmt.Sprintf("host=%s port=%d user=%s password=%s dbname=%s sslmode=disable",
		host, port, user, password, dbname)
	// それを代入しました。
	postgreSQL, err := sql.Open("postgres", psqlInfo)
	// init 内では使っていなためにエラーが出る。それの回避でアンダースコア。
	var _ = postgreSQL
	if err != nil {
		panic(err)
	}

	// ColseしているためにDBに接続していないと予想。

	// defer postgreSQL.Close()

	// err = postgreSQL.Ping()
	// if err != nil {
	// 	panic(err)
	// }

	fmt.Print("Successfully connected!\n")
}


// SQLRoomCreate [ Create a new room ]
func (room *Room) SQLRoomCreate() (err error) {
	fmt.Print("\nRoomCreate is Starting!!\n\n")
	statement := "insert into rooms (title, content) values ($1, $2) returning id, created_at"

///////////////////////////
// ここでエラーが発生している！！??
//////////////////////////

	stmt, err := postgreSQL.Prepare(statement)
	if err != nil {
		return
	}
	defer stmt.Close()
	err = stmt.QueryRow(room.Title, room.Content).Scan(&room.ID, &room.CreatedAt)
	fmt.Print("RoomCreate is DONE")
	return
}

func roomCreate(w http.ResponseWriter, r *http.Request) {
	if r.Method != "POST" {
		fmt.Print("不正なメソッドです。\n")
		fmt.Printf("Method : \n%v\n", r.Method)
		w.WriteHeader(http.StatusBadRequest)
		return
	}

	if r.Header.Get("Content-Type") != "application/json" {
		fmt.Print("JSONではありません。\n")
		fmt.Printf("Response Header : \n%v\n", r.Header.Get("Content-Type"))
		w.WriteHeader(http.StatusBadRequest)
		return
	}

	//To allocate slice for request body
	length, err := strconv.Atoi(r.Header.Get("Content-Length"))
	if err != nil {
		fmt.Printf("Content-Length : \n%v\n", r.Header.Get("Content-Length"))
		fmt.Print("エラーが発生しました。\n")
		log.Fatal(err)
		w.WriteHeader(http.StatusInternalServerError)
		return
	}

	// Read メソッドが []byte を読み込むことになっている
	body := make([]byte, length)
	_, err = r.Body.Read(body)
	if err != nil && err != io.EOF {
		fmt.Print("エラーが発生しました。\n")
		log.Fatal(err)
		w.WriteHeader(http.StatusInternalServerError)
		return
	}

	// 受け取ったJSONを解析して構造体 Room にマッピング
	// []byteをlength 分だけパースする
	var room model.Room
	err = json.Unmarshal(body[:length], &room)
	if err != nil {
		fmt.Print("エラーが発生しました。\n")
		log.Fatal(err)
		w.WriteHeader(http.StatusInternalServerError)
		return
	}

	err = room.SQLRoomCreate()
	if err != nil {
		fmt.Printf("*\nERROR in room.go\n*\n")
		log.Fatal(err)
		w.WriteHeader(http.StatusInternalServerError)
		return
	}
	w.WriteHeader(http.StatusOK)
	http.Redirect(w, r, "/room", 302)
}

func main() {
	mux := http.NewServeMux()

	files := http.FileServer(http.Dir("assets"))
	mux.Handle("/static/", http.StripPrefix("/static/", files))

	mux.HandleFunc("/", homeIndex)
	mux.HandleFunc("/room/new", roomCreate)

	server := http.Server{
		Addr:    "127.0.0.1:8080",
		Handler: mux,
	}
	log.Fatal(server.ListenAndServe())
}

質問

①タイムスタンプはいつ押すべきなのかわからないため、created_atにデータを入れる処理を書いていません。いつその処理を書くべきですか？ もしくはDB保存時に打刻されますか？

②プリペアドステートメントは間違っていないかチェックしていただきたいです。書籍を参考にしながらかいたので間違っているかもしれません。

どうかこのエラー解決に協力してください。お願いします！

Answer 1

ぱっと見た感じですが提示しているコードだけ見ると func initに問題があるのではないでしょうか？

とりあえずコードにコメントしておきます(間違ってたらすみません)

var postgreSQL *sql.DB

func init() {
    // := は宣言と代入をいっぺんに行うので上で宣言している以上ここで使うのは違う気がする
    postgreSQL, err := sql.Open("postgres", "user=user dbname=db password=pw sslmode=disable")
    if err != nil {
        panic(err)
    }
    // ここが問題
    // deferは全ての実行が終わると最後に呼び出されるのでinit関数の実行が終了した時点で
    // DBとの接続をクローズしてしまっている可能性大
    defer postgreSQL.Close()

    err = postgreSQL.Ping()
    if err != nil {
        panic(err)
    }

// 接続成功する。
    fmt.Print("Successfully connected!\n")
}

2/17 追記

必要な時にinit関数呼んであげてdaoをポインタで返せばいいかと思います
なるべく元の物に変更を加えないようにしたので正直イケてないですが恐らく動くかと

type Room struct {
	ID        int       `json:"id"`
	Title     string    `json:"title"`
	Content   string    `json:"content"`
	CreatedAt time.Time `json:"created_at"`
	Posts     []Post    `json:"posts"`
}

const (
	host     = "localhost"
	port     = 8080
	user     = "user"
	password = "pw"
	dbname   = "database"
)

func init() (*sql.DB, error) {
	psqlInfo := fmt.Sprintf("host=%s port=%d user=%s password=%s dbname=%s sslmode=disable",
		host, port, user, password, dbname)

	postgreSQL, err := sql.Open("postgres", psqlInfo)

	if err != nil {
		return nil, err
	}

	fmt.Print("Successfully connected!\n")
	
	return &postgreSQL, nil
}

func (room *Room) SQLRoomCreate() (err error) {
	postgreSQL, err := init()
	
	if err != nil {
		panic(err)
	}
	
	defer postgreSQL.Close()

	err = postgreSQL.Ping()

	if err != nil {
		panic(err)
	}
	
	fmt.Print("\nRoomCreate is Starting!!\n\n")
	statement := "insert into rooms (title, content) values ($1, $2) returning id, created_at"

	stmt, err := postgreSQL.Prepare(statement)
	
	if err != nil {
		return
	}
	
	defer stmt.Close()
	err = stmt.QueryRow(room.Title, room.Content).Scan(&room.ID, &room.CreatedAt)
	fmt.Print("RoomCreate is DONE")
	
	return nil
}

func roomCreate(w http.ResponseWriter, r *http.Request) {
	if r.Method != "POST" {
        	fmt.Print("不正なメソッドです。\n")
        	fmt.Printf("Method : \n%v\n", r.Method)
        	w.WriteHeader(http.StatusBadRequest)
	
        	return
    	}

	if r.Header.Get("Content-Type") != "application/json" {
        	fmt.Print("JSONではありません。\n")
        	fmt.Printf("Response Header : \n%v\n", r.Header.Get("Content-Type"))
        	w.WriteHeader(http.StatusBadRequest)
	
        	return
	}

	length, err := strconv.Atoi(r.Header.Get("Content-Length"))

	if err != nil {
		fmt.Printf("Content-Length : \n%v\n", r.Header.Get("Content-Length"))
		fmt.Print("エラーが発生しました。\n")
		log.Fatal(err)
		w.WriteHeader(http.StatusInternalServerError)
		
		return
	}

	body := make([]byte, length)
    	_, err = r.Body.Read(body)
	
	if err != nil && err != io.EOF {
		fmt.Print("エラーが発生しました。\n")
		log.Fatal(err)
		w.WriteHeader(http.StatusInternalServerError)
		
		return
	}

	var room model.Room

	err = json.Unmarshal(body[:length], &room)

	if err != nil {
		fmt.Print("エラーが発生しました。\n")
		log.Fatal(err)
		w.WriteHeader(http.StatusInternalServerError)
		
		return
	}

	err = room.SQLRoomCreate()

	if err != nil {
		fmt.Printf("*\nERROR in room.go\n*\n")
		log.Fatal(err)
		w.WriteHeader(http.StatusInternalServerError)
		
		return
	}

	w.WriteHeader(http.StatusOK)
	http.Redirect(w, r, "/room", 302)
}

func main() {
	mux := http.NewServeMux()

	files := http.FileServer(http.Dir("assets"))
	mux.Handle("/static/", http.StripPrefix("/static/", files))

	mux.HandleFunc("/", homeIndex)
	mux.HandleFunc("/room/new", roomCreate)

	server := http.Server{
		Addr:    "127.0.0.1:8080",
		Handler: mux,
	}

	log.Fatal(server.ListenAndServe())
}

2/17追記 2

postgresの環境を作るのが面倒なので検証していませんがDBアクセスに必要な前準備の部分だけ作ってみました
これを元に必要な処理の追加などやってみてはいかがでしょうか？
ちなみにdbのポートはサーバーポートと同じではダメです。

// main.go

package main

import (
	"github.com/yourname/projectname/controller"
	"log"
	"net/http"
)

func main() {
	mux := http.NewServeMux()

	controller.NewRouter(mux)
	log.Fatal(http.ListenAndServe(":8080", mux))
}

// router.go

package controller

import (
	"net/http"
)

func NewRouter(mux *http.ServeMux) {
	mux.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
		w.WriteHeader(200)
		w.Write([]byte("Index"))
	})

	mux.HandleFunc("/room/new", NewRoom)
}

// room.go

package controller

import (
	_ "github.com/lib/pq"
	
	"database/sql"
	"net/http"
)

func NewRoom(w http.ResponseWriter, r *http.Request) {
	db, err := sql.Open("postgres", "host=127.0.0.1 port=5555 user=user password=pw dbname=database")

	defer db.Close()

	if err != nil {
		http.Error(w, err.Error(), 500)
	}

	// リクエストのパース(JSONから値を抜き出す)

	// データベースの操作(書き込みとか)
}

Comments

[uk_63]

回答ありがとうございました。
コード（回答を受けて編集しました）を追記しましたので、見ていただけないでしょうか？
よろしくおねがいします！

[teikoku-penguin]

回答を編集して追記しました

[uk_63]

回答ありがとうございます。
いただいた回答を早速ためそうとしましたが、init 関数の引数と戻り値がないとエラーがでてしまいました。どのように引数と戻り値をせっていするのが正しいですか？
また必要なときにinit 関数を呼ぶというのは、必要なときにDBへ接続するということですか？

お忙しい中、私の質問にお付き合いくださりありがとうございます。引き続きよろしくおねがいします。

[teikoku-penguin]

> 必要なときにinit 関数を呼ぶというのは、必要なときにDBへ接続するということですか？

リクエストがDBアクセスを行う処理に対する物であればアクセスされたタイミングで接続して処理が終わったら切断する といった感じです

とりあえずコードサンプル追加しました
雛形的なものを作ったので必要な処理をコメントの部分に入れたりして試してみて下さい。

[uk_63]

回答ありがとうございます。
> リクエストがDBアクセスを行う処理に対する物であればアクセスされたタイミングで接続して処理が終わったら切断する
この処理の実装に取り組んでみます。
返事遅れますが、都合が許す限りお付き合いください。
よろしくおねがいします！

[uk_63]

ベストアンサー遅れてすみません。
質問にお付き合いしてくださり、また丁寧な回答をありがとうございました。

[teikoku-penguin]

解決できたようでよかったです