MongoDB

Java整合MongoDB

应用

2.1引入依赖

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>

2.2添加远程链接配置

spring:
    data:
        mongodb:
            uri: mongodb://localhost:27017/chat_memory_db

CRUD测试

创建实体类：映射MongoDB中的文档（相当于MySQL的表）

package com.atguigu.java.ai.langchain4j.bean;

@Data
@AllArgsConstructor
@NoArgsConstructor
@Document("chat_messages")
public class ChatMessages{

    //唯一标识，映射到MongoDB文档的_id字段
    @Id
    private Long MessageId;
    private String content;//存储当前聊天记录列表的json字符串
}

2.4 @AiService

也可以在Assistant接口上添加@AiService注解

    @Test
    public void testInsert(){
        ChatMessages chatMessages = new ChatMessages();
        chatMessages.setContent("聊天记录列表");
        mongoTemplate.insert(chatMessages);
    }

    @Test
    public void testFindById(){
        ChatMessages chatMessages = mongoTemplate.findById("sdasdaf",ChatMessages.class);
        System.out.println(chatMessages);
    }

    @Test
    public void testUpdate(){
        Criteria criteria = Criteria.where("_id").is("askldjlksajfklasf");//_id
        Query query = new Query(criteria);
        Update update = new Update();
        update.set("content","新的聊天记录列表");

        //修改成新增
        mongoTemplate.upsert(query,update,ChatMessages.class);
    }

    @Test
    public void testDelete(){
        Criteria criteria = Criteria.where("_id").is("100");
        Query query = new Query(criteria);
        mongoTemplate.remove(query,ChatMessages.class);
    }