MongoDB 是一个基于分布式文件存储的数据库。由 C++ 语言编写。旨在为 WEB 应用提供可扩展的高性能数据存储解决方案。MongoDB 是一个介于关系数据库和非关系数据库之间的产品，是非关系数据库当中功能最丰富，最像关系数据库的。本文介绍了Java操作MongoDB数据库的使用。
模式自由 :可以把不同结构的文档存储在同一个数据库里
面向集合的存储：适合存储 JSON风格文件的形式
完整的索引支持：对任何属性可索引
复制和高可用性：支持服务器之间的数据复制，支持主-从模式及服务器之间的相互复制。复制的主要目的是提供冗余及自动故障转移
自动分片：支持云级别的伸缩性：自动分片功能支持水平的数据库集群，可动态添加额外的机器
丰富的查询：支持丰富的查询表达方式，查询指令使用JSON形式的标记，可轻易查询文档中的内嵌的对象及数组
快速就地更新：查询优化器会分析查询表达式，并生成一个高效的查询计划
高效的传统存储方式：支持二进制数据及大型对象（如照片或图片）
客户端MongoDBCompass，下载地址：
https://www.mongodb.com/try/download/compass
这次先不自己安装了，看到阿里云有试用，于是花费9.9元购买了三个月的试用。
阿里有很多选项提供选购，这次购买的是Serverless实例，Serverless轻量级低成本；单节点高性价比；多节点副本集保障业务高可用；分片集群自由配置弹性扩展。
购买地址：https://www.aliyun.com/product/mongodb
为了方便测试使用，做如下操作：
购买后进入控制台，重置mongodb密码
然后进入数据库连接，申请一个公网进行访问
然后进入安全设置，设置允许所有人访问
然后在工具输入公网访问地址：
mongodb://用户名:密码@连接地址:端口/admin
具体连接地址从阿里复制即可，复制过来的连接信息只要改下你的密码即可，然后就可以进入管理页面
Maven中引入MongoDB客户端
<dependency>
<groupId>org.mongodb</groupId>
<artifactId>mongo-java-driver</artifactId>
<version>3.0.4</version>
</dependency>
MongoDB的3.x版本Java驱动相对2.x做了全新的设计，类库和使用方法上有很大区别。
例如用Document替换BasicDBObject、通过Builders类构建Bson替代直接输入$命令等。
以下JAVA代码演示了对于MongoDB的增删改查操作
package com.example.zMongoDB;
import java.util.ArrayList;
import java.util.List;
import org.bson.Document;
import org.bson.conversions.Bson;
import com.mongodb.BasicDBObject;
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 MongoDBJDBC {
private static MongoClient mongoClient = null;
public static void main(String args[]) {
testQuery();
}
public static void testQuery() {
MongoDatabase mongoDatabase = getDB();
// 这里的 "user" 表示集合的名字，如果指定的集合不存在，mongoDB将会在你第一次插入文档时创建集合。
MongoCollection<Document> collection = mongoDatabase.getCollection("user");
// 查找集合中的所有文档
FindIterable<Document> findIterable = collection.find();
MongoCursor<Document> cursor = findIterable.iterator();
while (cursor.hasNext()) {
System.out.println(cursor.next());
}
// 指定查询过滤器
Bson filter = Filters.eq("name", "张1");
// 指定查询过滤器查询
findIterable = collection.find(filter);
cursor = findIterable.iterator();
while (cursor.hasNext()) {
System.out.println(cursor.next());
}
// 查找集合中的所有文档，－1表示倒序
findIterable = collection.find().sort(new BasicDBObject("age", -1));
// 取出查询到的第一个文档
Document document = (Document) findIterable.first();
// 打印输出
System.out.println(document);
closeDB();
}
public static void testUpdate() {
MongoDatabase mongoDatabase = getDB();
// 这里的 "user" 表示集合的名字，如果指定的集合不存在，mongoDB将会在你第一次插入文档时创建集合。
MongoCollection<Document> collection = mongoDatabase.getCollection("user");
// 修改过滤器
Bson filter = Filters.eq("name", "阿娇");
// 指定修改的更新文档
Document document = new Document("$set", new Document("age", 22));
// 修改单个文档
collection.updateOne(filter, document);
// 修改多个文档
collection.updateMany(filter, document);
closeDB();
}
public static void testDel() {
MongoDatabase mongoDatabase = getDB();
// 这里的 "user" 表示集合的名字，如果指定的集合不存在，mongoDB将会在你第一次插入文档时创建集合。
MongoCollection<Document> collection = mongoDatabase.getCollection("user");
// 申明删除条件，eq等于，也可以设置大于小于等条件
Bson filter = Filters.eq("age", 18);
// 删除与筛选器匹配的单个文档
collection.deleteOne(filter);
// 删除与筛选器匹配的所有文档
collection.deleteMany(filter);
closeDB();
}
public static void testAdd() {
MongoDatabase mongoDatabase = getDB();
// 这里的 "user" 表示集合的名字，如果指定的集合不存在，mongoDB将会在你第一次插入文档时创建集合。
MongoCollection<Document> collection = mongoDatabase.getCollection("user");
Document document = new Document("name", "阿娇").append("sex", "女").append("age", 18);
collection.insertOne(document);
// 要插入的数据
List<Document> list = new ArrayList<>();
for (int i = 1; i <= 3; i++) {
Document documents = new Document("name", "张" + i).append("sex", "男").append("age", 20 + i);
list.add(documents);
}
// 插入多个文档
collection.insertMany(list);
closeDB();
}
public static MongoDatabase getDB() {
List<ServerAddress> adds = new ArrayList<>();
ServerAddress serverAddress = new ServerAddress("地址", 3717);
adds.add(serverAddress);
List<MongoCredential> credentials = new ArrayList<>();
// 用户名 数据库名称 密码
MongoCredential mongoCredential = MongoCredential.createScramSha1Credential("用户名", "admin",
"密码".toCharArray());
credentials.add(mongoCredential);
mongoClient = new MongoClient(adds, credentials);
// 这里的 "test" 表示数据库名，若指定的数据库不存在，mongoDB将会在你第一次插入文档时创建数据库。
MongoDatabase mongoDatabase = mongoClient.getDatabase("test");
return mongoDatabase;
}
public static void closeDB() {
mongoClient.close();
}
}
可以通过客户端看到已经录入进去的数据
END
