1、下载驱动：
如下图：选择c#解决方案，右键，点击 “管理NuGet程序包(N)...”
在弹出的对话框中，输入MongoDB.Driver,进行搜索，然后选择安装。
2、引用命名空间：
using MongoDB.Bson;
using MongoDB.Driver;
using MongoDB.Driver.Core;
3、程序代码
配置文件：
public class iCTRMongodbCache : CacheBase
{
IMongoCollection<BsonDocument> _collect;
IMongoDatabase _db;
string _collectionName = "";
/// <summary>
/// 默认搜索列字段名称
/// </summary>
string defaultColumn = ConfigurationManager.AppSettings["DefaultColumn"].ToString();
/// <summary>
/// 构造函数
/// </summary>
/// <param name="collectionName">集合名称，类似关系型数据库中的表名</param>
public iCTRMongodbCache(string collectionName)
: base(collectionName)
{
_collectionName = collectionName;
string mongoDB_Host = ConfigurationManager.AppSettings["MongoDB_Host"].ToString();
string mongoDB_DbName = ConfigurationManager.AppSettings["MongoDB_DbName"].ToString();
string mongoDB_UserName = ConfigurationManager.AppSettings["MongoDB_UserName"].ToString();
string mongoDB_Password = ConfigurationManager.AppSettings["MongoDB_Password"].ToString();
MongoDB.Driver.MongoClient mc = new MongoClient(mongoDB_Host);
_db = mc.GetDatabase(mongoDB_DbName);
_collect = _db.GetCollection<BsonDocument>(collectionName);
}
public override bool Append(string keyValue, string value)
{
if (string.IsNullOrEmpty(value) || value.IndexOf(":") < 0)
{
return false;
}
Dictionary<string, string> dictR = new Dictionary<string, string>();
dictR.Add(defaultColumn, keyValue);
try
{
string[] values = value.Split(‘,‘);
foreach (string keyv in values)
{
dictR.Add(keyv.Split(‘:‘)[0], keyv.Split(‘:‘)[1]);
}
BsonDocument bd = new BsonDocument();
bd.AddRange(dictR);
_collect.InsertOne(bd);
}
catch (System.InvalidOperationException ex)
{
throw ex;
}
return true;
}
public override object Get(string keyValue)
{
Dictionary<string,object> dict =new Dictionary<string,object>();
dict.Add(defaultColumn, keyValue);
var query = new BsonDocument(dict);
IAsyncCursor<BsonDocument> result = _collect.FindSync(query);
List<BsonDocument> list = null;
if (result.MoveNext())
{
list = result.Current as List<BsonDocument>;
}
return list;
}
public override T Get<T>(string keyValue)
{
Dictionary<string, object> dict = new Dictionary<string, object>();
dict.Add(defaultColumn, keyValue);
var query = new BsonDocument(dict);
IAsyncCursor<BsonDocument> result = _collect.FindSync(query);
if (result.MoveNext())
{
List<BsonDocument> list = result.Current as List<BsonDocument>;
if (list != null)
{
BsonDocument bd = list[0];
bd.Remove("_id");
bd.Remove(defaultColumn);
JavaScriptSerializer Serializer = new JavaScriptSerializer();
Serializer.MaxJsonLength = int.MaxValue;
return Serializer.Deserialize<T>(bd.ToString());
}
else
{
return default(T);
}
}
else
{
return default(T);
}
}
public override void Set(string keyValue, object value, DateTime expiration)
{
Dictionary<string, object> dictR = new Dictionary<string, object>();
dictR.Add(defaultColumn, keyValue);
try
{
BsonDocument bd = value.ToBsonDocument();
bd.AddRange(dictR);
_collect.InsertOne(bd);
}
catch (System.InvalidOperationException ex)
{
throw ex;
}
}
public override void Set<T>(string keyValue, T value)
{
Dictionary<string, object> dictR = new Dictionary<string, object>();
dictR.Add(defaultColumn, keyValue);
try
{
BsonDocument bd = value.ToBsonDocument<T>();
bd.AddRange(dictR);
_collect.InsertOne(bd);
}
catch (System.InvalidOperationException ex)
{
throw ex;
}
}
public override void Remove(string key)
{
Dictionary<string, object> dictR = new Dictionary<string, object>();
dictR.Add(defaultColumn, key);
_collect.DeleteOne(new BsonDocument(dictR));
}
public override void Clear()
{
_db.DropCollection(_collectionName);
}
public override void Dispose()
{
_db.DropCollection(_collectionName);
_collect = null;
}
}
4、测试代码
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Microsoft.VisualStudio.TestTools.UnitTesting;
using MongodbCache.Caching;
namespace UnitTest
{
[TestClass]
public class iCTRMongodbCacheTest
{
private iCTRMongodbCache _cache;
public iCTRMongodbCacheTest()
{
_cache = new iCTRMongodbCache("test1");
}
[TestMethod]
public void TestAppend()
{
//ID454为主键字段对应的数据，"age:43,name:Marry为要插入的数据，
//调用缓存的Append方法，第二个参数必须为类似"column1 : column1Value,column2 : column2Value "的数据
_cache.Append("ID1", "age:43,name:Marry");
}
[TestMethod]
public void TestSet1()
{
Dictionary<string, string> dict = new Dictionary<string, string>();
dict.Add("age", "12");
dict.Add("Name", "Marry");
_cache.Set("ID2", dict);
}
[TestMethod]
public void TestSet2()
{
student s = new student();
s.age = 234;
s.name = "lengli";
_cache.Set<student>("ID3", s);
}
[TestMethod]
public void TestRemove()
{
string ID = "ID1";
_cache.Remove(ID);
}
[TestMethod]
public void TestGet1()
{
object obj = _cache.Get("ID2");
}
[TestMethod]
public void TestGet2()
{
student dd = _cache.Get<student>("ID3");
}
[TestMethod]
public void TestClear()
{
_cache.Clear();
}
[TestClass]
class student
{
public string name
{
get;
set;
}
public int age
{
get;
set;
}
}
}
}