安装教程 window 二进制安装 创建文件夹
data/db
创建配置文件：mongod.conf

storage: dbPath: F:\Java\app\mongodb-win32-x86_64-2008plus-ssl-4.0.12\data

启动

.\bin\mongod.exe -f .\config\mongod.conf

文章图片

Linux安装
文章图片

mkdir -p data/db mkdir -p logs

编写配置文件：mongodb.conf

#增加如下配置 dbpath = /usr/local/mongodb/data/db #数据文件存放目录 logpath = /usr/local/mongodb/logs/mongodb.log #日志文件存放目录 port = 27017#端口 bind_ip = 0.0.0.0 fork = true#以守护程序的方式启用，即在后台运行

启动mongodb

/usr/local/mongodb/bin/mongod -f /usr/local/mongodb/mongodb.conf

使用教程

# 查看版本 db.version() # 查看所有数据库 show dbs; # 使用数据库 use admin; # 查看当前数据库 db # 关闭mongodb db.shutdownServer()

创建一个articletest数据库，并赋予全部权限

use articletest; # 插入一条数据 db.comment.insert({"articleId":"10000","content":"今天天气真好！","userId":"10001"}) # 切换到admin数据库 use admin; # 查看当前用户zkc 没有 show users; # 创建新的用户 db.createUser({user:"root",pwd:"A_dminjs#888",roles:[{role:"userAdminAnyDatabase",db:"admin"}]}) db.createUser({user:"testuser",pwd:"123456",roles:[{role:"readWrite",db:"admin"}]}) # 修改用户 db.updateUser("testuser", {"roles":[{"role":"userAdminAnyDatabase",db:"admin"} # 更新密码 db.updateUser("用户名", {"pwd":"新密码"}) db.changeUserPassword("用户名", "新密码") # 删除用户 db.dropUser("testuser") #验证是否有该用户 db.auth("testuser", "123456")

登录

mongo mongo IP:27017/admin -uroot -pA_dminjs#888

【中间件|Mongodb学习】
文章图片

Java程序调用mongodb pom.xml

org.springframework.boot spring-boot-starter-data-mongodb

配置文件 application.properties

#Mongodb数据源 spring.data.mongodb.host=localhost spring.data.mongodb.port=27017 spring.data.mongodb.username=root spring.data.mongodb.password=A_dminjs#888 spring.data.mongodb.authentication-database=admin spring.data.mongodb.database=articledbspring.servlet.multipart.max-file-size=100MB spring.servlet.multipart.max-request-size=100MB

创建pojo People

@Document("collection1") @Data public class People implements Serializable {@Id private String id; @Field("name") private String userName; private Integer age; }

MongoService

