MongoDB 整合SpringBoot举例介绍
目录
- 映入依赖
- yaml配置
- 数据库
- 定义文档实体
- 增删改查
映入依赖
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-MongoDB</artifactId> </dependency>
yaml配置
spring: data: mongodb: uri: mongodb://localhost:27017/chat_memory_db # mongodb地址 会自动创建
数据库
定义文档(文档相当于mysql 的行)
定义文档实体
@Data @AllArgsConstructor @NoArgsConstructor @Document("chat_message") public class ChatMessages { @Id private Long messageId; /** * 聊天记录列表json字符串 */ private String content; }
www.devze.com @Test public void test(){ ChatMessages chatMessages = new ChatMessages(1L,"你好"); mo编程客栈编程客栈ngoTemplate.insert(chatMessages); }
增删改js查
public void testInsert(){ ChatMessages chatMessages = new ChatMessages(); chatMessages.setContent("你好"); mongoTemplate.insert(chatMessages); } @Test public void testQuery(){ ChatMessages byId = mongoTemplate.findById("680e38d1eb0e2f7b6d287541", ChatMessages.class); System.out.print(byId); } @Test public void testUpdate1(){ // 根据id修改 Criteria criteria = Criteria.where("_id").is("680e38d1eb0e2f7b6d287541"); Query query = new Query(criteria); Update update = new Update(); update.set("content","新的聊天记录"); // 新增或者更新 mongoTemplate.upsert(query,update,ChatMessages.class); } @Test public void testUpdate2(){ // 根据id修改 Criteria criteria = Criteria.where("_id").is("100"); Query query = new Query(criteria); Update update = new Update(); update.set("content","新的聊天记录"); // 新增或者更新 mongoTemplate.upsert(query,update,ChatMessages.class); } @Test public void testRemove(){ // 根据id修改 Criteria criteria = Criteria.where("_id").is("100"); Query query = new Query(criteria); Update update = new Update(); update.set("content","新的聊天记录"); // 新增或者更新 mongoTemplate.remove(query,ChatM编程客栈essages.class); }
到此这篇关于MongoDB 整合SpringBoot举例介绍的文章就介绍到这了,更多相关MongoDB 整合SpringBoot内容请搜索编程客栈(www.devze.com)以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程客栈(www.devze.com)!
精彩评论