MySQL insert文が発行されない

Question

#Spring Bootでメッセージアプリケーション
メッセージアプリケーションをSpring Bootで作っていますが
メッセージを送信した後にうまくDBに情報が保存されません。
どの部分に問題があるのかお分かりの方がいたらアドバイスをいただきたいです。

以下のように実行をしてみましたが、発行されたSQL文は

select message0_.message_id as message_1_4_, message0_.message_content as message_2_4_, message0_.message_time as message_3_4_, message0_.receiver_user_id as receiver4_4_, message0_.sender_user_id as sender_u5_4_ from message message0_ left outer join user user1_ on message0_.receiver_user_id=user1_.user_id where user1_.user_id=?

のようにselect文のみになっています。
本来はメッセージテーブルに送信した情報を保存したいです。
おそらくは@ManyToOneにおけるDBへの保存方法に問題があると思うのですが
具体的にどの部分に問題があるのかが見当がつきません。
何かアドバイスをいただけると幸いです。

使用環境
SpringBoot 2.2.4.
mysql 8.0.18

##insert文

@Repository
@Transactional
public interface MessageReposioty extends JpaRepository<Message, Long>{
	List<Message> findBySenderUser_UserId(int userId);
	List<Message> findByReceiverUser_UserId(int userId);
	
	@Modifying
    @Query(value = "insert into message (sender_user_id,receiver_user_id,message_content) "
            + "VALUES (:senderUserId,:receiverUserId,:messageContent)", nativeQuery = true)
    @Transactional
    void sendMessage(@Param("senderUserId") int senderUserId, @Param("receiverUserId") int receiverUserId,
            @Param("messageContent") String messageContent);
}

##Entity

@Entity
@Transactional
@NamedQuery(name="User.findAll", query="SELECT u FROM User u")
public class User implements Serializable {
	private static final long serialVersionUID = 1L;

	@Id
	@Column(name="user_id")
	private int userId;

	
	//bi-directional many-to-one association to Message
	@OneToMany(mappedBy="senderUser")
	private List<Message> messages1;

	//bi-directional many-to-one association to Message
	@OneToMany(mappedBy="receiverUser")
	private List<Message> messages2;

	public User() {
	}

	public int getUserId() {
		return this.userId;
	}

	public void setUserId(int userId) {
		this.userId = userId;
	}

	
	public List<Message> getMessages1() {
		return this.messages1;
	}

	public void setMessages1(List<Message> messages1) {
		this.messages1 = messages1;
	}

	public Message addMessages1(Message messages1) {
		getMessages1().add(messages1);
		messages1.setSenderUser(this);

		return messages1;
	}

	public Message removeMessages1(Message messages1) {
		getMessages1().remove(messages1);
		messages1.setSenderUser(null);

		return messages1;
	}

	public List<Message> getMessages2() {
		return this.messages2;
	}

	public void setMessages2(List<Message> messages2) {
		this.messages2 = messages2;
	}

	public Message addMessages2(Message messages2) {
		getMessages2().add(messages2);
		messages2.setReceiverUser(this);

		return messages2;
	}

	public Message removeMessages2(Message messages2) {
		getMessages2().remove(messages2);
		messages2.setReceiverUser(null);

		return messages2;
	}

	
}

@Entity
@NamedQuery(name="Message.findAll", query="SELECT m FROM Message m")
public class Message implements Serializable {
	private static final long serialVersionUID = 1L;

	@Id
	@GeneratedValue(strategy=GenerationType.IDENTITY)
	@Column(name="message_id")
	private long messageId;

	@Column(name="message_content")
	private String messageContent;

	@Temporal(TemporalType.TIMESTAMP)
	@Column(name="message_time")
	private Date messageTime;

	//送信者
	@ManyToOne
	@JoinColumn(name="sender_user_id")
	private User senderUser;

	//受信者
	@ManyToOne
	@JoinColumn(name="receiver_user_id")
	private User receiverUser;

	public Message() {
	}

	public long getMessageId() {
		return this.messageId;
	}

	public void setMessageId(long messageId) {
		this.messageId = messageId;
	}

	public String getMessageContent() {
		return this.messageContent;
	}

	public void setMessageContent(String messageContent) {
		this.messageContent = messageContent;
	}

	public Date getMessageTime() {
		return this.messageTime;
	}

	public void setMessageTime(Date messageTime) {
		this.messageTime = messageTime;
	}

	public User getSenderUser() {
		return senderUser;
	}

	public void setSenderUser(User senderUser) {
		this.senderUser = senderUser;
	}

