Skip to content

Commit 50ccfd6

Browse files
committed
Fix JdbcChatMemoryRepositoryPostgresqlIT
- Make sure to set the dialect via datasource Signed-off-by: Ilayaperumal Gopinathan <[email protected]>
1 parent b581bce commit 50ccfd6

File tree

1 file changed

+10
-5
lines changed

1 file changed

+10
-5
lines changed

memory/repository/spring-ai-model-chat-memory-repository-jdbc/src/test/java/org/springframework/ai/chat/memory/repository/jdbc/JdbcChatMemoryRepositoryPostgresqlIT.java

Lines changed: 10 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,8 @@
4040
import java.util.List;
4141
import java.util.UUID;
4242

43+
import javax.sql.DataSource;
44+
4345
import 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

Comments
 (0)