既然有MySQL了，为什么还要有MongoDB？

大家好，我是哪吒，最近项目在使用MongoDB作为图片和文档的存储数据库，为啥不直接存MySQL里，还要搭个MongoDB集群，麻不麻烦？

让我们一起，一探究竟，了解一下MongoDB的特点和基本用法，实现快速入门，丰富个人简历，提高面试level，给自己增加一点谈资，秒变面试小达人，BAT不是梦。

三分钟你将学会：

1. MongoDB主要特征
2. MongoDB优缺点，扬长避短
3. 何时选择MongoDB？为啥要用它？
4. MongoDB与MySQL关键字对比
5. 下载与安装过程中一些常见的坑
6. Java整合MongoDB，实现农民工增删改查

一、基本概念走起

MongoDB是一款开源、跨平台、分布式，具有大数据处理能力的文档存储数据库。

文档数据库MongoDB用于记录文档结构的数据，比如JSON、XML结构的数据。

二、MongoDB的主要特征

1. 高性能。提供JSON、XML等可嵌入数据快速处理功能，提供文档的索引功能，以提高查询速度；
2. 丰富的查询语言。为数据聚合、结构文档、地理空间提供丰富的查询功能；
3. 高可用性。提供自动故障转移和数据冗余处理功能；
4. 水平扩展能力。提供基于多服务器集群的分布式数据处理能力，具体处理时分「主从」和「权衡」（基于Hash自动推选）两种处理模式；
5. 支持多种存储引擎。MongoDB提供多种存储引擎，WiredTiger引擎、MMAPv1引擎是基于硬盘读写的存储引擎，In-Memory引擎是基于内存的存储引擎；

三、MongoDB优缺点，扬长避短

1. Free-schema无模式文档，适应非结构化数据存储；
2. 内置GridFS，支持大容量的存储；
3. 内置Sharding，分片简单
4. 弱一致性（最终一致），更能保证用户的访问速度;
5. 查询性能优越，对于千万级别的文档对象，差不多10个G，对有索引的ID的查询不会比MySQL慢，而对非索引字段的查询，则是完胜MySQL;
6. 聚合框架，它支持典型几种聚合操作 , 比如，Aggregate pipelien, Map-Reduce等；
7. 支持自动故障恢复

1. 太吃内存，快是有原因的，因为MongoDB把数据都放内存里了；
2. 对事务的支持不够友好；
3. 占用空间过大；
4. 对联表查询的支持不够强大；
5. 只有最终一致性，言外之意，就是可能造成数据的不一致，如果想要保持强一致性，必须在一个服务器处理所有的读写操作，坑；
6. 复杂聚合操作通过mapreduce创建，速度慢
7. Mongodb全局锁机制也是个坑；
8. 预分配模式会带来的磁盘瓶颈；
9. 删除记录时不会释放空间，相当于逻辑删除，这个真的坑；
10. MongoDB到现在为止，好像还没有太好用的客户端工具；

四、何时选择MongoDB？为啥要用它？

MongoDB目前只支持单文档事务，MongoDB暂时不适合需要复杂事务的场景。灵活的文档模型JSON格式存储最接近真实对象模型，对开发者友好，方便快速开发迭代，可用复制集满足数据高可靠、高可用的需求，运维较为简单、故障自动切换可扩展分片集群海量数据存储。

• 支持地理位置索引
• 可用于构建各种O2O应用
• 文本索引解决搜索的需求
• TTL索引解决历史数据过期的需求
• Gridfs解决文件存储的需求
• aggregation mapreduce解决数据分析场景需求，可以自己写查询语句或脚本，将请求分发到 MongoDB 上完成。

传统的关系型数据库在解决三高问题上的力不从心。何为三高？

• High performance - 对数据库高并发读写的需求。
• Huge Storage - 对海量数据的高效率存储和访问的需求。
• High Scalability High Availability- 对数据库的高可扩展性和高可用性的需求。

MongoDB可以完美解决三高问题。

（1）游戏场景

使用MongoDB存储游戏用户信息、装备、积分等，直接以内嵌文档的形式存储，方便查询、更新。

（2）物流场景

