回答編集履歴

コード修正

2019/02/17 00:18

投稿

teikoku-penguin

スコア314

test CHANGED Viewed

@@ -484,11 +484,11 @@
-	// JSONのパース
+	// リクエストのパース(JSONから値を抜き出す)
-	// データベースへの操作
+	// データベースの操作(書き込みとか)
 }

追記

2019/02/17 00:18

投稿

teikoku-penguin

スコア314

test CHANGED Viewed

@@ -353,3 +353,143 @@
 }
 ```
+# 2/17追記 2
+postgresの環境を作るのが面倒なので検証していませんがDBアクセスに必要な前準備の部分だけ作ってみました
+これを元に必要な処理の追加などやってみてはいかがでしょうか？
+ちなみにdbのポートはサーバーポートと同じではダメです。
+```Go
+// 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))
+}
+```
+```Go
+// 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)
+}
+```
+```Go
+// 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のパース
+	// データベースへの操作
+}
+```

コード修正

2019/02/17 00:08

投稿

teikoku-penguin

スコア314

test CHANGED Viewed

@@ -58,18 +58,14 @@
-init関数をmainで呼んであげてdaoをポインタで返せばいいかと思います
+必要な時にinit関数呼んであげてdaoをポインタで返せばいいかと思います
-なるべく元の物に変更を加えないようにしました
+なるべく元の物に変更を加えないようにしたので正直イケてないですが恐らく動くかと
 ```Go
-package main
 type Room struct {
 	ID        int       `json:"id"`
@@ -134,6 +130,34 @@
 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"
@@ -298,34 +322,6 @@
 func main() {
-	postgreSQL, err := init()
-	if err != nil {
-		panic(err)
-	}
-	defer postgreSQL.Close()
-	err = postgreSQL.Ping()
-	if err != nil {
-		panic(err)
-	}
 	mux := http.NewServeMux()

コード修正

2019/02/16 15:46

投稿

teikoku-penguin

スコア314

test CHANGED Viewed

@@ -314,15 +314,15 @@
-    	err = postgreSQL.Ping()
+	err = postgreSQL.Ping()
-    	if err != nil {
+	if err != nil {
-        	panic(err)
+		panic(err)
-    	}
+	}

修正

2019/02/16 15:31

投稿

teikoku-penguin

スコア314

test CHANGED Viewed

@@ -116,212 +116,216 @@
 	if err != nil {
+		return nil, err
+	}
+	fmt.Print("Successfully connected!\n")
+	return &postgreSQL, nil
+}
+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 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() {
+	postgreSQL, err := init()
+	if err != nil {
 		panic(err)
 	}
-	fmt.Print("Successfully connected!\n")
-}
-func (room *Room) SQLRoomCreate() (err error) {
+	defer postgreSQL.Close()
-	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)
+    	err = postgreSQL.Ping()
-	if err != nil {
+    	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
+        	panic(err)
-}
-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() {
-	postgreSQL, err := init()
-	if err != nil {
-		panic(err)
-	}
-	defer postgreSQL.Close()
-    	err = postgreSQL.Ping()
-    	if err != nil {
-        	panic(err)
-    	}
 	mux := http.NewServeMux()

追記

2019/02/16 15:29

投稿

teikoku-penguin

スコア314

test CHANGED Viewed

@@ -51,3 +51,305 @@
 }
 ```
+# 2/17 追記
+init関数をmainで呼んであげてdaoをポインタで返せばいいかと思います
+なるべく元の物に変更を加えないようにしました
+```Go
+package main
+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 {
+		panic(err)
+	}
+	fmt.Print("Successfully connected!\n")
+}
+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 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() {
+	postgreSQL, err := init()
+	if err != nil {
+		panic(err)
+	}
+	defer postgreSQL.Close()
+    	err = postgreSQL.Ping()
+    	if err != nil {
+        	panic(err)
+    	}
+	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())
+}
+```

文章修正

2019/02/16 15:27

投稿

teikoku-penguin

スコア314

test CHANGED Viewed

@@ -1,7 +1,3 @@
-サーバーのコードの一部なのだと思うので全部貼ってあると回答しやすいです。
 ぱっと見た感じですが提示しているコードだけ見ると func initに問題があるのではないでしょうか？