<返回更多

有MySQL了，为什么还硬要搭个MongoDB集群？

2023-05-24    dbaplus社群
加入收藏

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

让我们一探究竟，了解一下MongoDB的特点和基本用法。

三分钟你将学会：

一、基本概念

MongoDB是一款开源、跨平台、分布式，具有大数据处理能力的文档存储数据库。文档数据库MongoDB用于记录文档结构的数据，比如JSON、XML结构的数据。

二、MongoDB的主要特征

三、MongoDB的优缺点

1、优点

2、缺点

四、何时选择MongoDB？

为啥要用它？

MongoDB事务

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

多引擎支持各种强大的索引需求

支持地理位置索引

可用于构建各种O2O应用

文本索引解决搜索的需求

TTL索引解决历史数据过期的需求

Gridfs解决文件存储的需求

aggregation & mapreduce解决数据分析场景需求，可以自己写查询语句或脚本，将请求分发到 MongoDB 上完成。

具体的应用场景

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

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

以下是几个实际的应用案例：

1）游戏场景

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

2）物流场景

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

3）社交场景

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

4）物联网场景

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

5）视频直播

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

选择MongoDB的场景总结

五、MongoDB与MySQL关键字对比

关键字对比

集合相当于MySQL中的表

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

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

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

集合的命名

文档相当于MySQL中的行

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

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

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

游标

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

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

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

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

游标的生命周期

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

何时销毁游标：

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

1、下载地址：

https://www.mongodb.com/try/download/community2

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

在bin文件夹下执行cmd，执行mongod --dbpath D:Program Filesmongodbdatadb命令；

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

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

systemLog:

destination: file

logAppend: true

path: D:Program Filesmongodbdatalogsmongod.log

storage:

dbPath: D:Program Filesmongodbdatadb

执行mongod --config "D:Program Filesmongodbbinmongod.cfg" --install 命令，安装MongoDB。

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

D:Program Filesmongodbbin>mongod --version

db version v5.0.14

Build Info: {

"version": "5.0.14",

"gitVersion": "1b3b0073a0b436a8a502b612f24fb2bd572772e5",

"modules": [],

"allocator": "tcmalloc",

"environment": {

"distmod": "windows",

"distarch": "x86_64",

"target_arch": "x86_64"

}

}

2、mongodb由于目标计算机积极拒绝，无法连接

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

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

3、由于找不到vcruntime140_1.dll,无法继续执行代码

下载vcruntime140_1.dll文件；

将vcruntime140_1.dll文件拷贝到C:WindowsSystem32即可。

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

加入POM

<dependency>

<groupId>org.mongodb</groupId>

<artifactId>mongo-java-driver</artifactId>

<version>3.8.2</version>

</dependency>

MongoDBUtil工具类

package com.example.demo.utils;

import java.util.ArrayList;

import java.util.List;

import java.util.Map;

import org.bson.Document;

import org.bson.conversions.Bson;

import com.mongodb.MongoClient;

import com.mongodb.MongoCredential;

import com.mongodb.ServerAddress;

import com.mongodb.client.FindIterable;

import com.mongodb.client.MongoCollection;

import com.mongodb.client.MongoCursor;

import com.mongodb.client.MongoDatabase;

import com.mongodb.client.model.Filters;