import java.util.List; public interface MongoService { //添加数据 public Boolean save(People people); //根据id查询 public People getById(String id); //查询全部 public List getAll(); //修改数据 public Boolean update(String id); }

MongoServiceImpl

package com.shengun.mongo.service.impl; import com.shengun.mongo.pojo.People; import com.shengun.mongo.service.MongoService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.mongodb.core.MongoTemplate; import org.springframework.data.mongodb.gridfs.GridFsTemplate; import org.springframework.stereotype.Service; import java.util.List; @Service public class MongoServiceImpl implements MongoService {@Autowired private MongoTemplate mongoTemplate; @Autowired private GridFsTemplate gridFsTemplate; @Override public Boolean save(People people) { People save = mongoTemplate.save(people); if(save == null){ return false; } return true; }@Override public People getById(String id) { People people = mongoTemplate.findById(id, People.class); return people; }@Override public List getAll() { List list = mongoTemplate.findAll(People.class); return list; }@Override public Boolean update(String id) { People people = mongoTemplate.findById(id, People.class); if(people != null){ people.setAge(200); People save = mongoTemplate.save(people); if(save == null){ return false; } } return true; } }

MongoController 添加数据

@GetMapping("/add") public R add(){ People people = new People(); people.setUserName("张三"); people.setAge(19); Boolean save = mongoService.save(people); return R.ok().data("flag", save); }

更新数据

@GetMapping("/update/{id}") public R update(@PathVariable String id){ Boolean update = mongoService.update(id); return R.ok().data("flag", update); }

删除数据

@GetMapping("/delete/{id}") public R delete(@PathVariable String id){ People people = new People(); people.setId(id); DeleteResult remove = mongoTemplate.remove(people); return R.ok().data("data", remove); }

根据年龄查询 数据

@GetMapping("/getByAge/{age}") public R getByAge(@PathVariable Integer age){ Query query = new Query(Criteria.where("age").gte(age)); List list = mongoTemplate.find(query, People.class); return R.ok().data("data", list); }

得到所有数据

@GetMapping("/getList") public R select(){ List all = mongoService.getAll(); return R.ok().data("list", all); }

存储图片和文件

@Autowired private GridFsTemplate gridFsTemplate; @PostMapping("/upload") public R upload(MultipartFile file) throws Exception{ log.info("############上传开始#############"); if(file == null){ return R.error().message("未上传文件"); } String originalFilename = file.getOriginalFilename(); InputStream inputStream = file.getInputStream(); String contentType = file.getContentType(); ObjectId store = gridFsTemplate.store(inputStream, originalFilename, contentType); log.info("############id####:" + store); log.info("############id####:" + store.toHexString()); return R.ok().data("id", store.toHexString()); }

获取图片

@GetMapping("/showing/{imgeId}") public void showImage(@PathVariable String imgeId, HttpServletResponse response) throws IOException { log.info("##############查询id:" + imgeId); Query id = new Query(Criteria.where("_id").is(imgeId)); GridFSFile result= gridFsTemplate.findOne(id); GridFsResource resource = gridFsTemplate.getResource(result); InputStream inputStream = resource.getInputStream(); response.setContentType("image/jpg"); IOUtils.copy(inputStream,response.getOutputStream()); }

获取pdf

@GetMapping("/showPdf/{pdfId}") public void showPdf(@PathVariable String pdfId, HttpServletResponse response) throws IOException { log.info("##############查询id:" + pdfId); Query id = new Query(Criteria.where("_id").is(pdfId)); GridFSFile result= gridFsTemplate.findOne(id); GridFsResource resource = gridFsTemplate.getResource(result); InputStream inputStream = resource.getInputStream(); //response.setContentType("image/jpg"); //response.setContentType("text/html"); response.setContentType("application/pdf"); IOUtils.copy(inputStream,response.getOutputStream()); }

根据大于并且小于查询

void range() { Query query = new Query(Criteria.where("age").gte(12).lte(14)); List list = mongoTemplate.find(query, People.class); list.forEach(System.out::println); }

根据正则查询（模糊查询）

void regex() { // java中正则不需要有// Query query = new Query(Criteria.where("name").regex("张")); List list = mongoTemplate.find(query, People.class); list.forEach(System.out::println); }

多添加查询

@Test void and() { Criteria c = new Criteria(); c.andOperator(Criteria.where("name").is("张三123"), Criteria.where("age").is(12)); Query query = new Query(c); List list = mongoTemplate.find(query, People.class); list.forEach(System.out::println); }

推荐阅读

• 

  redmi|再爆新品！Redmi Watch 2将于28日发布 这次有点猛！
• 

  长沙跨境电商公司 长沙电商平台众联什么样，长沙比较大的电商公司有哪些
• 

  香榧吃了会不会胖 香榧相关介绍
• 

  如何解决人脸识别服务器超时问题？ 人脸识别服务器超时怎么办
• 

  贫血吃什么
• 

  违章代码1355是什么意思
• 

  财务报表分析程序
• 

  学什么舞蹈能提升气质
• 

  云朵简笔画 云朵简笔画怎么画
• 

  别客气用英语怎么说 welcome
• 

  分布式理论
• 

  golang获取命令行参数方法总结
• 

  玻尿酸丰胸多少钱_玻尿酸丰胸和假体丰胸哪种好
• 

  四年级我就这样长大了作文3篇
• 

  QQ飞车手游荣耀勋章第9期车大全：荣耀勋章第九期全部奖励总汇
• 

  唐朝皇帝后宫女人等级是如何，唐朝宫女等级制度
• 

  刚做完流产已经三天没吃饭只喝点水解
• 

  喊山红霞被判几年
• 

  gis罐体外卡式，gis罐体常用材料
• 

  大巴车载客人数 中型客车核载多少人

• MongoDB Atlas云服务
• Java MongoDB连接操作实例
• Redis与MongoDB有什么区别（）
• CouchDB与MongoDB有什么区别（）
• Cassandra和MongoDB的区别和比较
• MongoDB sort()方法
• MongoDB limit()方法
• MongoDB更新文件
• MongoDB查询文件