使用MongoDB存储订单信息、订单状态、物流信息，订单状态在运送过程中飞速迭代、以MongoDB内嵌数组的形式来存储，一次查询就能将订单所有的变更查出来，牛逼plus。

（3）社交场景

使用MongoDB存储用户信息，朋友圈信息，通过地理位置索引实现附近的人、定位功能。

（4）物联网场景

使用MongoDB存储设备信息、设备汇报的日志信息、并对这些信息进行多维度分析。

（5）视频直播

使用MongoDB存储用户信息、点赞互动信息。

• 数据量大
• 读写操作频繁
• 数据价值较低，对事务要求不高

五、MongoDB与MySQL关键字对比

MySQL	MongoDB	解释说明
database	database	数据库
table	collection	表/集合
row	document	行/文档
column	field	字段/域
index	index	索引
join	嵌入文档	表关联/MongoDB不支持join，MongoDB通过嵌入式文档来替代多表连接
primary key	primary key	主键/MongoDB自动将_id字段设置为主键

集合就是一组文档。可以看作是具有动态模式的表。

集合具有动态模式的特性。这意味着一个集合中的文档可以具有任意数量的不同形态。

但是，将不同类型的文档存放在一个集合中会出现很多问题：

1. 文档中可以存放任意类型的变量，但是，这里不建议将不同类型的文档保存在同一个集合中，开发人员需要确保每个查询只返回特定模式的文档，或者确保执行查询的应用程序代码可以处理不同类型的文档；
2. 获取集合列表比提取集合中的文档类型列表要快得多，减少磁盘查找次数；
3. 相同类型的文档存放在同一个集合中可以实现数据的局部性，对于集合，让使用者见文知意；
4. 集合中只存放单一类型的文档，可以更高效地对集合进行索引；

1. 集合名称中不能是空字符串；
2. 集合名称不能包含\0（空字符），因为这个字符用于表示一个集合名称的结束；
3. 集合名称不能以system.开头，该前缀是为内部集合保留的。
4. 集合名称不能有$，只能在某些特定情况下使用。通常情况下，可以认为这两个字符是MongoDB的保留字符，如果使用不当，那么驱动程序将无法正常工作。

文档是MongoDB中的基本数据单元，相当于传统关系型数据库中的行，它是一组有序键值的集合。每个文档都有一个特殊的键“_id”，其在所属的集合中是唯一的。

文档中的键是字符串类型。

键中不能含有\0（空字符）。这个字符用于表示一个键的结束。.和$是特殊字符，只能在某些特定情况下使用。通常情况下，可以认为这两个字符是MongoDB的保留字符，如果使用不当，那么驱动程序将无法正常工作。

数据库会使用游标返回find的执行结果。游标的客户端实现通常能够在很大程度上对查询的最终输出进行控制。你可以限制结果的数量，跳过一些结果，按任意方向的任意键组合对结果进行排序，以及执行许多其他功能强大的操作。

通过cursor.hasNext()检查是否还有其它结果，通过cursor.next()用来对其进行获取。

调用find()时，shell并不会立即查询数据库，而是等到真正开始请求结果时才发送查询，这样可以在执行之前给查询附加额外的选项。cursor对象的大多数方法会返回游标本身，这样就可以按照任意顺序将选项链接起来了。

在使用db.users.find();查询时，实际上查询并没有真正执行，只是在构造查询，执行cursor.hasNext()，查询才会发往服务器端。shell会立刻获取前100个结果或者前4MB的数据（两者之中的较小者），这样下次调用next或者hasNext时就不必再次连接服务器去获取结果了。在客户端遍历完第一组结果后，shell会再次连接数据库，使用getMore请求更多的结果。getMore请求包含一个游标的标识符，它会向数据库询问是否还有更多的结果，如果有则返回下一批结果。这个过程会一直持续，直到游标耗尽或者结果被全部返回。

在服务器端，游标会占用内存和资源。一旦游标遍历完结果之后，或者客户端发送一条消息要求终止，数据库就可以释放它正在使用的资源。

何时销毁游标：

1. 当游标遍历完匹配的结果时，它会消除自身；
2. 当游标超出客户端的作用域时，驱动程序会向数据库发送一条特殊的消息，让数据库终止该游标；
3. 如果10分钟没有被使用的话，数据库游标也将自动销毁；

