feat: 채팅 저장을 jdbc template을 이용한 bulk insert 변경

Author: Curry4182

lime-domain/src/main/java/com/programmers/lime/domains/chat/implementation/ChatAppender.java

@@ -3,10 +3,12 @@
 import java.util.List;
 import java.util.stream.Collectors;
 
+import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.stereotype.Component;
 
 import com.programmers.lime.domains.chat.domain.Chat;
 import com.programmers.lime.domains.chat.model.ChatInfo;
+import com.programmers.lime.domains.chat.repository.ChatJdbcTemplateRepository;
 import com.programmers.lime.domains.chat.repository.ChatRepository;
 
 import lombok.RequiredArgsConstructor;
@@ -17,6 +19,8 @@ public class ChatAppender {
 
 	private final ChatRepository chatRepository;
 
+	private final ChatJdbcTemplateRepository chatJdbcTemplateRepository;
+
 	public void appendChat(
 		final ChatInfo chatInfo
 	) {
@@ -45,6 +49,6 @@ public void appendChats(
 				.build()
 		).collect(Collectors.toList());
 
-		chatRepository.saveAll(chats);
+		chatJdbcTemplateRepository.bulkInsertChats(chats);
 	}
 }

lime-domain/src/main/java/com/programmers/lime/domains/chat/repository/ChatJdbcTemplateRepository.java

@@ -0,0 +1,36 @@
+package com.programmers.lime.domains.chat.repository;
+
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
+import java.sql.Timestamp;
+import java.util.List;
+
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.stereotype.Repository;
+import org.springframework.transaction.annotation.Transactional;
+
+import com.programmers.lime.domains.chat.domain.Chat;
+
+import lombok.RequiredArgsConstructor;
+
+@Repository
+@RequiredArgsConstructor
+public class ChatJdbcTemplateRepository {
+
+	private static final String INSERT_SQL = "INSERT INTO chats (chat_room_id, member_id, message, send_at, chat_type) VALUES (?, ?, ?, ?, ?)";
+
+	private final JdbcTemplate jdbcTemplate;
+
+	@Transactional
+	public void bulkInsertChats(final List<Chat> chats) {
+		jdbcTemplate.batchUpdate(INSERT_SQL, chats, 50, this::prepareStatement);
+	}
+
+	private void prepareStatement(final PreparedStatement ps, final Chat chat) throws SQLException {
+		ps.setLong(1, chat.getChatRoomId());
+		ps.setLong(2, chat.getMemberId());
+		ps.setString(3, chat.getMessage());
+		ps.setTimestamp(4, Timestamp.valueOf(chat.getSendAt()));
+		ps.setString(5, chat.getChatType().toString());
+	}
+}