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

可视化界面下载

https://robomongo.org

添加链接

1570758426787.png

1570758388556.png

代码示例

引入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);
 }

}