4040import java .util .List ;
4141import java .util .UUID ;
4242
43+ import javax .sql .DataSource ;
44+
4345import static org .assertj .core .api .Assertions .assertThat ;
4446
4547/**
@@ -77,7 +79,7 @@ void saveMessagesSingleMessage(String content, MessageType messageType) {
7779
7880 chatMemoryRepository .saveAll (conversationId , List .of (message ));
7981
80- var query = "SELECT conversation_id, content, type, \" timestamp\" FROM ai_chat_memory WHERE conversation_id = ?" ;
82+ var query = "SELECT conversation_id, content, type, \" timestamp\" FROM SPRING_AI_CHAT_MEMORY WHERE conversation_id = ?" ;
8183 var result = jdbcTemplate .queryForMap (query , conversationId );
8284
8385 assertThat (result .size ()).isEqualTo (4 );
@@ -96,7 +98,7 @@ void saveMessagesMultipleMessages() {
9698
9799 chatMemoryRepository .saveAll (conversationId , messages );
98100
99- var query = "SELECT conversation_id, content, type, \" timestamp\" FROM ai_chat_memory WHERE conversation_id = ?" ;
101+ var query = "SELECT conversation_id, content, type, \" timestamp\" FROM SPRING_AI_CHAT_MEMORY WHERE conversation_id = ?" ;
100102 var results = jdbcTemplate .queryForList (query , conversationId );
101103
102104 assertThat (results .size ()).isEqualTo (messages .size ());
@@ -148,7 +150,7 @@ void deleteMessagesByConversationId() {
148150
149151 chatMemoryRepository .deleteByConversationId (conversationId );
150152
151- var count = jdbcTemplate .queryForObject ("SELECT COUNT(*) FROM ai_chat_memory WHERE conversation_id = ?" ,
153+ var count = jdbcTemplate .queryForObject ("SELECT COUNT(*) FROM SPRING_AI_CHAT_MEMORY WHERE conversation_id = ?" ,
152154 Integer .class , conversationId );
153155
154156 assertThat (count ).isZero ();
@@ -159,8 +161,11 @@ void deleteMessagesByConversationId() {
159161 static class TestConfiguration {
160162
161163 @ Bean
162- ChatMemoryRepository chatMemoryRepository (JdbcTemplate jdbcTemplate ) {
163- return JdbcChatMemoryRepository .builder ().jdbcTemplate (jdbcTemplate ).build ();
164+ ChatMemoryRepository chatMemoryRepository (JdbcTemplate jdbcTemplate , DataSource dataSource ) {
165+ return JdbcChatMemoryRepository .builder ()
166+ .jdbcTemplate (jdbcTemplate )
167+ .dialect (JdbcChatMemoryDialect .from (dataSource ))
168+ .build ();
164169 }
165170
166171 }
0 commit comments