MongoDB
简介与下载安装
什么是MongoDB ?
MongoDB 是由C++语言编写的，是一个基于分布式文件存储的开源数据库系统。
在高负载的情况下，添加更多的节点，可以保证服务器性能。
MongoDB 旨在为WEB应用提供可扩展的高性能数据存储解决方案。
MongoDB 将数据存储为一个文档，数据结构由键值(key=>value)对组成。MongoDB 文档类似于 JSON 对象。字段值可以包含其他文档，数组及文档数组。
主要特点
MongoDB 是一个面向文档存储的数据库，操作起来比较简单和容易。
你可以在MongoDB记录中设置任何属性的索引 (如：FirstName="Sameer",Address="8 Gandhi Road")来实现更快的排序。
你可以通过本地或者网络创建数据镜像，这使得MongoDB有更强的扩展性。
如果负载的增加（需要更多的存储空间和更强的处理能力） ，它可以分布在计算机网络中的其他节点上这就是所谓的分片。
Mongo支持丰富的查询表达式。查询指令使用JSON形式的标记，可轻易查询文档中内嵌的对象及数组。
MongoDb 使用update()命令可以实现替换完成的文档（数据）或者一些指定的数据字段 。
Mongodb中的Map/reduce主要是用来对数据进行批量处理和聚合操作。
Map和Reduce。Map函数调用emit(key,value)遍历集合中所有的记录，将key与value传给Reduce函数进行处理。
Map函数和Reduce函数是使用Javascript编写的，并可以通过db.runCommand或mapreduce命令来执行MapReduce操作。
GridFS是MongoDB中的一个内置功能，可以用于存放大量小文件。
MongoDB允许在服务端执行脚本，可以用Javascript编写某个函数，直接在服务端执行，也可以把函数的定义存储在服务端，下次直接调用即可。
下载：
https://www.mongodb.com/download-center/community 下载地址
https://docs.mongodb.com/manual/tutorial/install-mongodb-enterprise-on-windows/
基本命令：
--> show dbs
admin 0.000GB config 0.000GB local 0.000GB
-- > db
test
-- > use local 使用某个库
switched to db loacl
use spring 创建数据库
有一些数据库名是保留的，可以直接访问这些有特殊作用的数据库。
admin： 从权限的角度来看，这是"root"数据库。要是将一个用户添加到这个数据库，这个用户自动继承所有数据库的权限。一些特定的服务器端命令也只能从这个数据库运行，比如列出所有的数据库或者关闭服务器。
local: 这个数据永远不会被复制，可以用来存储限于本地单台服务器的任意集合
config: 当Mongo用于分片设置时，config数据库在内部使用，用于保存分片的相关信息。
MongoDB 数据类型
下表为MongoDB中常用的几种数据类型。
| 数据类型 | 描述 |
|---|---|
| String | 字符串。存储数据常用的数据类型。在 MongoDB 中，UTF-8 编码的字符串才是合法的。 |
| Integer | 整型数值。用于存储数值。根据你所采用的服务器，可分为 32 位或 64 位。 |
| Boolean | 布尔值。用于存储布尔值（真/假）。 |
| Double | 双精度浮点值。用于存储浮点值。 |
| Min/Max keys | 将一个值与 BSON（二进制的 JSON）元素的最低值和最高值相对比。 |
| Array | 用于将数组或列表或多个值存储为一个键。 |
| Timestamp | 时间戳。记录文档修改或添加的具体时间。 |
| Object | 用于内嵌文档。 |
| Null | 用于创建空值。 |
| Symbol | 符号。该数据类型基本上等同于字符串类型，但不同的是，它一般用于采用特殊符号类型的语言。 |
| Date | 日期时间。用 UNIX 时间格式来存储当前日期或时间。你可以指定自己的日期时间：创建 Date 对象，传入年月日信息。 |
| Object ID | 对象 ID。用于创建文档的 ID。 |
| Binary Data | 二进制数据。用于存储二进制数据。 |
| Code | 代码类型。用于在文档中存储 JavaScript 代码。 |
| Regular expression | 正则表达式类型。用于存储正则表达式。 |
示例
docker上安装
# 搜索MongoDB
docker search mongodb
# 拉镜像
docker pull docker.io/mongo
# 运行
docker run -d -p 27017:27017 docker.io/mongo
# 进入容器
docker exec -it d0e24f024974 /bin/sh
# 使用MongoDB
mongo
可视化界面下载
添加链接
代码示例
引入jar
<!-- 对MongoDB的支持 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>
开启对MongoDB的支持
@SpringBootApplication
@EnableMongoRepositories
public class Ch8Application {
public static void main(String[] args) {
SpringApplication.run(Ch8Application.class, args);
}
}
DTO与MongoDB映射
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;
import org.springframework.data.mongodb.core.mapping.Field;
import java.util.Collection;
import java.util.LinkedHashSet;
/**
* @description: 与MongoDB使用测试
*
* @author: ShenShuaihu
* @version: 1.0
* @data: 2019-10-10 15:05
*/
@Document
@Data
@AllArgsConstructor
@NoArgsConstructor
public class PersonMongo {
/**
* 文档ID
*/
@Id
private String id;
private String name;
private Integer age;
/**
* 文档中命名为locs，locations属性以数组形式存在当前数据中，即同另外一种名字来命名数据
*/
@Field("locs")
private Collection<Location> locations = new LinkedHashSet<Location>();
}
Repository操作数据库
类似于jpa
import com.ch8.domain.PersonMongo;
import org.springframework.data.mongodb.repository.MongoRepository;
import org.springframework.data.mongodb.repository.Query;
import java.util.List;
/**
* @description:
*
* @author: Shenshuaihu
* @version: 1.0
* @data: 2019-08-15 16:46
*/
public interface PersonMongoRepository extends MongoRepository<PersonMongo, String> {
PersonMongo findByName(String name);
/**
* 查询参数构造JSON字符串即可
* @param age
* @return
*/
@Query("{'age': ?0}")
List<PersonMongo> withQueryFindByAge(Integer age);
}
控制器的请求
@RestController
public class CacheController {
@Autowired
private PersonMongoRepository personMongoRepository;
/**
* 以下是对MongoDB的数据测试
*/
@RequestMapping("/save/personDoc")
public PersonMongo save() {
PersonMongo personMongo = new PersonMongo();
personMongo.setName("沈帅虎");
personMongo.setAge(18);
Collection<Location> locations = new LinkedHashSet<Location>();
Location location1 = new Location("郑州", "2018");
Location location2 = new Location("上海", "2018");
Location location3 = new Location("北京", "2019");
locations.add(location1);
locations.add(location2);
locations.add(location3);
personMongo.setLocations(locations);
return personMongoRepository.save(personMongo);
}
@RequestMapping("/findByName/personDoc")
public PersonMongo findByName(String name) {
return personMongoRepository.findByName(name);
}
@RequestMapping("/withQueryFindByAge/personDoc")
public List<PersonMongo> withQueryFindByAge(Integer age) {
return personMongoRepository.withQueryFindByAge(age);
}
}
测试：
保存
http://127.0.0.1:8888/save/personDoc
通过名字查询
http://127.0.0.1:8888/findByName/personDoc?name=%E6%B2%88%E5%B8%85%E8%99%8E
通过年龄查询
http://127.0.0.1:8888/withQueryFindByAge/personDoc?age=18
2019/5/14 创建于成都
2019/11/10 完善于成都
