首页 / C# / Mongodb c#增删改查
Mongodb c#增删改查
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了Mongodb c#增删改查，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含4514字，纯文字阅读大概需要7分钟。
内容图文
写在前面
最近项目需要，就研究了下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";
5privatestaticreadonlystring _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//连接mongodb11 mongo.Connect();
12//获得要操作的数据库13var db = mongo.GetDatabase(_dbName);
14//获取要操作的Collection15var collection = db.GetCollection<Customer>();
16 collection.Insert(customer);
17 }
18 }
19///<summary>20/// 批量添加
21///</summary>22///<param name="lstCustomer"></param>23privatestaticvoid InsertList(List<Customer> lstCustomer)
24 {
25using (Mongo mongo = new Mongo(_connectionString))
26 {
27 mongo.Connect();
28var db = mongo.GetDatabase(_dbName);
29var collection = db.GetCollection<Customer>();
30 collection.Insert(lstCustomer);
31 }
32 }
33///<summary>34/// 更新
35///</summary>36///<param name="customer"></param>37privatestaticvoid Update(Customer customer)
38 {
39using (Mongo mongo = new Mongo(_connectionString))
40 {
41 mongo.Connect();
42var db = mongo.GetDatabase(_dbName);
43var 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>52privatestatic IList<Customer> GetList()
53 {
54using (Mongo mongo = new Mongo(_connectionString))
55 {
56 mongo.Connect();
57var db = mongo.GetDatabase(_dbName);
58var collection = db.GetCollection<Customer>();
59 ICursor<Customer> mogoCollection = collection.FindAll();
6061return mogoCollection.Documents.ToList();
62 }
63 }
64///<summary>65/// 根据id获取单个对象
66///</summary>67///<param name="customerId"></param>68///<returns></returns>69privatestatic Customer GetById(string customerId)
70 {
71using (Mongo mongo = new Mongo(_connectionString))
72 {
73 mongo.Connect();
74var db = mongo.GetDatabase(_dbName);
75var collection = db.GetCollection<Customer>();
76return collection.FindOne(x => x.CustomerID == customerId);
77 }
78 }
79 }
80 [Serializable]
81class Customer
82 {
83 [MongoId]
84publicstring CustomerID { set; get; }
85publicstring CustomerName { set; get; }
86publicstring ContactName { set; get; }
87publicstring Address { set; get; }
88publicstring PostalCode { set; get; }
89publicstring 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#endregion20#region 更新
21//更新需要先将该对象查询出，然后更新修改的值，不然其他的值为null
22//Update(new Customer() { CustomerID = "08dca525-fb6d-4984-a55f-53723a6ce39c", ContactName = "wolfy22222" });23#endregion24#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#endregion30 Console.Read();
31 }
总结
到这里就结束了，这里弄了一个简单例子，算是快速上手的例子。
原文：http://www.cnblogs.com/wolf-sun/p/4455469.html
内容总结
以上是互联网集市为您收集整理的Mongodb c#增删改查全部内容，希望文章能够帮你解决Mongodb c#增删改查所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。