MongDD的语法很多,我们只需要记一些常用的即可,在实际开发中还是使用Java面向对象的方式来操作Mongodb。
1.小试牛刀
1.1.导入依赖
在 Java 程序中如果要使用 MongoDB,你需要确保已经安装了 Java 环境及 MongoDB JDBC 驱动,创建一个普通java项目,导入如下依赖
<dependencies>
<dependency>
<groupId>org.mongodb</groupId>
<artifactId>mongo-java-driver</artifactId>
<version>3.12.10</version>
</dependency>
</dependencies>
1.2.连接MongDB
不使用账号连接:mongodb://localhost:27017
, 使用账号连接 mongodb://账号:密码@localhost:27017/
//1.创建客户端 : mongodb://用户名:密码@127.0.0.1:27017
//如果没有账号:mongodb://127.0.0.1:27017
com.mongodb.client.MongoClient mongoClient =
MongoClients.create("mongodb://testuser:testuser@127.0.0.1:27017");
1.3.查询文档
通过客户端链接数据库,然后查询文档
//2.链接数据库tempdb
MongoDatabase userDB = mongoClient.getDatabase("tempdb");
//3.获取集合 user
FindIterable<Document> documentFindIterable = userDB.getCollection("user").find();
//4.拿到文档迭代器
MongoCursor<Document> iterator = documentFindIterable.iterator();
//5.遍历文档
while(iterator.hasNext()){
System.out.println(iterator.next());
}
2.MongDB的CRUD
2.1.数据库CRUD
通过listDatabases查询所有数据库
//列出所有数据库
ListDatabasesIterable<Document> listDatabasesIterable = mongoClient.listDatabases();
MongoCursor<Document> iterator1 = listDatabasesIterable.iterator();
while(iterator1.hasNext()){
System.out.println(iterator1.next());
}
通过 getDatabase 获取指定数据库
MongoDatabase empdb = mongoClient.getDatabase("empdb");
System.out.println(empdb.getName());
drop删除数据库
MongoDatabase empdb = mongoClient.getDatabase("empdb");
empdb.drop();
创建数据库 ,直接使用 mongoClient.getDatabase("db") ,当添加数据的时候会自动创建数据库
MongoDatabase testdb = mongoClient.getDatabase("testdb");
testdb.createCollection("user");
2.2.集合CRUD
查看集合
MongoCursor<Document> iterator2 = userDB.listCollections().iterator();
while (iterator2.hasNext()){
System.out.println(iterator2.next());
}
获取某个集合
MongoCollection<Document> user = userDB.getCollection("集合名");
添加集合
userDB.createCollection("user");
//集合名,固定大小 , 最大文档数 ,最大字节数
userDB.createCollection("user", new CreateCollectionOptions().capped(true).maxDocuments(1000).sizeInBytes(1024*1024*1024));
//========================================================================================================
//验证规则,添加的文档中必须出现username和 age字段
ValidationOptions validationOptions = new ValidationOptions().validator(Filters.or(Filters.exists("username"),Filters.exists("age")));
userDB.createCollection("user",
//集合名,固定大小 , 最大文档数 ,最大字节数
new CreateCollectionOptions().capped(true).maxDocuments(1000).sizeInBytes(1024*1024*1024)
//添加的文档必须满足的验证规则
.validationOptions(validationOptions)
);
删除集合
//拿到集合
MongoCollection<Document> user = userDB.getCollection("user");
//删除集合
user.drop();
2.3.文档CRUD
创建文档
//创建集合
userDB.createCollection("tempcol");
//拿到集合
MongoCollection<Document> tempcol = userDB.getCollection("tempcol");
//创建文档
Document doc = new Document();
doc.append("_id",1);
doc.append("username","zs");
doc.append("age",18).append("info",new Document("x","22").append("y","33"));
//添加文档
tempcol.insertOne(doc);
获取文档
//构建查询的内容
Document bson = new Document();
bson.put("_id",1);
//拿到集合,执行find
FindIterable<Document> documentFindIterable1 = userDB.getCollection("tempcol").find(bson);
//遍历结果
MongoCursor<Document> iterator3 = documentFindIterable1.iterator();
while(iterator3.hasNext()){
System.out.println(iterator3.next());
}
//组装条件
MongoCollection<Document> tempcol = userDB.getCollection("tempcol");
Bson filter = Filters.and(Filters.eq("sex", 1), Filters.gte("age", 18));
FindIterable<Document> documentFindIterable = tempcol.find(filter);
//获取文档数量
userDB.getCollection("tempcol").countDocuments();
删除文档
//构建条件文档
Bson filter = Filters.eq("_id", 1);
//执行文档删除
DeleteResult result = userDB.getCollection("tempcol").deleteOne(bson);
System.out.println(result);
//删除符合条件的第一个文档
userDB.getCollection("tempcol").deleteOne(Filters.eq("likes", 200));
//删除符合条件的所有文档
userDB.getCollection("tempcol").deleteMany (Filters.eq("likes", 200));
修改文档
//过滤条件,_id = 1
Bson filter = Filters.eq("_id", 1);
//把 age 设置为 100
Document update = new Document("$set",new Document("age",100));
//执行修改
UpdateResult updateResult = userDB.getCollection("tempcol").updateOne(filter, update);
System.out.println(updateResult);