.NET平台下使用MongoDB入门教程

水莹儿

/*******************************************************　　
*
　　
* 作者：徐文东
　　
* 创建日期：20170510
　　
* 说明：MongoDb帮助类
　　
* 运行环境：.NET 4.0
　　
* 版本号：1.0.0
　　
*
　　
* 历史记录：
　　
* 创建文件 徐文东 20170510 11:56
　　
*
　　
******************************************************
*/　　
using System;
　　
using System.Collections.Generic;
　　
using System.Linq;
　　
using System.Text;
　　
using System.Threading.Tasks;
　　
using MongoDB.Bson;
　　
using MongoDB.Driver;
　　
using MongoDB.Driver.Core.Servers;
　　
using System.Linq.Expressions;
　　

　　
namespace DBI.SaaS.ExternalService.BigData
　　
{
　　
/// <summary>
　　
/// MongoDb帮助类
　　
/// </summary>

　　
public>　　
{
　　
private static readonly string connStr = "mongodb://127.0.0.1:27017";//GlobalConfig.Settings["mongoConnStr"];
　　

　　
private static readonly string dbName = "xuwendong";//GlobalConfig.Settings["mongoDbName"];
　　

　　
private static IMongoDatabase db = null;
　　

　　
private static readonly object lockHelper = new object();
　　

　　
private DB() { }
　　

　　
public static IMongoDatabase GetDb()
　　
{
　　
if (db == null)
　　
{
　　
lock (lockHelper)
　　
{
　　
if (db == null)
　　
{
　　
var client = new MongoClient(connStr);
　　
db = client.GetDatabase(dbName);
　　
}
　　
}
　　
}
　　
return db;
　　
}
　　
}
　　


　　
public>　　
{
　　
private IMongoDatabase db = null;
　　

　　
private IMongoCollection<T> collection = null;
　　

　　
public MongoDbHelper()
　　
{
　　
this.db = DB.GetDb();
　　
collection = db.GetCollection<T>(typeof(T).Name);
　　
}
　　
/// <summary>
　　
/// 新增
　　
/// </summary>
　　
/// <param name="entity"></param>
　　
/// <returns></returns>
　　
public T Insert(T entity)
　　
{
　　
var flag = ObjectId.GenerateNewId();
　　
entity.GetType().GetProperty("Id").SetValue(entity, flag);
　　
entity.State = "y";
　　
entity.CreateTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
　　
entity.UpdateTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
　　

　　
collection.InsertOneAsync(entity);
　　
return entity;
　　
}
　　
/// <summary>
　　
/// 修改
　　
/// </summary>
　　
/// <param name="id"></param>
　　
/// <param name="field"></param>
　　
/// <param name="value"></param>

　　
public void Modify(string>　　
{
　　
var filter = Builders<T>.Filter.Eq("Id", ObjectId.Parse(id));
　　
var updated = Builders<T>.Update.Set(field, value);
　　
UpdateResult result = collection.UpdateOneAsync(filter, updated).Result;
　　
}
　　
/// <summary>
　　
/// 更新
　　
/// </summary>
　　
/// <param name="entity"></param>
　　
public void Update(T entity)
　　
{
　　
try
　　
{
　　
var old = collection.Find(e => e.Id.Equals(entity.Id)).ToList().FirstOrDefault();
　　

　　
foreach (var prop in entity.GetType().GetProperties())
　　
{
　　
var newValue = prop.GetValue(entity);
　　
var oldValue = old.GetType().GetProperty(prop.Name).GetValue(old);
　　
if (newValue != null)
　　
{
　　
if (oldValue == null)
　　
oldValue = "";
　　
if (!newValue.ToString().Equals(oldValue.ToString()))
　　
{
　　
old.GetType().GetProperty(prop.Name).SetValue(old, newValue.ToString());
　　
}
　　
}
　　
}
　　
old.State = "n";
　　
old.UpdateTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
　　

　　
var filter = Builders<T>.Filter.Eq("Id", entity.Id);
　　
ReplaceOneResult result = collection.ReplaceOneAsync(filter, old).Result;
　　
}
　　
catch (Exception ex)
　　
{
　　
var aaa = ex.Message + ex.StackTrace;
　　
throw;
　　
}
　　
}
　　
/// <summary>
　　
/// 删除
　　
/// </summary>
　　
/// <param name="entity"></param>
　　
public void Delete(T entity)
　　
{
　　
var filter = Builders<T>.Filter.Eq("Id", entity.Id);
　　
collection.DeleteOneAsync(filter);
　　
}
　　
/// <summary>
　　
/// 根据id查询一条数据
　　
/// </summary>
　　
/// <param name="id"></param>
　　
/// <returns></returns>

　　
public T QueryOne(string>　　
{
　　
return collection.Find(a => a.Id == ObjectId.Parse(id)).ToList().FirstOrDefault();
　　
}
　　
/// <summary>
　　
/// 查询所有数据
　　
/// </summary>
　　
/// <returns></returns>
　　
public List<T> QueryAll()
　　
{
　　
return collection.Find(a => a.State != "").ToList();
　　
}
　　
/// <summary>
　　
/// 根据条件查询一条数据
　　
/// </summary>
　　
/// <param name="express"></param>
　　
/// <returns></returns>
　　
public T QueryByFirst(Expression<Func<T,bool>> express)
　　
{
　　
return collection.Find(express).ToList().FirstOrDefault();
　　
}
　　
/// <summary>
　　
/// 批量添加
　　
/// </summary>
　　
/// <param name="list"></param>
　　
public void InsertBatch(List<T> list)
　　
{
　　
collection.InsertManyAsync(list);
　　
}
　　
/// <summary>
　　
/// 根据Id批量删除
　　
/// </summary>
　　
public void DeleteBatch(List<ObjectId> list)
　　
{
　　
var filter = Builders<T>.Filter.In("Id", list);
　　
collection.DeleteManyAsync(filter);
　　
}
　　

　　
/// <summary>
　　
/// 未添加到索引的数据
　　
/// </summary>
　　
/// <returns></returns>
　　
public List<T> QueryToLucene()
　　
{
　　
return collection.Find(a => a.State.Equals("y")|| a.State.Equals("n")).ToList();
　　
}
　　
}

　　
public>　　
{
　　
/// <summary>
　　
/// 购方名称
　　
/// </summary>
　　
public string Name { get; set; }
　　
/// <summary>
　　
/// 纳税人识别号
　　
/// </summary>
　　
public string TaxCode { get; set; }
　　
/// <summary>
　　
/// 地址电话
　　
/// </summary>
　　
public string AddressPhone { get; set; }
　　
/// <summary>
　　
/// 开户行及账号
　　
/// </summary>
　　
public string BankAccount { get; set; }
　　
}

　　
public abstract>　　
{

　　
public ObjectId>　　

　　
public string State { get; set; }
　　

　　
public string CreateTime { get; set; }
　　

　　
public string UpdateTime { get; set; }
　　
}
　　
}