悠悠楠杉
网站页面
.NET如何使用MongoDB进行数据操作
11/15
在现代软件开发中，随着数据结构的多样化和系统性能要求的提升，传统关系型数据库已无法完全满足所有业务场景。尤其是在处理非结构化或半结构化数据时，NoSQL数据库展现出更强的灵活性与扩展性。MongoDB作为最受欢迎的文档型数据库之一，凭借其高性能、高可用性和水平扩展能力，被广泛应用于各类后端系统中。而.NET平台，尤其是.NET Core及后续版本，以其跨平台、高性能和丰富的生态体系，成为企业级应用开发的重要选择。将两者结合，能够构建出高效、可扩展的数据驱动应用。
要在.NET项目中操作MongoDB，首先需要引入官方提供的驱动程序 MongoDB.Driver。通过NuGet包管理器安装该库后，即可在C#代码中建立与MongoDB的连接。核心对象是 MongoClient，它代表与MongoDB服务器的连接会话。通过该客户端，可以获取指定的数据库和集合（Collection），进而执行增删改查等操作。
以一个简单的用户管理系统为例，假设我们有一个 User 类：
csharp
public class User
{
public ObjectId Id { get; set; }
public string Name { get; set; }
public int Age { get; set; }
public string Email { get; set; }
}
接下来，在程序启动时初始化数据库连接：
csharp
var client = new MongoClient("mongodb://localhost:27017");
var database = client.GetDatabase("AppDb");
var collection = database.GetCollection<User>("Users");
插入数据非常直观。使用 InsertOne 或 InsertMany 方法即可完成单条或多条记录的写入：
csharp
var user = new User { Name = "张三", Age = 28, Email = "zhangsan@example.com" };
await collection.InsertOneAsync(user);
查询操作则通过构建过滤条件来实现。MongoDB.Driver 提供了强大的 Builders<T>.Filter 工具类，支持链式语法构造复杂查询。例如，查找年龄大于25的用户：
csharp
var filter = Builders<User>.Filter.Gt(u => u.Age, 25);
var results = await collection.Find(filter).ToListAsync();
还可以结合 Sort、Limit 等方法实现排序与分页：
csharp
var sorted = await collection.Find(filter)
.Sort(Builders<User>.Sort.Ascending(u => u.Name))
.Limit(10)
.ToListAsync();
更新操作同样灵活。可以通过 UpdateDefinition 构建更新内容。比如将某个用户的年龄加1：
csharp
var update = Builders<User>.Update.Inc(u => u.Age, 1);
await collection.UpdateOneAsync(u => u.Id == user.Id, update);
删除操作则使用 DeleteOne 或 DeleteMany，配合过滤条件精准移除数据：
csharp
await collection.DeleteOneAsync(u => u.Email == "zhangsan@example.com");
在整个数据操作过程中，推荐始终使用异步方法（如 InsertOneAsync、FindAsync 等），以避免阻塞主线程，提升应用响应能力，特别是在高并发场景下尤为重要。
此外，为了提升代码可维护性，建议将数据库访问逻辑封装在独立的服务类中，并通过依赖注入方式在控制器或其他组件中使用。例如定义一个 UserService，内部持有 IMongoCollection<User> 实例，对外暴露业务方法。
值得注意的是，MongoDB 是模式自由的，这意味着同一个集合中的文档结构可以不同。但在实际开发中，仍建议保持一定的结构一致性，便于后期维护和类型映射。同时，合理设计索引对于提升查询性能至关重要。可以通过 IndexBuilder 创建索引，例如为Email字段添加唯一索引：
csharp
var indexModel = new CreateIndexModel<User>(
Builders<User>.IndexKeys.Ascending(u => u.Email));
await collection.Indexes.CreateOneAsync(indexModel);
