JCode.ORMX.DbProvider.MongoDB 1.2.2

JCode.ORMX.DbProvider.MongoDB

MongoDB 数据库提供程序，用于 JCode.ORMX 框架。

快速开始

安装

Install-Package JCode.ORMX.DbProvider.MongoDB

基本用法

using JCode.ORMX.DbProvider.MongoDB;
using JCode.ORMX.Attributes;
using MongoDB.Bson;

// 定义实体
[Table("Users")]
public class User
{
    [Column(IsPrimaryKey = true)]
    public ObjectId Id { get; set; }
    
    [Column]
    public string Name { get; set; }
    
    [Column]
    public string Email { get; set; }
}

// 初始化
using var provider = new MongoDbProvider("mongodb://localhost:27017/MyDb");
var tableManager = provider.GetTableManager();

// 创建集合
tableManager.Create(typeof(User));

// CRUD 操作
var table = tableManager.Table<User>();

// 插入
var user = table.Insert(new User { Name = "John", Email = "john@example.com" });

// 查询
var users = table.Where(u => u.Name == "John").GetList();

// 更新
table.Update(u => u.Email, "newemail@example.com");

// 删除指定实体
table.Delete(user);

// 或使用条件删除
table.Where(u => u.Id == userId).Delete();

功能特性

• ✅ 完整的 MongoDB 支持
• ✅ 类型安全的 LINQ 查询
• ✅ 事务支持
• ✅ 批量操作（InsertAll/UpdateAll/DeleteAll）
• ✅ 连接池管理
• ✅ 参数化查询（防 SQL 注入）
• ✅ 智能 SQL 调试

链式查询

ORMX 提供流畅的链式查询 API：

// 复杂查询
var result = table
    .Where(u => u.Age > 18)
    .OrderByDesc(u => u.CreatedAt)
    .Limit(10)
    .GetList();

// 聚合查询
var count = table.Count();
var maxAge = table.Max(u => u.Age);

SQL 调试

// 查看生成的 SQL
table.Extension((extObj) =>
{
    Console.WriteLine($"SQL: {extObj.Query}");
    Console.WriteLine($"参数：{string.Join(", ", extObj.Parameters)}");
})
.Where(u => u.Age > 25)
.GetList();

配置选项

连接字符串

// 简单连接
var provider = new MongoDbProvider("mongodb://localhost:27017/MyDb");

// 带认证连接
var provider = new MongoDbProvider("mongodb://username:password@localhost:27017/MyDb");

// 副本集
var provider = new MongoDbProvider("mongodb://node1:27017,node2:27017/MyDb?replicaSet=rs0");

高级配置

var settings = new MongoClientSettings
{
    Server = new MongoServerAddress("localhost", 27017),
    ConnectTimeout = TimeSpan.FromSeconds(30),
    SocketTimeout = TimeSpan.FromSeconds(30),
    MaxConnectionPoolSize = 100,
    MinConnectionPoolSize = 10
};

var client = new MongoClient(settings);
var provider = new MongoDbProvider(client.GetDatabase("MyDb"));

📖 完整手册

详细使用文档请访问：ORMX 完整使用手册

手册包含：

• 高级查询（聚合、连接、子查询、分组）
• 事务管理最佳实践
• Redis 缓存集成
• 分布式数据库支持（分片、读写分离）
• 性能优化建议
• 完整 API 参考
• 故障排除指南

依赖项

• MongoDB.Driver (2.x+)
• JCode.ORMX (1.0.0+)