六、下载与安装过程中一些常见的坑

下载zip文件，解压，在bin同级目录下建data文件夹，在data下建一个db文件夹，存储MongoDB数据。

在bin文件夹下执行cmd，执行mongod --dbpath D:\Program Files\mongodb\data\db命令；

再在data目录下，建一个logs文件夹，存放MongoDB日志。

在mongodb/bin目录下，建一个mongod.cfg文件，写入

systemLog:
destination:file
logAppend:true
path:D:\ProgramFiles\mongodb\data\logs\mongod.log
storage:
dbPath:D:\ProgramFiles\mongodb\data\db

执行mongod --config "D:\Program Files\mongodb\bin\mongod.cfg" --install命令，安装MongoDB。

通过mongod --version检查MongoDB版本。

D:\ProgramFiles\mongodb\bin>mongod--version
dbversionv5.0.14
BuildInfo:{
"version":"5.0.14",
"gitVersion":"1b3b0073a0b436a8a502b612f24fb2bd572772e5",
"modules":[],
"allocator":"tcmalloc",
"environment":{
"distmod":"windows",
"distarch":"x86_64",
"target_arch":"x86_64"
}
}

突然间，mongodb无法连接了？mongod.exe --dbpath "D:\Program Files\mongodb\data完美解决。

注意一点，在重新启动时，执行mongod.exe --dbpath "D:\Program Files\mongodb\data的窗口不要关闭。

七、Java整合MongoDB，实现农民工增删改查

<dependency>
<groupId>org.mongodb</groupId>
<artifactId>mongo-java-driver</artifactId>
<version>3.8.2</version>
</dependency>

packagecom.example.demo.utils;

importjava.util.ArrayList;
importjava.util.List;
importjava.util.Map;

importorg.bson.Document;
importorg.bson.conversions.Bson;

importcom.mongodb.MongoClient;
importcom.mongodb.MongoCredential;
importcom.mongodb.ServerAddress;
importcom.mongodb.client.FindIterable;
importcom.mongodb.client.MongoCollection;
importcom.mongodb.client.MongoCursor;
importcom.mongodb.client.MongoDatabase;
importcom.mongodb.client.model.Filters;

