一、MongoDB
- MongoDB是一个基于分布式文件存储 [1] 的数据库。由C++语言编写。旨在为WEB应用提供可扩展的高性能数据存储解决方案。
- MongoDB是一个介于关系数据库和非关系数据库之间的产品,是非关系数据库当中功能最丰富,最像关系数据库的。它支持的数据结构非常松散,是类似json的bson格式,因此可以存储比较复杂的数据类型。Mongo最大的特点是它支持的查询语言非常强大,其语法有点类似于面向对象的查询语言,几乎可以实现类似关系数据库单表查询的绝大部分功能,而且还支持对数据建立索引。
- 安装:
- linux 安装 MongoDB:传送门
- Docker 安装 MongoDB:传送门
二、MongoDB 引入使用
2.1、pom 文件 添加依赖
<!-- mongodb -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>
2.2、修改 application.yml 配置,添加Redis 配置
# 应用服务 WEB 访问端口
server:
port: 8801
spring:
# mongodb 配置
data:
mongodb:
host: **.**.**.**
port: 8893
username: admin
password: admin
database: admin
2.3、添加 MongoDBController 测试
package cn.piesat.testdemo.controller;
import com.alibaba.druid.support.json.JSONUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.data.mongodb.core.query.Update;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.*;
@RestController
@RequestMapping("/mongo")
public class MongoDBController {
@Autowired
public MongoTemplate mongoTemplate;
@GetMapping("/save")
public String save() {
Map<String, Object> map = new HashMap<>();
map.put("_id", "id_1");
map.put("name", "王京");
map.put("age", "18");
this.mongoTemplate.save(map, "collectionName1");
return "新增成功";
}
@GetMapping("/remove")
public String remove() {
Query query = new Query();
query.addCriteria(Criteria.where("_id").is("id_1"));
mongoTemplate.remove(query, Map.class, "collectionName1");
return "删除成功";
}
@GetMapping("/update")
public String update() {
Query query = new Query();
query.addCriteria(Criteria.where("_id").is("id_1"));
Update update = new Update();
update.set("age", "120");
mongoTemplate.upsert(query, update, Map.class, "collectionName1");
return "更新成功";
}
@GetMapping("/getCollectionNames")
public String getCollectionNames() {
Set<String> set = this.mongoTemplate.getCollectionNames();
return JSONUtils.toJSONString(set);
}
@GetMapping("/getOne")
public String getOne() {
Query query = new Query();
query.addCriteria(Criteria.where("_id").is("id_1"));
Map resutl = this.mongoTemplate.findOne(query, Map.class, "collectionName1");
return JSONUtils.toJSONString(resutl);
}
@GetMapping("/list")
public String list() {
Query query = new Query();
query.addCriteria(Criteria.where("name").is("王京"));
List<Map> maps = mongoTemplate.find(query, Map.class, "collectionName1");
List<Map> all = mongoTemplate.findAll(Map.class);
System.out.println(JSONUtils.toJSONString(all));
return JSONUtils.toJSONString(maps);
}
}
2.4、启动项目,访问接口测试
新增:http://localhost:8802/mongo/save
查询:http://localhost:8802/mongo/list 注:以上内容仅提供参考和交流,请勿用于商业用途,如有侵权联系本人删除!