电脑知识|欧美黑人一区二区三区|软件|欧美黑人一级爽快片淫片高清|系统|欧美黑人狂野猛交老妇|数据库|服务器|编程开发|网络运营|知识问答|技术教程文章 - 好吧啦网

您的位置:首頁技術文章
文章詳情頁

Spring Boot 整合 MongoDB的示例

瀏覽:8日期:2023-08-05 16:29:22

本節使用SpringBoot 2.1.9.RELEASE,示例源碼在https://github.com/laolunsi/spring-boot-examples/tree/master/06-spring-boot-mongo-demo

SpringBoot可以非常方便地引入和操作MongoDB。本節分兩部分,記錄個人學習SpringBoot使用MongoDB數據庫的一些知識。

第一部分是一個簡單的springboot連接mongo的demo,測試查詢功能。

第二部分是基于mongo實現的增刪改查數據示例。

本節使用SpringBoot 2.1.9.RELEASE

一、A simple demo

首先來演示SpringBoot項目引入MongoDB,以及一個簡單的findAll操作。

maven依賴:

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

環境配置:

application.yml文件中寫入如下配置,test表示MongoDB中的test表

spring: data: mongodb: uri: 'mongodb://localhost:27017/test'

以一個bean類為例:

package com.example;public class User { private String id; private String name; private Integer age; private Integer grade; // ... ignore getter and setter // override its toString method @Override public String toString() { return 'User{' +'id=’' + id + ’’’ +', name=’' + name + ’’’ +', age=' + age +', grade=' + grade +’}’; }}

在MongoDB數據庫中新建一個collection(也就是表),名字叫user,插入幾條數據,比如:

Spring Boot 整合 MongoDB的示例

注:這里用的可視化工具是robo 3t:https://www.jb51.net/database/567493.html

我們這里先默認JavaBean的字段與user表的字段名保持一致。

下面我們編寫測試類:

@SpringBootTest@RunWith(SpringRunner.class)public class MongoTest { @Autowired private MongoTemplate mongoTemplate; @Test public void test1() { List<User> userList = mongoTemplate.findAll(User.class); if (userList != null && userList.size() > 0) { userList.forEach(user -> {System.out.println(user.toString()); }); } }}

運行測試類,輸出如下:

User{id=’5d243534514701183f5fcab8’, name=’zf0’, age=12, grade=1}User{id=’5d243534514701183f5fcab9’, name=’zf1’, age=13, grade=2}User{id=’5d243534514701183f5fcaba’, name=’zf2’, age=14, grade=3}User{id=’5d243534514701183f5fcabb’, name=’zf3’, age=15, grade=4}User{id=’5d243534514701183f5fcabc’, name=’zf4’, age=16, grade=5}

二、基于SpringBoot的MongoDB增刪改查操作

下面來實現一個基于SpringBoot的對MongoDB增刪改查操作的簡單示例,依然使用上面的環境:

maven:

<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId></dependency><dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope></dependency><dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-mongodb</artifactId></dependency><dependency> <groupId>com.alibaba</groupId> <artifactId>fastjson</artifactId> <version>1.2.60</version></dependency>

yml:

server: port: 8866spring: data: mongodb: uri: 'mongodb://localhost:27017/test'

User類:

這里我們清楚一下之前的數據,把mongo里的user表里的數據全部刪掉。

Spring Boot 整合 MongoDB的示例

注:這里用的可視化工具admin-mongo:https://github.com/mrvautin/adminMongo

Spring Boot 整合 MongoDB的示例

新建一個不同的user類:

@Document('user')public class User { @Id private String id; @Field('name') private String name; @Field('password') private String password; @Field('address') private String address; @Field('create_time') private Date createTime; @Field('last_update_time') private Date lastUpdateTime; // ... ignore getter and setter methods @Override public String toString() { return JSONObject.toJSONString(this); }}

此處定義一個JsonResult類,用于封裝接口返回數據:

import com.alibaba.fastjson.JSONObject;import java.util.HashMap;import java.util.Map;public class JsonResult { /** * 未登錄 */ public static final int NO_LOGIN = 400; /** * 登錄失敗 */ public static final int LOGIN_FAILED = 401; /** * TOKEN過期 */ public static final int TOKEN_EXPIRED = 402; /** * 無權限 */ public static final int NO_PERMISSION = 403; private Boolean success; private Integer code; private String msg; private Object data; public JsonResult(Boolean success) { this.success = success; } public JsonResult(Boolean success, String msg) { this.success = success; this.msg = msg; } public JsonResult(Integer code, Boolean success, String msg) { this.code = code; this.success = success; this.msg = msg; } public JsonResult(Boolean success, Object data) { this.success = success; this.data = data; } public JsonResult(Boolean success, Integer code, String msg, Object data) { this.success = success; this.code = code; this.msg = msg; this.data = data; } // ... ignore getter and setter methods public void put(String key, Object value) { if (data == null) { data = new HashMap<>(); } ((Map) data).put(key, value); } public void putAll(Map<String, Object> map) { if (data == null) { data = new HashMap<>(); } ((Map) data).putAll(map); } @Override public String toString() { return JSONObject.toJSONString(this); }}

下面編寫測試接口類,實現用戶的新增、刪除、更新、查詢功能

UserController類:

@RestController@RequestMapping(value = 'user')public class UserController { @Autowired private MongoTemplate mongoTemplate; @GetMapping(value = '') public JsonResult list() { List<User> userList = mongoTemplate.findAll(User.class, 'user'); return new JsonResult(true, userList); } @PostMapping(value = '') public JsonResult add(User user) { String msg = verifySaveForm(user); if (!StringUtils.isEmpty(msg)) { return new JsonResult(false, msg); } if (user.getId() == null) { user.setCreateTime(new Date()); user.setLastUpdateTime(new Date()); User newUser = mongoTemplate.insert(user, 'user'); return new JsonResult(true, newUser); } else { Query query = new Query(); query.addCriteria(Criteria.where('_id').is(user.getId())); Update update = new Update(); update.set('name', user.getName()); update.set('password', user.getPassword()); update.set('address', user.getAddress()); update.set('last_update_time', new Date()); UpdateResult updateResult = mongoTemplate.updateFirst(query, update, 'user'); return new JsonResult(true, updateResult); } } @DeleteMapping(value = '{id}') public JsonResult delete(@PathVariable String id) { Query query = new Query(); query.addCriteria(Criteria.where('_id').is(id)); DeleteResult deleteResult = mongoTemplate.remove(query, User.class, 'user'); return new JsonResult(true, deleteResult); } // private methods private String verifySaveForm(User user) { if (user == null || StringUtils.isEmpty(user.getName())) { return '用戶名不能為空'; } else if (user.getPassword() == null) { return '密碼不能為空'; } return null; }}

下面用postman模擬一下請求:

新增用戶:

Spring Boot 整合 MongoDB的示例

查看Mongodb:

Spring Boot 整合 MongoDB的示例

更改數據,新增多個用戶:

Spring Boot 整合 MongoDB的示例

列表查詢:

Spring Boot 整合 MongoDB的示例

更改user:

Spring Boot 整合 MongoDB的示例

Spring Boot 整合 MongoDB的示例

刪除user:

Spring Boot 整合 MongoDB的示例

Spring Boot 整合 MongoDB的示例

好,到此為止,我們已經在SpringBoot項目中引入了MongoDB,并實現了基本的增刪改查操作,這將是我們使用MongoDB開發更加復雜的業務的基礎!

以上就是Spring Boot 整合 MongoDB的示例的詳細內容,更多關于Spring Boot 整合 MongoDB的資料請關注好吧啦網其它相關文章!

標簽: Spring
相關文章:
主站蜘蛛池模板: 紫外荧光硫分析仪-硫含量分析仪-红外光度测定仪-泰州美旭仪器 | 智能案卷柜_卷宗柜_钥匙柜_文件流转柜_装备柜_浙江福源智能科技有限公司 | 阿里巴巴诚信通温州、台州、宁波、嘉兴授权渠道商-浙江联欣科技提供阿里会员办理 | 回转炉,外热式回转窑,回转窑炉-淄博圣元窑炉工程有限公司 | 天津仓储物流-天津电商云仓-天津云仓一件代发-博程云仓官网 | 点焊机-缝焊机-闪光对焊机-电阻焊设备生产厂家-上海骏腾发智能设备有限公司 | 扬子叉车厂家_升降平台_电动搬运车|堆高车-扬子仓储叉车官网 | 棕刚玉-白刚玉厂家价格_巩义市东翔净水材料厂 | 恒温油槽-恒温水槽-低温恒温槽厂家-宁波科麦仪器有限公司 | 国资灵活用工平台_全国灵活用工平台前十名-灵活用工结算小帮手 | 蓄电池在线监测系统|SF6在线监控泄露报警系统-武汉中电通电力设备有限公司 | ?水马注水围挡_塑料注水围挡_防撞桶-常州瑞轩水马注水围挡有限公司 | 天津货架厂_穿梭车货架_重型仓储货架_阁楼货架定制-天津钢力仓储货架生产厂家_天津钢力智能仓储装备 | CTP磁天平|小电容测量仪|阴阳极极化_双液系沸点测定仪|dsj电渗实验装置-南京桑力电子设备厂 | 房在线-免费房产管理系统软件-二手房中介房屋房源管理系统软件 | 便携式表面粗糙度仪-彩屏硬度计-分体式粗糙度仪-北京凯达科仪科技有限公司 | 广东恩亿梯电源有限公司【官网】_UPS不间断电源|EPS应急电源|模块化机房|电动汽车充电桩_UPS电源厂家(恩亿梯UPS电源,UPS不间断电源,不间断电源UPS) | 深圳天际源广告-形象堆头,企业文化墙,喷绘,门头招牌设计制作专家 | 高效节能电机_伺服主轴电机_铜转子电机_交流感应伺服电机_图片_型号_江苏智马科技有限公司 | 郑州水质检测中心_井水检测_河南废气检测_河南中环嘉创检测 | 短信营销平台_短信群发平台_106短信发送平台-河南路尚 | 恒温振荡混匀器-微孔板振荡器厂家-多管涡旋混匀器厂家-合肥艾本森(www.17world.net) | 杰福伦_磁致伸缩位移传感器_线性位移传感器-意大利GEFRAN杰福伦-河南赉威液压科技有限公司 | 无负压供水设备,消防稳压供水设备-淄博创辉供水设备有限公司 | 活动策划,舞台搭建,活动策划公司-首选美湖上海活动策划公司 | 物流公司电话|附近物流公司电话上门取货 | 附着力促进剂-尼龙处理剂-PP处理剂-金属附着力处理剂-东莞市炅盛塑胶科技有限公司 | SOUNDWELL 编码器|电位器|旋转编码器|可调电位器|编码开关厂家-广东升威电子制品有限公司 | 深圳市万色印象美业有限公司 | 集装袋吨袋生产厂家-噸袋廠傢-塑料编织袋-纸塑复合袋-二手吨袋-太空袋-曹县建烨包装 | 不锈钢电动球阀_气动高压闸阀_旋塞疏水调节阀_全立阀门-来自温州工业阀门巨头企业 | 工业风机_环保空调_冷风机_工厂车间厂房通风降温设备旺成服务平台 | 七维官网-水性工业漆_轨道交通涂料_钢结构漆 | 哈尔滨治「失眠/抑郁/焦虑症/精神心理」专科医院排行榜-京科脑康免费咨询 一对一诊疗 | 江西自考网| RO反渗透设备_厂家_价格_河南郑州江宇环保科技有限公司 | 济南律师,济南法律咨询,山东法律顾问-山东沃德律师事务所 | 氢氧化钙设备_厂家-淄博工贸有限公司 | 楼承板-钢筋楼承板-闭口楼承板-无锡优贝斯楼承板厂 | 地脚螺栓_材质_标准-永年县德联地脚螺栓厂家 | 塑料异型材_PVC异型材_封边条生产厂家_PC灯罩_防撞扶手_医院扶手价格_东莞市怡美塑胶制品有限公司 |