	public User getReceiverUser() {
		return receiverUser;
	}

	public void setReceiverUser(User receiverUser) {
		this.receiverUser = receiverUser;
	}

##controller

@Controller
@RequestMapping("profile")
public class MessageController {
	
	@Autowired 
	UserRepository userRepository;
	@Autowired
	MessageReposioty messageRepository;
	
	@ModelAttribute
	public MessageForm messageForm() {
		return new MessageForm();
	}
	
	@GetMapping("/{userId}/message")
	String showMessage(@PathVariable("userId") Integer userId,
			Model model) {
		User senderUser = userRepository.findById(userId).orElse(null);
		List<Message> recieveMessage = messageRepository.findByReceiverUser_UserId(userId);
		model.addAttribute("recieveMessage",recieveMessage);
		model.addAttribute("senderUser",senderUser);
		return "profile/message";
	}
	
	//送信時の処理
	@PostMapping("/{userId}/message")
	String sendMessage(@Validated MessageForm messageForm,
			@AuthenticationPrincipal LoginUserDetails userDetails,
			@PathVariable("userId") Integer userId,
			Model model) {
		User senderUser = userDetails.getUser();
		User receiverUser = userRepository.findById(userId).orElse(null);
		User senderUser = userDetails.getUser();
		User receiverUser = userRepository.findById(userId).orElse(null);
		int senderUserId = senderUser.getUserId();
		int receiverUserId = receiverUser.getUserId();
		String messageContent = messageForm.getMessageContent();
       //ここでinsertを実行
		messageRepository.sendMessage(senderUserId, receiverUserId, messageContent);
		return "redirect:{userId}/message";
	}
}

##HTML

<!DOCTYPE html>
<html xmlns:th="http://www.thymeleaf.org"
	xmlns:sec="http://www.thymeleaf.org/extras/spring-security">
<head>
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8" />
<title>Insert title here</title>
</head>
<body th:with="user = ${#authentication.principal.user}">
	<h1>メッセージ</h1>
	<p th:text="${senderUser.userName}+'さんへメッセージを送る'"></p>
	<form th:action="@{'/profile/'+${senderUser.userId}+'/message'}" th:object="${messageForm}">
		<textarea placeholder="メッセージを入力してください" th:field="*{messageContent}">
		</textarea>
		<input type="submit">
	</form>
</body>
</html>

#作成したテーブル

--ユーザーテーブル--
CREATE TABLE IF NOT EXISTS user(
  user_id INTEGER AUTO_INCREMENT,
  user_name VARCHAR(12) NOT NULL,
  PRIMARY KEY(user_id);
) ENGINE=INNODB DEFAULT CHARSET=utf8;

--メッセージテーブル--
CREATE TABLE IF NOT EXISTS message(
  message_id BIGINT AUTO_INCREMENT NOT NULL,
  sender_user_id INTEGER NOT NULL,
  receiver_user_id INTEGER NOT NULL,
  message_content VARCHAR(300),
  message_time datetime DEFAULT CURRENT_TIMESTAMP,
  PRIMARY KEY(message_id),
  FOREIGN KEY (sender_user_id)
        REFERENCES user(user_id)
        ON DELETE CASCADE,
  FOREIGN KEY (receiver_user_id)
        REFERENCES user(user_id)
        ON DELETE CASCADE
) ENGINE=INNODB DEFAULT CHARSET=utf8;

#ER図

Comments

[Orlofsky]

SQLで使われるテーブルはCREATE TABLEされていなければなりません。テーブル内のデータはINSERTされていなければSELECTできません。ですから、質問にCREATE TABLEやINSERTでデータを提示した方が適切な回答が付き易いです。

[encho]

ありがとうございます。
テーブルを作成したSQL分の追加を行いました。
MESSAGEテーブルにはまだ何もinsertされておらず
これからINSERTをしようという状態です。

Answer 1

このmethodを省略したフォームだとGETメソッドでメッセージを送信するので、実行されるコントローラメソッドはMessageController.showMessageになります。
これがinsert文が実行されない原因となります。

<form th:action="@{'/profile/'+${senderUser.userId}+'/message'}" th:object="${messageForm}">

  <!-- 省略 -->

</form>

修正は以下のようにフォームにmethod="POST"を追加すればよいと思います。これでPOSTメソッドでメッセージを送信するので、MessageController.sendMessageが実行されます。
他にも修正が必要な個所がありますが、とりあえずinsert文は実行されると思います。

<form th:action="@{'/profile/'+${senderUser.userId}+'/message'}" th:object="${messageForm}" method="POST">

