MongoDB学习笔记三一C#操作数据库
目标：向数据库插入两条Notes，一个包含标签一个没有，然后通过Update给不包含标签的Notes添加标签

为了完成我们的目标，首先我们的到http://github.com/samus/mongodb-csharp 下载Mongodb的c#驱动，解压缩并打开Visual Studio解决方案，然后编译得到两个DLL的：MongoDB.Driver.dll、MongoDB.Linq.dll 。我们用json.net来实现序列化和反序列化，您可以从这里下载 。

接着我们用vs2010创建一个简单的控制台应用程序，这里提供三种用C#操作MongoDB的方法：1.使用JSON 2.使用序列化/反序列化的Json.Net 3.使用动态代理

一、这里我们创建一个帮助类(MongoJson.cs)来实现数据库Document和C# 实体类之间的映射：

using System.Collections.Generic;
using System.Linq;
using MongoDB.Driver;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;

namespace Pls.MdbIntro
{
public class MongoJson
{
private const string _oidContainerName = "_id";

public T ObjectFrom<T>(Document document)
where T : class, IMongoEntity
{
if (document == null)
return null;

return JsonConvert.DeserializeObject<T>(document.ToString());
}

public Document DocumentFrom(string json)
{
return PopulateDocumentFrom(new Document(), json);
}

public Document DocumentFrom<T>(T item)
where T : class, IMongoEntity
{
return PopulateDocumentFrom(new Document(), item);
}

public Document PopulateDocumentFrom<T>(Document document, T item)
where T : class, IMongoEntity
{
if (item == null)
return document;

var json = JsonConvert.SerializeObject(item, Formatting.None);

return PopulateDocumentFrom(document, json);
}

private Document PopulateDocumentFrom(Document document, string json)
{
var keyValues = JsonConvert.DeserializeObject<Dictionary<string, object>>(json);

foreach (var keyValue in keyValues)
{
var isEmptyKeyField = (
keyValue.Key == _oidContainerName && document[_oidContainerName] != MongoDBNull.Value);

if (isEmptyKeyField)
continue;

var value = keyValue.Value ?? MongoDBNull.Value;

if (value != MongoDBNull.Value)
{
var arrayValue = (keyValue.Value as JArray);
if (arrayValue != null)
value = arrayValue.Select(j => (string)j).ToArray();
}

if (document.Contains(keyValue.Key))
document[keyValue.Key] = value;
else
{
if (value != MongoDBNull.Value)
document.Add(keyValue.Key, value);
}
}

return document;
}
}
}

二、创建Note实体类

public interface IMongoEntity
{
string _id { get; set; }
Oid GetOid();

Document GetAsDocument();
void UpdateFromDocument(Document document);
}



[Serializable]
public class Note
: IMongoEntity
{
public virtual string _id { get; set; }
public virtual string Title { get; set; }
public virtual string Body { get; set; }
public virtual string[] Tags { get; set; }

public virtual Oid GetOid()
{
return new Oid(_id);
}

public virtual Document GetAsDocument()
{
throw new NotImplementedException();
}

public virtual void UpdateFromDocument(Document document)
{
throw new NotImplementedException();
}
}

三、编写测试代码

var json = new MongoJson();
var mongo = new Mongo();

mongo.Connect();


var db = mongo["SimpleNotes"];
db.SendCommand("dropDatabase");
var notes = db["Notes"];

PrintNotes("Initial notes", notes);

//创建一个包含Tags的Note
var firstNoteDocument = json.DocumentFrom("{Title : \"First note using Json.\", Body : \"Some nice text.\", Tags : [\"MongoDB\", \"Getting started\"]}");
notes.Insert(firstNoteDocument);



//创建不包含Tags的Note
var secondNoteDocument = json.DocumentFrom("{Title : \"Second note using Json.\", Body : \"Some nice text.\"}");
notes.Insert(secondNoteDocument);



//查询Tags为空的Note并更新添加Tags
var noteDocument = notes.FindOne(new Document { { "Tags", MongoDBNull.Value } });
noteDocument.Update(json.DocumentFrom("{Tags : [\"The tag\"]}"));

notes.Update(noteDocument);



mongo.Disconnect();