如何在.Net中使用MongoDB

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using MongoDB.Bson;
using MongoDB.Driver;
using MongoDB.Driver.Builders;

namespace Soffice.DeveloperTools.Bll
{
public class CsSystem
{
/// <summary>
/// 获取分页列表数据
/// </summary>
/// <param name="total">记录总数</param>
/// <param name="pageIndex">当前页</param>
/// <param name="pageSize">每页显示多少条</param>
/// <param name="where">where条件</param>
/// <returns></returns>
public static List<ModelDb.CsSystem> GetList(out int total, int pageIndex, int pageSize, ModelMvc.CsSystemWhere where)
{
MongoClient client = new MongoClient("mongodb://localhost");
MongoServer server = client.GetServer();
MongoDatabase database = server.GetDatabase("CoreSystem");
MongoCollection collection = database.GetCollection<ModelDb.CsSystem>("CsSystem");
total = Convert.ToInt32(collection.Count());
return collection.FindAllAs<ModelDb.CsSystem>().Skip((pageIndex - 1) * pageSize).Take(pageSize).ToList();
}

/// <summary>
/// 获取DtGrid列表数据
/// </summary>
/// <param name="gridParam">Grid传入参数</param>
/// <returns></returns>
public static string GetGrid(string gridParam)
{
ModelMvc.CsSystemDtGrid grid = CommonFunction.Deserialize<ModelMvc.CsSystemDtGrid>(gridParam);

int total = 0;
List<ModelDb.CsSystem> listDb = GetList(out total, grid.nowPage, grid.pageSize, grid.parameters);
List<ModelMvc.CsSystemGridData> gridDatas = new List<ModelMvc.CsSystemGridData>();
foreach (ModelDb.CsSystem m in listDb)
{
gridDatas.Add(new ModelMvc.CsSystemGridData
{
Id = m.Id,
TypesName = CsDict.CsSystem_Types.Where(w => w.Id == m.Types).Select(s => s.ItemValue).FirstOrDefault(),
Names = m.Names,
Code = m.Code,
EntryUrl = m.EntryUrl,
Remark = m.Remark,
IsEnabledName = m.IsEnabled ? "是" : "否"
});
}

grid.isSuccess = true;
grid.recordCount = total;
grid.exhibitDatas = gridDatas;

return CommonFunction.Serialize(grid);
}

/// <summary>
/// 根据主键id获取编辑数据
/// </summary>
/// <param name="id"></param>
/// <returns></returns>
public static ModelMvc.CsSystemForm GetEditInfo(int id)
{
MongoClient client = new MongoClient("mongodb://localhost");
MongoServer server = client.GetServer();
MongoDatabase database = server.GetDatabase("CoreSystem");
MongoCollection collection = database.GetCollection<ModelDb.CsSystem>("CsSystem");
var query = Query.EQ("_id", id);
ModelDb.CsSystem m = collection.FindOneAs<ModelDb.CsSystem>(query);
return new ModelMvc.CsSystemForm
{
Id = m.Id,
Types = m.Types,
Names = m.Names,
Code = m.Code,
EntryUrl = m.EntryUrl,
IsEnabled = m.IsEnabled,
Remark = m.Remark
};
}

/// <summary>
/// 保存新增
/// </summary>
/// <param name="m">表单数据</param>
/// <returns></returns>
public static bool SaveAdd(ModelMvc.CsSystemForm m)
{
CommonValid valid = new CommonValid(m);
if (valid.IsValid)
{
MongoClient client = new MongoClient("mongodb://localhost");
MongoServer server = client.GetServer();
MongoDatabase database = server.GetDatabase("CoreSystem");
MongoCollection collection = database.GetCollection<ModelDb.CsSystem>("CsSystem");
return collection.Insert(new ModelDb.CsSystem
{
Id = m.Id,
Types = m.Types,
Names = m.Names,
Code = m.Code,
EntryUrl = m.EntryUrl,
IsEnabled = m.IsEnabled,
Remark = m.Remark
}).Ok;
}
else
{
throw new ExceptionValid(valid);
}
}

/// <summary>
/// 保存新增
/// </summary>
/// <param name="m">表单数据</param>
/// <returns></returns>
public static bool SaveEdit(ModelMvc.CsSystemForm m)
{
CommonValid valid = new CommonValid(m);
if (valid.IsValid)
{
MongoClient client = new MongoClient("mongodb://localhost");
MongoServer server = client.GetServer();
MongoDatabase database = server.GetDatabase("CoreSystem");
MongoCollection collection = database.GetCollection<ModelDb.CsSystem>("CsSystem");
return collection.Save(new ModelDb.CsSystem
{
Id = m.Id,
Types = m.Types,
Names = m.Names,
Code = m.Code,
EntryUrl = m.EntryUrl,
IsEnabled = m.IsEnabled,
Remark = m.Remark
}).Ok;
}
else
{
throw new ExceptionValid(valid);
}
}

/// <summary>
/// 删除
/// </summary>
/// <param name="id"></param>
/// <returns></returns>
public static bool SaveDelete(int id)
{
MongoClient client = new MongoClient("mongodb://localhost");
MongoServer server = client.GetServer();
MongoDatabase database = server.GetDatabase("CoreSystem");
var collection = database.GetCollection<ModelDb.CsSystem>("CsSystem");
var query = Query.EQ("_id", id);
return collection.Remove(query).Ok;
}
}
}

using System;

namespace Soffice.DeveloperTools.ModelDb
{
public class CsSystem
{
/// <summary>
/// Id
/// </summary>
public int Id { get; set; }
/// <summary>
/// 1.子系统，2.其它第三方系统
/// </summary>
public int Types { get; set; }
/// <summary>
/// Names
/// </summary>
public string Names { get; set; }
/// <summary>
/// Code
/// </summary>
public string Code { get; set; }
/// <summary>
/// EntryUrl
/// </summary>
public string EntryUrl { get; set; }
/// <summary>
/// Remark
/// </summary>
public string Remark { get; set; }
/// <summary>
/// IsEnabled
/// </summary>
public bool IsEnabled { get; set; }
}
}