publicclassMongoDBUtil{

privatestaticMongoClientmongoClient;

privatestaticMongoClientmongoClientIdentify;

/**
*不通过认证获取连接数据库对象
*/
publicstaticMongoDatabasegetNoIdentifyConnect(Stringhost,intport,StringdbaseName){
//连接mongodb服务
MongoDBUtil.mongoClient=newMongoClient(host,port);

//连接数据库
MongoDatabasemongoDatabase=MongoDBUtil.mongoClient.getDatabase(dbaseName);

//返回连接数据库对象
returnmongoDatabase;
}

/**
*通过连接认证获取MongoDB连接
*/
publicstaticMongoDatabasegetIdentifyConnect(Stringhost,intport,StringdbaseName,StringuserName,Stringpassword){

List<ServerAddress>adds=newArrayList<ServerAddress>();

ServerAddressserverAddress=newServerAddress(host,port);
adds.add(serverAddress);

List<MongoCredential>credentials=newArrayList<>();

MongoCredentialmongoCredential=MongoCredential.createScramSha1Credential(userName,dbaseName,password.toCharArray());
credentials.add(mongoCredential);

//通过连接认证获取MongoDB连接
MongoDBUtil.mongoClientIdentify=newMongoClient(adds,credentials);

MongoDatabasemongoDatabase=MongoDBUtil.mongoClientIdentify.getDatabase(dbaseName);

returnmongoDatabase;
}

/**
*关闭连接
*/
publicstaticvoidcloseNoIdentifyConnect(){
MongoDBUtil.mongoClient.close();
}

/**
*关闭连接
*/
publicstaticvoidcloseIdentifyConnect(){
MongoDBUtil.mongoClientIdentify.close();
}

/**
*插入一个文档
*/
publicstaticvoidinsertOne(Map<String,Object>data,MongoDatabasemongoDatabase,Stringcol){
//获取集合
MongoCollection<Document>collection=mongoDatabase.getCollection(col);

//创建文档
Documentdocument=newDocument();

for(Map.Entry<String,Object>m:data.entrySet()){
document.append(m.getKey(),m.getValue()).append(m.getKey(),m.getValue());
}

//插入一个文档
collection.insertOne(document);
}

/**
*插入多个文档
*/
publicstaticvoidinsertMany(List<Map<String,Object>>listData,MongoDatabasemongoDatabase,Stringcol){
//获取集合
MongoCollection<Document>collection=mongoDatabase.getCollection(col);

//要插入的数据
List<Document>list=newArrayList<>();
for(Map<String,Object>data:listData){
//创建文档
Documentdocument=newDocument();

for(Map.Entry<String,Object>m:data.entrySet()){
document.append(m.getKey(),m.getValue());
}
list.add(document);
}

//插入多个文档
collection.insertMany(list);
}

/**
*删除匹配到的第一个文档
*/
publicstaticvoiddelectOne(Stringcol,Stringkey,Objectvalue,MongoDatabasemongoDatabase){
//获取集合
MongoCollection<Document>collection=mongoDatabase.getCollection(col);
//申明删除条件
Bsonfilter=Filters.eq(key,value);
//删除与筛选器匹配的单个文档
collection.deleteOne(filter);
}

/**
*删除匹配的所有文档
*/
publicstaticvoiddeleteMany(Stringcol,Stringkey,Objectvalue,MongoDatabasemongoDatabase){
//获取集合
MongoCollection<Document>collection=mongoDatabase.getCollection(col);
//申明删除条件
Bsonfilter=Filters.eq(key,value);
//删除与筛选器匹配的所有文档
collection.deleteMany(filter);
}

/**
*删除集合中所有文档
*/
publicstaticvoiddeleteAllDocument(Stringcol,MongoDatabasemongoDatabase){
//获取集合
MongoCollection<Document>collection=mongoDatabase.getCollection(col);
collection.deleteMany(newDocument());
}

/**
*删除文档和集合。
*/
publicstaticvoiddeleteAllCollection(Stringcol,MongoDatabasemongoDatabase){
//获取集合
MongoCollection<Document>collection=mongoDatabase.getCollection(col);
collection.drop();
}

/**
*修改单个文档，修改过滤器筛选出的第一个文档
*
*@paramcol修改的集合
*@paramkey修改条件的键
*@paramvalue修改条件的值
*@parameqKey要修改的键，如果eqKey不存在，则新增记录
*@parameqValue要修改的值
*@parammongoDatabase连接数据库对象
*/
publicstaticvoidupdateOne(Stringcol,Stringkey,Objectvalue,StringeqKey,ObjecteqValue,MongoDatabasemongoDatabase){
//获取集合
MongoCollection<Document>collection=mongoDatabase.getCollection(col);
//修改过滤器
Bsonfilter=Filters.eq(key,value);
//指定修改的更新文档
Documentdocument=newDocument("$set",newDocument(eqKey,eqValue));
//修改单个文档
collection.updateOne(filter,document);
}

/**
*修改多个文档
*
*@paramcol修改的集合
*@paramkey修改条件的键
*@paramvalue修改条件的值
*@parameqKey要修改的键，如果eqKey不存在，则新增记录
*@parameqValue要修改的值
*@parammongoDatabase连接数据库对象
*/
publicstaticvoidupdateMany(Stringcol,Stringkey,Objectvalue,StringeqKey,ObjecteqValue,MongoDatabasemongoDatabase){
//获取集合
MongoCollection<Document>collection=mongoDatabase.getCollection(col);
//修改过滤器
Bsonfilter=Filters.eq(key,value);
//指定修改的更新文档
Documentdocument=newDocument("$set",newDocument(eqKey,eqValue));
//修改多个文档
collection.updateMany(filter,document);
}

/**
*查找集合中的所有文档
*/
publicstaticMongoCursor<Document>find(Stringcol,MongoDatabasemongoDatabase){
//获取集合
MongoCollection<Document>collection=mongoDatabase.getCollection(col);
//查找集合中的所有文档
FindIterable<Document>findIterable=collection.find();
MongoCursor<Document>cursorIterator=findIterable.iterator();
returncursorIterator;
}

/**
*按条件查找集合中文档
*/
publicstaticMongoCursor<Document>Filterfind(Stringcol,Stringkey,Objectvalue,MongoDatabasemongoDatabase){
//获取集合
MongoCollection<Document>collection=mongoDatabase.getCollection(col);
//指定查询过滤器
Bsonfilter=Filters.eq(key,value);

//指定查询过滤器查询
FindIterable<Document>findIterable=collection.find(filter);
MongoCursor<Document>cursorIterator=findIterable.iterator();
returncursorIterator;
}
}

