【データ更新APIの実装】Go言語でのAPI開発 | 実践的な学習から実装まで④

package domain

// 各エンティティ項目の`json:～`の部分を追記
type User struct {
	UserID   int    `json:"user_id"`
	Name     string `json:"name"`
	Email    string `json:"email"`
	Password string `json:"password"`
}

package usecase

import (
	"myApiProject/internal/domain"
	"myApiProject/internal/repository"
)

type UserUseCase struct {
	repo repository.UserRepository
}

func NewUserUseCase(repo repository.UserRepository) *UserUseCase {
	return &UserUseCase{repo: repo}
}

/* 
*  ～ 前回までのGetUserロジック ～
*/

// ここから下のコードを新たに追記
func (uc *UserUseCase) UpdateUser(userRes domain.User) (string, error) {
	return uc.repo.UpdateUser(userRes)
}

package repository

import (
	"database/sql"
	"myApiProject/internal/domain"
	// 新たに"strconv"をimportに追記
	"strconv"
	"strings"
)

/* 
*  ～ 前回までのFindByIDロジック ～
*/

// ここから下のコードを新たに追記
func (r *UserRepository) UpdateUser(userRes domain.User) (string, error) {

	updates := []string{}
	params := []interface{}{}
	message := []string{}

	message = append(message, "ユーザーID'"+strconv.Itoa(userRes.UserID)+"'の")

	if userRes.Name != "" {
		updates = append(updates, "name = ?")
		params = append(params, userRes.Name)
		message = append(message, "名前を'"+userRes.Name+"'に、")
	}
	if userRes.Email != "" {
		updates = append(updates, "email = ?")
		params = append(params, userRes.Email)
		message = append(message, "Emailを'"+userRes.Email+"'に、")
	}
	if userRes.Password != "" {
		updates = append(updates, "password = ?")
		params = append(params, userRes.Password)
		message = append(message, "パスワードを'"+userRes.Password+"'に、")
	}

	message = append(message, "変更しました！")

	if len(updates) == 0 {
	 // 何も更新しない場合は、エラーではなく更新0件メッセージをセット
		return "ユーザーデータの更新は0件数です！", nil 
	}

	query := "UPDATE Users SET " + strings.Join(updates, ", ") + " WHERE user_id = ?"
	params = append(params, userRes.UserID)

	_, err := r.db.Exec(query, params...)
	return strings.Join(message, ""), err
}

package handler

import (
	"encoding/json"
	"myApiProject/internal/domain"
	"myApiProject/internal/usecase"
	"net/http"
)

/* 
*  ～ 前回までのGetUserロジック ～
*/

// ここから下のコードを新たに追記
func (h *UserHandler) UpdateUser(w http.ResponseWriter, r *http.Request) {
	var user domain.User
	if err := json.NewDecoder(r.Body).Decode(&user); err != nil {
		http.Error(w, "User Data is missing", http.StatusBadRequest)
		return
	}

	message, err := h.useCase.UpdateUser(user)
	if err != nil {
		http.Error(w, "Internal server error", http.StatusInternalServerError)
		return
	}
  // messageをHTTPレスポンスに返答
	json.NewEncoder(w).Encode(message)
}

package router

import (
	"database/sql"
	"myApiProject/internal/handler"
	"myApiProject/internal/repository"
	"myApiProject/internal/usecase"
	"net/http"
)

func NewRouter(db *sql.DB) *http.ServeMux {
	repo := repository.NewUserRepository(db)
	useCase := usecase.NewUserUseCase(*repo)
	userHandler := handler.NewUserHandler(useCase)

	router := http.NewServeMux()
	router.HandleFunc("/user", userHandler.GetUser)
	// ↓の１行だけ追加
	router.HandleFunc("/user-update", userHandler.UpdateUser)
	return router
}

{
    "user_id": 1,
    "name": "田中次郎"
}