四.MongoDB入门-Java操作MongoDB

本文涉及的产品
云数据库 MongoDB,独享型 2核8GB
推荐场景:
构建全方位客户视图
简介: MongoDB入门-Java操作MongoDB

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);
相关实践学习
MongoDB数据库入门
MongoDB数据库入门实验。
快速掌握 MongoDB 数据库
本课程主要讲解MongoDB数据库的基本知识,包括MongoDB数据库的安装、配置、服务的启动、数据的CRUD操作函数使用、MongoDB索引的使用(唯一索引、地理索引、过期索引、全文索引等)、MapReduce操作实现、用户管理、Java对MongoDB的操作支持(基于2.x驱动与3.x驱动的完全讲解)。 通过学习此课程,读者将具备MongoDB数据库的开发能力,并且能够使用MongoDB进行项目开发。 &nbsp; 相关的阿里云产品:云数据库 MongoDB版 云数据库MongoDB版支持ReplicaSet和Sharding两种部署架构,具备安全审计,时间点备份等多项企业能力。在互联网、物联网、游戏、金融等领域被广泛采用。 云数据库MongoDB版(ApsaraDB for MongoDB)完全兼容MongoDB协议,基于飞天分布式系统和高可靠存储引擎,提供多节点高可用架构、弹性扩容、容灾、备份回滚、性能优化等解决方案。 产品详情: https://www.aliyun.com/product/mongodb
相关文章
|
5天前
|
存储 监控 Java
【Java并发】【线程池】带你从0-1入门线程池
欢迎来到我的技术博客!我是一名热爱编程的开发者,梦想是编写高端CRUD应用。2025年我正在沉淀中,博客更新速度加快,期待与你一起成长。 线程池是一种复用线程资源的机制,通过预先创建一定数量的线程并管理其生命周期,避免频繁创建/销毁线程带来的性能开销。它解决了线程创建成本高、资源耗尽风险、响应速度慢和任务执行缺乏管理等问题。
110 60
【Java并发】【线程池】带你从0-1入门线程池
|
2月前
|
自然语言处理 Java
Java中的字符集编码入门-增补字符(转载)
本文探讨Java对Unicode的支持及其发展历程。文章详细解析了Unicode字符集的结构,包括基本多语言面(BMP)和增补字符的表示方法,以及UTF-16编码中surrogate pair的使用。同时介绍了代码点和代码单元的概念,并解释了UTF-8的编码规则及其兼容性。
113 60
|
2月前
|
NoSQL JavaScript 前端开发
Java访问MongoDB
Java访问MongoDB
43 21
|
2月前
|
SQL NoSQL Java
Java使用sql查询mongodb
通过MongoDB Atlas Data Lake或Apache Drill,可以在Java中使用SQL语法查询MongoDB数据。这两种方法都需要适当的配置和依赖库的支持。希望本文提供的示例和说明能够帮助开发者实现这一目标。
55 17
|
3月前
|
SQL NoSQL Java
Java使用sql查询mongodb
通过使用 MongoDB Connector for BI 和 JDBC,开发者可以在 Java 中使用 SQL 语法查询 MongoDB 数据库。这种方法对于熟悉 SQL 的团队非常有帮助,能够快速实现对 MongoDB 数据的操作。同时,也需要注意到这种方法的性能和功能限制,根据具体应用场景进行选择和优化。
126 9
|
3月前
|
Java 开发者 微服务
Spring Boot 入门:简化 Java Web 开发的强大工具
Spring Boot 是一个开源的 Java 基础框架,用于创建独立、生产级别的基于Spring框架的应用程序。它旨在简化Spring应用的初始搭建以及开发过程。
114 7
Spring Boot 入门:简化 Java Web 开发的强大工具
|
3月前
|
监控 架构师 Java
Java虚拟机调优的艺术:从入门到精通####
本文作为一篇深入浅出的技术指南,旨在为Java开发者揭示JVM调优的神秘面纱,通过剖析其背后的原理、分享实战经验与最佳实践,引领读者踏上从调优新手到高手的进阶之路。不同于传统的摘要概述,本文将以一场虚拟的对话形式,模拟一位经验丰富的架构师向初学者传授JVM调优的心法,激发学习兴趣,同时概括性地介绍文章将探讨的核心议题——性能监控、垃圾回收优化、内存管理及常见问题解决策略。 ####
|
4月前
|
监控 安全 Java
Java中的多线程编程:从入门到实践####
本文将深入浅出地探讨Java多线程编程的核心概念、应用场景及实践技巧。不同于传统的摘要形式,本文将以一个简短的代码示例作为开篇,直接展示多线程的魅力,随后再详细解析其背后的原理与实现方式,旨在帮助读者快速理解并掌握Java多线程编程的基本技能。 ```java // 简单的多线程示例:创建两个线程,分别打印不同的消息 public class SimpleMultithreading { public static void main(String[] args) { Thread thread1 = new Thread(() -> System.out.prin
|
4月前
|
Java 程序员 数据库连接
Java中的异常处理:从入门到精通
在Java编程的海洋中,异常处理是一艘不可或缺的救生艇。它不仅保护你的代码免受错误数据的侵袭,还能确保用户体验的平稳航行。本文将带你领略异常处理的风浪,让你学会如何在Java中捕捉、处理和预防异常,从而成为一名真正的Java航海家。
|
18天前
|
存储 NoSQL MongoDB
数据库数据恢复—MongoDB数据库迁移过程中丢失文件的数据恢复案例
某单位一台MongoDB数据库由于业务需求进行了数据迁移,数据库迁移后提示:“Windows无法启动MongoDB服务(位于 本地计算机 上)错误1067:进程意外终止。”

热门文章

最新文章