<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
</dependency>

packagecom.example.demo.utils;

importcom.mongodb.client.MongoCursor;
importcom.mongodb.client.MongoDatabase;
importorg.bson.Document;
importorg.junit.Test;

importjava.util.ArrayList;
importjava.util.HashMap;
importjava.util.List;
importjava.util.Map;

publicclassMongoDBTest{

//获取数据库连接对象
MongoDatabasemongoDatabase=MongoDBUtil.getNoIdentifyConnect("127.0.0.1",27017,"test");

@Test
publicvoidinsertOne(){
Map<String,Object>map=newHashMap<String,Object>();
map.put("姓名","哪吒编程");
map.put("性别","男");
map.put("年龄",18);
MongoDBUtil.insertOne(map,mongoDatabase,"worker");
MongoDBUtil.closeNoIdentifyConnect();
}

@Test
publicvoidinsertMany(){
Map<String,Object>map1=newHashMap<String,Object>();
map1.put("姓名","哪吒编程2");
map1.put("性别","男");
map1.put("年龄",18);
Map<String,Object>map2=newHashMap<String,Object>();
map2.put("姓名","妲己");
map2.put("性别","女");
map2.put("年龄",18);
List<Map<String,Object>>listData=newArrayList<>();
listData.add(map1);
listData.add(map2);
MongoDBUtil.insertMany(listData,mongoDatabase,"worker");
MongoDBUtil.closeNoIdentifyConnect();
}

@Test
publicvoiddelectOne(){
MongoDBUtil.delectOne("worker","姓名","妲己",mongoDatabase);

MongoDBUtil.closeNoIdentifyConnect();
}

@Test
publicvoiddeleteMany(){

MongoDBUtil.deleteMany("worker","姓名","哪吒编程",mongoDatabase);
MongoDBUtil.deleteMany("worker","姓名","妲己",mongoDatabase);

MongoDBUtil.closeNoIdentifyConnect();
}

@Test
publicvoiddeleteAllDocument(){
MongoDBUtil.deleteAllDocument("worker",mongoDatabase);

MongoDBUtil.closeNoIdentifyConnect();
}

@Test
publicvoiddeleteAllCollection(){

MongoDBUtil.deleteAllCollection("worker",mongoDatabase);

MongoDBUtil.closeNoIdentifyConnect();
}

@Test
publicvoidupdateOne(){

MongoDBUtil.updateOne("worker","姓名","哪吒编程2","姓名","哪吒编程",mongoDatabase);

MongoDBUtil.closeNoIdentifyConnect();
}

@Test
publicvoidupdateMany(){

MongoDBUtil.updateMany("worker","姓名","哪吒编程2","姓名","哪吒编程",mongoDatabase);

MongoDBUtil.closeNoIdentifyConnect();
}

@Test
publicvoidfind(){
MongoCursor<Document>mongoCursor=MongoDBUtil.find("worker",mongoDatabase);

while(mongoCursor.hasNext()){
Documentdocument=mongoCursor.next();
System.out.println(document+"size:"+document.size());
}
MongoDBUtil.closeNoIdentifyConnect();
}

@Test
publicvoidfilterfind(){
MongoCursor<Document>mongoCursor=MongoDBUtil.Filterfind("worker","姓名","哪吒编程",mongoDatabase);

while(mongoCursor.hasNext()){
Documentdocument=mongoCursor.next();
System.out.println(document+"size:"+document.size());
}
MongoDBUtil.closeNoIdentifyConnect();
}
}