  <!-- 省略 -->

</form>

今回のような不具合に早く気付くには、必要な個所にログを出力するコードを仕込んでおくのが効果的です。
以下はlogbackを利用したロギングの例です。メソッドの先頭で引数をdebugログに出力しています。

@GetMapping("/{userId}/message")
String showMessage(@PathVariable("userId") Integer userId, Model model) {
  log.debug("showMessage userId:{}", userId);

  // 省略

  return "profile/message";
}

@PostMapping("/{userId}/message")
String sendMessage(@Validated MessageForm messageForm, @AuthenticationPrincipal LoginUserDetails userDetails, @PathVariable("userId") Integer userId, Model model) {
  log.debug("sendMessage form:{}, userId:{}", messageForm, userId);

  // 省略

  // ↓ ちなみにこの書き方だと期待するリダイレクトになりません。
  return "redirect:{userId}/message";
}

追記

以下は私だったらこう実装するという意味の内容です。なのでこうしなければならないという訳ではなく、あくまで参考程度のものです。また、コード全体ではなく必要な個所だけ抜粋しています。

エンティティクラス

@Entity
@NamedQuery(name="Message.findAll", query="SELECT m FROM Message m")
public class Message implements Serializable {

	@Id
	@GeneratedValue(strategy=GenerationType.IDENTITY)
	@Column(name="message_id")
	// フィールドの型にプリミティブ型は使用しない
	//private long messageId;
	private Long messageId;

	//処理のないデフォルトコンストラクタは書かない
	//public Message() {
	//}

	public void setSenderUser(User senderUser) {
		this.senderUser = senderUser;
		this.senderUser.addSendMessage(this);
	}

	public void setReceiverUser(User receiverUser) {
		this.receiverUser = receiverUser;
		this.receiverUser.addReceiveMessage(this);
	}

}

@Entity
//Transactionalアノテーションはトランザクション境界を考えて付与する
//@Transactional
@NamedQuery(name="User.findAll", query="SELECT u FROM User u")
public class User implements Serializable {

	@Id
	@Column(name="user_id")
	// フィールドの型にプリミティブ型は使用しない
	//private int userId;
	private Integer userId;

	@OneToMany(mappedBy="senderUser")
	//意味の通じにくいフィールド名は避ける
	//private List<Message> messages1;
	private List<Message> sendMessages;

	@OneToMany(mappedBy="receiverUser")
	//意味の通じにくいフィールド名は避ける
	//private List<Message> messages2;
	private List<Message> receiveMessages;

	//処理のないデフォルトコンストラクタは書かない
	//public User() {
	//}

	public void addSendMessage(Message message) {
		if (this.sendMessages == null) {
			this.sendMessages = new ArrayList<>();
		}
		this.sendMessages.add(message);
	}

	public void addReceiveMessage(Message message) {
		if (this.receiveMessages == null) {
			this.receiveMessages = new ArrayList<>();
		}
		this.receiveMessages.add(message);
	}

}

リポジトリインターフェース
（※MessageReposiotyはMessageRepositoryのtypoです）

//不要なアノテーションは付与しない
//@Repository
//Transactionalアノテーションはトランザクション境界を考えて付与する
//@Transactional
public interface MessageRepository extends JpaRepository<Message, Long> {
	//プリミティブ型を避ける
	//List<Message> findBySenderUser_UserId(int userId);
	//List<Message> findByReceiverUser_UserId(int userId);
	List<Message> findBySenderUser_UserId(Integer userId);
	List<Message> findByReceiverUser_UserId(Integer userId);

	//可能な限りネイティブクエリを避ける
	//今回はsaveメソッドで十分なので使用しない
	//@Modifying
	//@Query(value = "insert into message (sender_user_id,receiver_user_id,message_content) "
	//		+ "VALUES (:senderUserId,:receiverUserId,:messageContent)", nativeQuery = true)
	//@Transactional
	//void sendMessage(@Param("senderUserId") int senderUserId, @Param("receiverUserId") int receiverUserId,
	//		@Param("messageContent") String messageContent);

}

コントローラクラス

@Controller
@RequestMapping("profile")
public class MessageController {

	//コンストラクタインジェクションを利用する
	//@Autowired
	//UserRepository userRepository;
	//@Autowired
	//MessageRepository messageRepository;

	private final UserRepository userRepository;
	private final MessageRepository messageRepository;

	public MessageController(UserRepository userRepository, MessageRepository messageRepository) {
		this.userRepository = userRepository;
		this.messageRepository = messageRepository;
	}