public class MongoDBUtil {

private static MongoClient mongoClient;

private static MongoClient mongoClientIdentify;

/**

* 不通过认证获取连接数据库对象

*/

public static MongoDatabase getNoIdentifyConnect(String host, int port, String dbaseName) {

// 连接mongodb服务

MongoDBUtil.mongoClient = new MongoClient(host, port);

// 连接数据库

MongoDatabase mongoDatabase = MongoDBUtil.mongoClient.getDatabase(dbaseName);

// 返回连接数据库对象

return mongoDatabase;

}

/**

* 通过连接认证获取MongoDB连接

*/

public static MongoDatabase getIdentifyConnect(String host, int port, String dbaseName, String userName, String password) {

List<ServerAddress> adds = new ArrayList<ServerAddress>();

ServerAddress serverAddress = new ServerAddress(host, port);

adds.add(serverAddress);

List<MongoCredential> credentials = new ArrayList<>();

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

credentials.add(mongoCredential);

// 通过连接认证获取MongoDB连接

MongoDBUtil.mongoClientIdentify = new MongoClient(adds, credentials);

MongoDatabase mongoDatabase = MongoDBUtil.mongoClientIdentify.getDatabase(dbaseName);

return mongoDatabase;

}

/**

* 关闭连接

*/

public static void closeNoIdentifyConnect () {

MongoDBUtil.mongoClient.close();

}

/**

* 关闭连接

*/

public static void closeIdentifyConnect () {

MongoDBUtil.mongoClientIdentify.close();

}

/**

* 插入一个文档

*/

public static void insertOne (Map<String, Object> data, MongoDatabase mongoDatabase, String col) {

//获取集合

MongoCollection<Document> collection = mongoDatabase.getCollection(col);

//创建文档

Document document = new Document();

for (Map.Entry<String, Object> m : data.entrySet()) {

document.append(m.getKey(), m.getValue()).append(m.getKey(), m.getValue());

}

//插入一个文档

collection.insertOne(document);

}

/**

* 插入多个文档

*/

public static void insertMany (List<Map<String, Object>> listData, MongoDatabase mongoDatabase, String col) {

//获取集合

MongoCollection<Document> collection = mongoDatabase.getCollection(col);

//要插入的数据

List<Document> list = new ArrayList<>();

for (Map<String, Object> data : listData) {

//创建文档

Document document = new Document();

for (Map.Entry<String, Object> m : data.entrySet()) {

document.append(m.getKey(), m.getValue());

}

list.add(document);

}

//插入多个文档

collection.insertMany(list);

}

/**

* 删除匹配到的第一个文档

*/

public static void delectOne (String col, String key, Object value, MongoDatabase mongoDatabase) {

//获取集合

MongoCollection<Document> collection = mongoDatabase.getCollection(col);

//申明删除条件

Bson filter = Filters.eq(key, value);

//删除与筛选器匹配的单个文档

collection.deleteOne(filter);

}

/**

* 删除匹配的所有文档

*/

public static void deleteMany (String col, String key, Object value, MongoDatabase mongoDatabase) {

//获取集合

MongoCollection<Document> collection = mongoDatabase.getCollection(col);

//申明删除条件

Bson filter = Filters.eq(key, value);

//删除与筛选器匹配的所有文档

collection.deleteMany(filter);

}

/**

* 删除集合中所有文档

*/

public static void deleteAllDocument(String col, MongoDatabase mongoDatabase) {

//获取集合

MongoCollection<Document> collection = mongoDatabase.getCollection(col);

collection.deleteMany(new Document());

}

/**

* 删除文档和集合。

*/

public static void deleteAllCollection(String col, MongoDatabase mongoDatabase) {

//获取集合

MongoCollection<Document> collection = mongoDatabase.getCollection(col);

collection.drop();

}

/**

* 修改单个文档，修改过滤器筛选出的第一个文档

* @param col 修改的集合

* @param key 修改条件的键

* @param value 修改条件的值

* @param eqKey 要修改的键，如果eqKey不存在，则新增记录

* @param eqValue 要修改的值

* @param mongoDatabase 连接数据库对象

*/

public static void updateOne (String col, String key, Object value,String eqKey, Object eqValue, MongoDatabase mongoDatabase) {

//获取集合

MongoCollection<Document> collection = mongoDatabase.getCollection(col);

//修改过滤器

Bson filter = Filters.eq(key, value);

//指定修改的更新文档

Document document = new Document("$set", new Document(eqKey, eqValue));

//修改单个文档

collection.updateOne(filter, document);

}

/**

* 修改多个文档

* @param col 修改的集合

* @param key 修改条件的键

* @param value 修改条件的值

* @param eqKey 要修改的键，如果eqKey不存在，则新增记录

* @param eqValue 要修改的值

* @param mongoDatabase 连接数据库对象

*/

public static void updateMany (String col, String key, Object value, String eqKey, Object eqValue, MongoDatabase mongoDatabase) {

//获取集合

MongoCollection<Document> collection = mongoDatabase.getCollection(col);

//修改过滤器

Bson filter = Filters.eq(key, value);

//指定修改的更新文档

Document document = new Document("$set", new Document(eqKey, eqValue));

//修改多个文档

collection.updateMany(filter, document);

}

/**

* 查找集合中的所有文档

*/

public static MongoCursor<Document> find (String col, MongoDatabase mongoDatabase) {

//获取集合

MongoCollection<Document> collection = mongoDatabase.getCollection(col);

//查找集合中的所有文档

FindIterable<Document> findIterable = collection.find();

MongoCursor<Document> cursorIterator = findIterable.iterator();

return cursorIterator;

}

/**

* 按条件查找集合中文档

*/

public static MongoCursor<Document> Filterfind (String col,String key, Object value, MongoDatabase mongoDatabase) {

//获取集合

MongoCollection<Document> collection = mongoDatabase.getCollection(col);

//指定查询过滤器

Bson filter = Filters.eq(key, value);

//指定查询过滤器查询

FindIterable<Document> findIterable = collection.find(filter);

MongoCursor<Document> cursorIterator = findIterable.iterator();

return cursorIterator;

}

}

测试类

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

package com.example.demo.utils;

import com.mongodb.client.MongoCursor;import com.mongodb.client.MongoDatabase;import org.bson.Document;import org.junit.Test;

import java.util.ArrayList;import java.util.HashMap;import java.util.List;import java.util.Map;

public class MongoDBTest {

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

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

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

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

MongoDBUtil.closeNoIdentifyConnect(); }

@Test public void deleteMany() {

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

MongoDBUtil.closeNoIdentifyConnect(); }

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

MongoDBUtil.closeNoIdentifyConnect(); }

@Test public void deleteAllCollection() {

MongoDBUtil.deleteAllCollection("worker", mongoDatabase);

MongoDBUtil.closeNoIdentifyConnect(); }

@Test public void updateOne() {

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

MongoDBUtil.closeNoIdentifyConnect(); }

@Test public void updateMany() {

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

MongoDBUtil.closeNoIdentifyConnect(); }

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

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

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

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

作者丨哪吒

来源丨公众号：哪吒编程（ID：gh_61b183bcf690）

声明：本站部分内容来自互联网,如有版权侵犯或其他问题请与我们联系，我们将立即删除或处理。
▍相关推荐
更多资讯 >>>
Copyright @ 简易百科 V 2.0 京ICP备14042104号