MongoDB作为常用的非关系型数据库，在Java项目中的应用非常广泛，掌握其CRUD操作是开发者的必备技能。下面我们先来看整体操作的准备工作和具体实现。
一、环境准备
1. 依赖引入
如果使用原生MongoDB Java驱动，在Maven项目的pom.xml中添加以下依赖：
<dependency>
<groupId>org.mongodb</groupId>
<artifactId>mongodb-driver-sync</artifactId>
<version>4.9.0</version>
</dependency>如果使用Spring Data MongoDB，添加对应 starter 依赖：
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>2. 连接配置
原生驱动连接示例：
// 连接本地MongoDB服务，默认端口27017
MongoClient mongoClient = MongoClients.create("mongodb://127.0.0.1:27017");
// 获取指定数据库，若不存在则自动创建
MongoDatabase database = mongoClient.getDatabase("test_db");
// 获取指定集合，若不存在则自动创建
MongoCollection<Document> collection = database.getCollection("user_collection");Spring Boot配置在application.yml中：
spring:
data:
mongodb:
host: 127.0.0.1
port: 27017
database: test_db二、原生驱动CRUD实现
1. 插入操作（Create）
单条插入：
Document user = new Document();
user.append("name", "张三");
user.append("age", 25);
user.append("hobby", "篮球");
// 插入单条文档
collection.insertOne(user);批量插入：
List<Document> userList = new ArrayList<>();
userList.add(new Document("name", "李四").append("age", 22).append("hobby", "足球"));
userList.add(new Document("name", "王五").append("age", 28).append("hobby", "阅读"));
// 批量插入文档
collection.insertMany(userList);2. 查询操作（Read）
查询所有文档：
// 查询集合中所有文档
FindIterable<Document> documents = collection.find();
for (Document doc : documents) {
System.out.println(doc.toJson());
}条件查询，比如查询年龄大于23岁的用户：
// 构建查询条件：age > 23
Bson filter = Filters.gt("age", 23);
FindIterable<Document> result = collection.find(filter);
for (Document doc : result) {
System.out.println(doc.toJson());
}3. 更新操作（Update）
更新单条匹配文档，比如把张三的年龄改为26：
// 匹配条件：name为张三
Bson updateFilter = Filters.eq("name", "张三");
// 更新内容：设置age为26
Bson update = Updates.set("age", 26);
// 更新第一条匹配的文档
collection.updateOne(updateFilter, update);批量更新，比如把所有年龄小于25的用户爱好改为跑步：
Bson batchFilter = Filters.lt("age", 25);
Bson batchUpdate = Updates.set("hobby", "跑步");
// 更新所有匹配的文档
collection.updateMany(batchFilter, batchUpdate);4. 删除操作（Delete）
删除单条匹配文档：
Bson deleteFilter = Filters.eq("name", "王五");
// 删除第一条匹配的文档
collection.deleteOne(deleteFilter);批量删除：
Bson batchDeleteFilter = Filters.lt("age", 20);
// 删除所有匹配的文档
collection.deleteMany(batchDeleteFilter);三、Spring Data MongoDB实现CRUD
1. 定义实体类
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;
@Document(collection = "user_collection")
public class User {
@Id
private String id;
private String name;
private Integer age;
private String hobby;
// 省略getter、setter和toString方法
}2. 定义Repository接口
import org.springframework.data.mongodb.repository.MongoRepository;
import java.util.List;
public interface UserRepository extends MongoRepository<User, String> {
// 自定义查询方法，根据名字查询
List<User> findByName(String name);
// 自定义查询方法，根据年龄大于指定值查询
List<User> findByAgeGreaterThan(Integer age);
}3. 业务层调用示例
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;
@Service
public class UserService {
@Autowired
private UserRepository userRepository;
// 插入用户
public User saveUser(User user) {
return userRepository.save(user);
}
// 查询所有用户
public List<User> getAllUsers() {
return userRepository.findAll();
}
// 根据名字查询用户
public List<User> getUsersByName(String name) {
return userRepository.findByName(name);
}
// 更新用户
public User updateUser(User user) {
return userRepository.save(user);
}
// 删除用户
public void deleteUser(String id) {
userRepository.deleteById(id);
}
}四、注意事项
- 操作完成后要及时关闭
MongoClient连接，避免资源泄露，Spring Data MongoDB会自动管理连接生命周期 - MongoDB的文档字段是动态可扩展的，不需要提前定义所有字段，新增字段直接插入即可
- 条件查询时如果字段不存在，默认会返回空结果，不会报错
- 批量操作如果数据量较大，建议分批次处理，避免单次操作占用过多内存
通过以上两种方式，开发者可以根据项目需求选择合适的Java操作MongoDB的方案，原生驱动更灵活，Spring Data MongoDB更便捷，都能满足日常CRUD开发需求。
JavaMongoDBCRUDSpring_Data_MongoDB修改时间：2026-05-25 00:41:17