	//送信時の処理
	@PostMapping("/{userId}/message")
	// トランザクション境界をここに設定する（この例では）
	// 本来ならサービスクラスを実装しそのメソッドにトランザクション境界を設定する
	@Transactional(readOnly = false, timeout = 10)
	String sendMessage(@Validated MessageForm messageForm,
			// バリデーションを行うのならBindingResultでその結果を受け取る
			BindingResult result,
			@AuthenticationPrincipal LoginUserDetails userDetails,
			@PathVariable("userId") Integer userId
			// 使用しない引数は定義しない
			/* Model model */) {

		if (result.hasErrors()) {
			// バリデーションエラー時の処理
		}

		//User senderUser = userDetails.getUser();
		User senderUser = userRepository.findById(userDetails.getUser().getUserId()).orElseThrow();

		//安易にnullを返さない。検索できなかったときにどうするか仕様を決めておく。
		//User receiverUser = userRepository.findById(userId).orElse(null);
		User receiverUser = userRepository.findById(userId).orElseThrow();

		//int senderUserId = senderUser.getUserId();
		//int receiverUserId = receiverUser.getUserId();

		String messageContent = messageForm.getMessageContent();

		Message message = new Message();
		message.setMessageContent(messageContent);
		message.setMessageTime(new Date());
		message.setSenderUser(senderUser);
		message.setReceiverUser(receiverUser);
		messageRepository.save(message);

		//リポジトリのsaveメソッドで永続化するので使用しない
		//messageRepository.sendMessage(senderUserId, receiverUserId, messageContent);
		return "redirect:/profile/" + userId + "/message";
	}

}

Comments

[encho]

ご回答ありがとうございます。本当に根本的な部分のミスでしたのでお恥ずかしい限りです。
ロギングの件も参考にさせていただきます。

[encho]

```
@PostMapping("/{userId}/message")
String sendMessage(@Validated MessageForm messageForm,
@AuthenticationPrincipal LoginUserDetails userDetails,
@PathVariable("userId") Integer userId,
Model model) {
User senderUser = userDetails.getUser();
User receiverUser = userRepository.findById(userId).orElse(null);
int senderUserId = senderUser.getUserId();
int receiverUserId = receiverUser.getUserId();
String messageContent = messageForm.getMessageContent();
messageRepository.sendMessage(senderUserId, receiverUserId, messageContent);
return "redirect:/profile/"+userId+"/message";
}
```

[encho]

以上のように改良することでリダイレクトDBへの保存含め問題なく機能するようになりました。
これ以外に変更が必要な箇所がありましたらご指摘いただけると幸いです。
ずっと止まってしまっていたので本当に感謝しています。ありがとうございました。

[rubytomato]

機能するようになったということでよかったです。
私だったらこうするという視点で追記しましたのでご確認ください。

[encho]

ご丁寧に参考のコードまで本当にありがとうございます。
初学者のため大変参考になる部分が多くありました
引き続き学習に励みスキルアップを図って行きたいと思います

Answer 2

最初のSELECT文だけしか見ていません。
少し見易く整形すると読む気に慣れます。

select
    message0_.message_id as message_1_4_
  , message0_.message_content as message_2_4_
  , message0_.message_time as message_3_4_
  , message0_.receiver_user_id as receiver4_4_
  , message0_.sender_user_id as sender_u5_4_
from message message0
left outer join user user1_
on message0_.receiver_user_id = user1_.user_id
where user1_.user_id = ?

from message message0

message というテーブルに message0 という別名を付けていますが、
selectの並びや on には message0_ と最後にアンダーバーが付いた存在しない別名を使っているからエラーになります。

エラーにならなくても as message_1_4_ って列の別名にことさら可読性を低めてバグを生みやすくするのは止めたほうが良いです。ネーミングのセンスを疑われます。

Comments

[encho]

ありがとうございます。
repositoryを通して発行しているSQL文なので
勝手に命名が行われているという状態です。
テーブルと連携して発行していると思うのでここに問題があるというよりかは
他の部分に問題があるように考えていたのですが...

[Orlofsky]

以前、全ての項目が連番、ってシステムからデータをもらっていたサブシステムで5%くらいだったか、本来の区分に設定されていけないデータがとんでもない区分で渡されて、連番が大好きな担当者は自分たちのバグを認めないことで解決したことに。もらっているデータ修復のためだけで月70～100時間の無駄な作業を強いられたことがあります。
同じようなことにならない事を祈ります。