在.NET项目中使用MongoDB进行数据操作，需要先完成环境搭建和相关配置，再通过官方提供的驱动实现各类数据交互逻辑。整个过程分为环境准备、连接配置、基础CRUD操作几个核心环节，下面逐步展开说明。
环境准备与驱动安装
首先确保本地已经安装MongoDB服务，并且服务处于正常运行状态。如果是首次使用，可以从MongoDB官方渠道下载对应系统的安装包完成部署。在.NET项目中，需要安装MongoDB官方提供的.NET驱动，最便捷的方式是通过NuGet包管理器安装。
打开NuGet包管理器控制台，执行以下命令安装驱动：
Install-Package MongoDB.Driver
安装完成后，项目中就可以引用MongoDB相关的命名空间，开展后续的操作。
建立数据库连接
操作MongoDB的第一步是建立与数据库的连接，需要指定MongoDB服务的地址、数据库名称等信息。通常我们会把连接字符串放在配置文件里，方便后续修改和维护。
以下是建立连接的示例代码：
using MongoDB.Driver;
using System;
namespace MongoDBDemo
{
public class MongoDBHelper
{
// 数据库连接字符串，本地默认端口为27017
private static readonly string connectionString = "mongodb://127.0.0.1:27017";
// 数据库名称
private static readonly string databaseName = "test_db";
// 获取数据库实例
public static IMongoDatabase GetDatabase()
{
var client = new MongoClient(connectionString);
return client.GetDatabase(databaseName);
}
}
}
定义实体模型
在C#中操作MongoDB时，通常会定义对应的实体类来映射集合中的文档。MongoDB的文档结构和C#的类结构可以灵活对应，不需要严格遵循表结构约束。
以下是一个用户实体的示例：
using MongoDB.Bson;
using MongoDB.Bson.Serialization.Attributes;
namespace MongoDBDemo
{
public class User
{
// 对应MongoDB文档中的_id字段
[BsonId]
[BsonRepresentation(BsonType.ObjectId)]
public string Id { get; set; }
// 用户名称
public string UserName { get; set; }
// 用户年龄
public int Age { get; set; }
// 用户邮箱
public string Email { get; set; }
// 创建时间
public DateTime CreateTime { get; set; }
}
}
基础CRUD操作实现
新增数据（Create）
向MongoDB的集合中插入数据，支持单条插入和批量插入两种方式。首先需要获取对应的集合对象，再调用插入方法。
using MongoDB.Driver;
using System;
using System.Collections.Generic;
namespace MongoDBDemo
{
public class UserOperation
{
private readonly IMongoCollection<User> _userCollection;
public UserOperation()
{
// 获取user集合，如果集合不存在会自动创建
_userCollection = MongoDBHelper.GetDatabase().GetCollection<User>("user");
}
// 插入单条数据
public void InsertSingleUser()
{
User user = new User
{
UserName = "张三",
Age = 25,
Email = "zhangsan@ipipp.com",
CreateTime = DateTime.Now
};
_userCollection.InsertOne(user);
Console.WriteLine("单条数据插入成功，生成的Id为：" + user.Id);
}
// 批量插入数据
public void InsertBatchUser()
{
List<User> userList = new List<User>
{
new User { UserName = "李四", Age = 28, Email = "lisi@ipipp.com", CreateTime = DateTime.Now },
new User { UserName = "王五", Age = 30, Email = "wangwu@ipipp.com", CreateTime = DateTime.Now }
};
_userCollection.InsertMany(userList);
Console.WriteLine("批量数据插入成功");
}
}
}
查询数据（Read）
MongoDB提供了丰富的查询方式，支持条件过滤、排序、分页等操作。可以通过FilterDefinitionBuilder构建查询条件。
using MongoDB.Driver;
using System;
using System.Collections.Generic;
namespace MongoDBDemo
{
public class UserQuery
{
private readonly IMongoCollection<User> _userCollection;
public UserQuery()
{
_userCollection = MongoDBHelper.GetDatabase().GetCollection<User>("user");
}
// 查询所有数据
public List<User> GetAllUsers()
{
return _userCollection.Find(Builders<User>.Filter.Empty).ToList();
}
// 按条件查询，查询年龄大于25的用户
public List<User> GetUsersByAge()
{
var filter = Builders<User>.Filter.Gt(u => u.Age, 25);
return _userCollection.Find(filter).ToList();
}
// 分页查询，查询第1页，每页2条数据
public List<User> GetUsersByPage(int pageIndex, int pageSize)
{
return _userCollection.Find(Builders<User>.Filter.Empty)
.Sort(Builders<User>.Sort.Descending(u => u.CreateTime))
.Skip((pageIndex - 1) * pageSize)
.Limit(pageSize)
.ToList();
}
}
}
更新数据（Update）
更新操作分为更新单条数据和更新多条数据，需要指定更新条件和更新的字段内容。
using MongoDB.Driver;
using System;
namespace MongoDBDemo
{
public class UserUpdate
{
private readonly IMongoCollection<User> _userCollection;
public UserUpdate()
{
_userCollection = MongoDBHelper.GetDatabase().GetCollection<User>("user");
}
// 更新单条数据，将用户名为张三的年龄改为26
public void UpdateSingleUser()
{
var filter = Builders<User>.Filter.Eq(u => u.UserName, "张三");
var update = Builders<User>.Update.Set(u => u.Age, 26);
var result = _userCollection.UpdateOne(filter, update);
Console.WriteLine("更新条数：" + result.ModifiedCount);
}
// 批量更新数据，将所有年龄小于25的用户年龄加1
public void UpdateBatchUser()
{
var filter = Builders<User>.Filter.Lt(u => u.Age, 25);
var update = Builders<User>.Update.Inc(u => u.Age, 1);
var result = _userCollection.UpdateMany(filter, update);
Console.WriteLine("批量更新条数：" + result.ModifiedCount);
}
}
}
删除数据（Delete）
删除操作同样支持单条删除和批量删除，操作前需要确认好删除条件，避免误删数据。
using MongoDB.Driver;
using System;
namespace MongoDBDemo
{
public class UserDelete
{
private readonly IMongoCollection<User> _userCollection;
public UserDelete()
{
_userCollection = MongoDBHelper.GetDatabase().GetCollection<User>("user");
}
// 删除单条数据，删除用户名为李四的用户
public void DeleteSingleUser()
{
var filter = Builders<User>.Filter.Eq(u => u.UserName, "李四");
var result = _userCollection.DeleteOne(filter);
Console.WriteLine("删除条数：" + result.DeletedCount);
}
// 批量删除数据，删除年龄大于30的用户
public void DeleteBatchUser()
{
var filter = Builders<User>.Filter.Gt(u => u.Age, 30);
var result = _userCollection.DeleteMany(filter);
Console.WriteLine("批量删除条数：" + result.DeletedCount);
}
}
}
注意事项
- 生产环境中不要将MongoDB连接字符串硬编码在代码里，建议放在配置文件或者环境变量中，避免敏感信息泄露。
- 插入数据时如果不指定
Id字段，MongoDB会自动生成ObjectId类型的值，对应实体类中的Id属性需要添加对应的特性标注。 - 构建查询条件时，注意字段名称和MongoDB集合中的字段名称保持一致，如果有自定义字段映射需要提前配置。
- 批量操作数据时，注意控制单次操作的数据量，避免对数据库造成过大压力。