Mongodb c#增删改查

最近项目需要，就研究了下mongodb，也是为了快速上手，就自己弄了一个简单的例子，这里记录一下。

Mongodb

传统的关系数据库一般由数据库（database）、表（table）、记录（record）三个层次概念组成，MongoDB是由数据库（database）、集合（collection）、文档对象（document）三个层次组成。MongoDB对于关系型数据库里的表，但是集合中没有列、行和关系概念，这体现了模式自由的特点。

那么在c#如何使用呢？下面看个例子，你会发现上手非常简单。

要操作数据库，首先考虑的就是连接字符串的问题，因为这就相当于你从那儿拿数据，先要有路子才行。

MongoDB 标准连接字符串

mongodb://[username:password@]host1[:port1][,host2[:port2],…[,hostN[:portN]]][/[database][?options]]

mongodb:// 是连接字串必须的前缀字串。

username:password@ 可选项，连接到数据库后会尝试验证登陆。

host1 必须的指定至少一个host。

:portX 可选项，默认连接到27017

/database 如果指定username:password@，连接并验证登陆指定数据库。若不指定，默认打开admin数据库。

?options 是连接选项。如果不使用/database，则前面需要加上/。所有连接选项都是键值对name=value，键值对之间通过 （分号）隔开。

关于options可参考官网的东西。

说这些不如先上个例子，先上手实践一下。

1 /// summary 

2 /// 连接字符串

3 /// /summary 

4 private static readonly string _connectionString = "mongodb://sa:sa@192.168.1.105:27017/Test_mongo";

5 private static readonly string _dbName = "Test_mongo";

在c#中使用Mongodb需要引入如下的dll
采用Nuget进行安装就可以了。

增删改查的代码如下：

 1 /// summary 

 2 /// 新增

 3 /// /summary 

 4 /// param name="customer" /param 

 5 private static void Insert(Customer customer)

 7 //创建mogodb对象

 8 using (Mongo mongo = new Mongo(_connectionString))

10 //连接mongodb

11 mongo.Connect();

12 //获得要操作的数据库

13 var db = mongo.GetDatabase(_dbName);

14 //获取要操作的Collection

15 var collection = db.GetCollection Customer ();

16 collection.Insert(customer); 

19 /// summary 

20 /// 批量添加

21 /// /summary 

22 /// param name="lstCustomer" /param 

23 private static void InsertList(List Customer lstCustomer)

25 using (Mongo mongo = new Mongo(_connectionString))

27 mongo.Connect();

28 var db = mongo.GetDatabase(_dbName);

29 var collection = db.GetCollection Customer ();

30 collection.Insert(lstCustomer);

33 /// summary 

34 /// 更新

35 /// /summary 

36 /// param name="customer" /param 

37 private static void Update(Customer customer)

39 using (Mongo mongo = new Mongo(_connectionString))

41 mongo.Connect();

42 var db = mongo.GetDatabase(_dbName);

43 var collection = db.GetCollection Customer ();

44 //更新对象

45 collection.Update(customer, (x = x.CustomerID == customer.CustomerID));

48 /// summary 

49 /// 获取所有的customer

50 /// /summary 

51 /// returns /returns 

52 private static IList Customer GetList()

54 using (Mongo mongo = new Mongo(_connectionString))

56 mongo.Connect();

57 var db = mongo.GetDatabase(_dbName);

58 var collection = db.GetCollection Customer ();

59 ICursor Customer mogoCollection = collection.FindAll();

61 return mogoCollection.Documents.ToList();

64 /// summary 

65 /// 根据id获取单个对象

66 /// /summary 

67 /// param name="customerId" /param 

68 /// returns /returns 

69 private static Customer GetById(string customerId)

71 using (Mongo mongo = new Mongo(_connectionString))

73 mongo.Connect();

74 var db = mongo.GetDatabase(_dbName);

75 var collection = db.GetCollection Customer ();

76 return collection.FindOne(x = x.CustomerID == customerId);

80 [Serializable]

81 class Customer

83 [MongoId]

84 public string CustomerID { set; get; }

85 public string CustomerName { set; get; }

86 public string ContactName { set; get; }

87 public string Address { set; get; }

88 public string PostalCode { set; get; }

89 public string Tel { set; get; }

90 }

测试

 1 static void Main(string[] args)

 3 #region 批量插入

 4 //List Customer list = new List Customer 

 5 //for (int i = 0; i 100; i++)

 6 //{

 7 // Customer customer = new Customer()

 8 // {

 9 // CustomerID = Guid.NewGuid().ToString(),

10 // Address = "北京" + i.ToString(),

11 // CustomerName = "wolfy" + i.ToString(),

12 // Tel = "123" + i.ToString(),

13 // PostalCode = "221212" + i.ToString(),

14 // ContactName = "wolfy" + i.ToString()

15 // };

16 // list.Add(customer);

17 //}

18 //InsertList(list); 

19 #endregion

20 #region 更新

21 //更新需要先将该对象查询出，然后更新修改的值，不然其他的值为null

22 //Update(new Customer() { CustomerID = "08dca525-fb6d-4984-a55f-53723a6ce39c", ContactName = "wolfy22222" });

23 #endregion

24 #region 查询单个对象和集合

25 //Customer customer = GetById("8211501b-4341-4acb-b2fa-d6a714765443");

26 //Console.WriteLine(new JavaScriptSerializer().Serialize(customer));

27 List Customer customers = GetList().ToList();

28 Console.WriteLine(new JavaScriptSerializer().Serialize(customers));

29 #endregion

30 Console.Read();

31 }

总结    

到这里就结束了，这里弄了一个简单例子，算是快速上手的例子。

 

博客版权： 本文以学习、研究和分享为主，欢迎转载，但必须在文章页面明显位置给出原文连接。
如果文中有不妥或者错误的地方还望高手的你指出，以免误人子弟。如果觉得本文对你有所帮助不如【推荐】一下！如果你有更好的建议，不如留言一起讨论，共同进步！
再次感谢您耐心的读完本篇文章。http://www.cnblogs.com/wolf-sun/p/4455469.html