Mongodb c#增删改查

  1. 云栖社区>
  2. 博客>
  3. 正文

Mongodb c#增删改查

ghost丶桃子 2016-05-24 11:52:49 浏览3431
展开阅读全文

写在前面

最近项目需要,就研究了下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)
 6         {
 7             //创建mogodb对象
 8             using (Mongo mongo = new Mongo(_connectionString))
 9             {
10                 //连接mongodb
11                 mongo.Connect();
12                 //获得要操作的数据库
13                 var db = mongo.GetDatabase(_dbName);
14                 //获取要操作的Collection
15                 var collection = db.GetCollection<Customer>();
16                 collection.Insert(customer);              
17             }
18         }
19         /// <summary>
20         /// 批量添加
21         /// </summary>
22         /// <param name="lstCustomer"></param>
23         private static void InsertList(List<Customer> lstCustomer)
24         {
25             using (Mongo mongo = new Mongo(_connectionString))
26             {
27                 mongo.Connect();
28                 var db = mongo.GetDatabase(_dbName);
29                 var collection = db.GetCollection<Customer>();
30                 collection.Insert(lstCustomer);
31             }
32         }
33         /// <summary>
34         /// 更新
35         /// </summary>
36         /// <param name="customer"></param>
37         private static void Update(Customer customer)
38         {
39             using (Mongo mongo = new Mongo(_connectionString))
40             {
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));
46             }
47         }
48         /// <summary>
49         /// 获取所有的customer
50         /// </summary>
51         /// <returns></returns>
52         private static IList<Customer> GetList()
53         {
54             using (Mongo mongo = new Mongo(_connectionString))
55             {
56                 mongo.Connect();
57                 var db = mongo.GetDatabase(_dbName);
58                 var collection = db.GetCollection<Customer>();
59                 ICursor<Customer> mogoCollection = collection.FindAll();
60               
61                 return mogoCollection.Documents.ToList();
62             }
63         }
64         /// <summary>
65         /// 根据id获取单个对象
66         /// </summary>
67         /// <param name="customerId"></param>
68         /// <returns></returns>
69         private static Customer GetById(string customerId)
70         {
71             using (Mongo mongo = new Mongo(_connectionString))
72             {
73                 mongo.Connect();
74                 var db = mongo.GetDatabase(_dbName);
75                 var collection = db.GetCollection<Customer>();
76                 return collection.FindOne(x => x.CustomerID == customerId);
77             }
78         }
79     }
80     [Serializable]
81     class Customer
82     {
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)
 2         {
 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/
博客版权: 本文以学习、研究和分享为主,欢迎转载,但必须在文章页面明显位置给出原文连接。
如果文中有不妥或者错误的地方还望高手的你指出,以免误人子弟。如果觉得本文对你有所帮助不如【推荐】一下!如果你有更好的建议,不如留言一起讨论,共同进步!
再次感谢您耐心的读完本篇文章。http://www.cnblogs.com/wolf-sun/p/4455469.html

网友评论

登录后评论
0/500
评论
ghost丶桃子
+ 关注