在C#中使用官方驱动操作MongoDB

8.3）插入数据：

好了数据打开了，现在得添加数据了，我们要添加一条User“记录”到 Users集合中。

在MongoDB中没有表的概念，所以在插入数据之前不需要创建表。

但我们得定义好要插入的数据的模型Users

Users.cs：

  public class Users
    {
        public ObjectId _id;//BsonType.ObjectId 这个对应了 MongoDB.Bson.ObjectId 
 　　　　public string Name { get; set; }
        public string Sex { set; get; }
    }

	_id 属性必须要有，否则在更新数据时会报错:“Element '_id' does not match any field or property of class”。 


	 好，现在看看添加数据的代码怎么写：


	


public void Insert()
{
    //创建数据库链接
 MongoServer server = MongoDB.Driver.MongoServer.Create(strconn);
    //获得数据库cnblogs
 MongoDatabase db = server.GetDatabase(dbName);
    Users users = new Users();
    users.Name = "xumingxiang";
    users.Sex = "man";
    //获得Users集合,如果数据库中没有，先新建一个
 MongoCollection col = db.GetCollection("Users");
    //执行插入操作
 col.Insert<Users>(users);
}
8.4）更新数据 

	



	


public void Update()
{
    //创建数据库链接
 MongoServer server = MongoDB.Driver.MongoServer.Create(strconn);
    //获得数据库cnblogs
 MongoDatabase db = server.GetDatabase(dbName);
    //获取Users集合
 MongoCollection col = db.GetCollection("Users");
    //定义获取“Name”值为“xumingxiang”的查询条件
 var query = new QueryDocument { { "Name", "xumingxiang" } };
    //定义更新文档
 var update = new UpdateDocument { { "$set", new QueryDocument { { "Sex", "wowen" } } } };
    //执行更新操作
 col.Update(query, update);
}
8.5)删除数据 

	



	


public void Delete()
{
    //创建数据库链接
 MongoServer server = MongoDB.Driver.MongoServer.Create(strconn);
    //获得数据库cnblogs
 MongoDatabase db = server.GetDatabase(dbName);
    //获取Users集合
 MongoCollection col = db.GetCollection("Users");
    //定义获取“Name”值为“xumingxiang”的查询条件
 var query = new QueryDocument { { "Name", "xumingxiang" } };
    //执行删除操作
 col.Remove(query);
}
8.6）查询数据 

	



	  

public void Query()
{
    //创建数据库链接
 MongoServer server = MongoDB.Driver.MongoServer.Create(strconn);
    //获得数据库cnblogs
 MongoDatabase db = server.GetDatabase(dbName);
    //获取Users集合
 MongoCollection col = db.GetCollection("Users");
    //定义获取“Name”值为“xumingxiang”的查询条件
 var query = new QueryDocument { { "Name", "xumingxiang" } };
          
    //查询全部集合里的数据
 var result1 = col.FindAllAs<Users>();
    //查询指定查询条件的第一条数据，查询条件可缺省。
 var result2 = col.FindOneAs<Users>();
    //查询指定查询条件的全部数据
 var result3 = col.FindAs<Users>(query);
}
MongoDb在C#中使用 

	



	 

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Runtime.Serialization;
using System.Data;
using System.Data.SqlClient;
using MongoDB.Bson;
using MongoDB.Driver;

namespace ConsoleApplication1
{
    class Program
    {
        static void Main(string[] args)
        {
            //连接信息
            string conn = "mongodb://localhost";
            string database = "demoBase";
            string collection = "demoCollection";

            MongoServer mongodb = MongoServer.Create(conn);//连接数据库
            MongoDatabase mongoDataBase = mongodb.GetDatabase(database);//选择数据库名
            MongoCollection mongoCollection = mongoDataBase.GetCollection(collection);//选择集合，相当于表

            mongodb.Connect();

            //普通插入
            var o = new { Uid = 123, Name = "xixiNormal", PassWord = "111111" };
            mongoCollection.Insert(o);

            //对象插入
            Person p = new Person { Uid = 124, Name = "xixiObject", PassWord = "222222" };
            mongoCollection.Insert(p);

            //BsonDocument 插入
            BsonDocument b = new BsonDocument();
            b.Add("Uid", 125);
            b.Add("Name", "xixiBson");
            b.Add("PassWord", "333333");
            mongoCollection.Insert(b);

            Console.ReadLine();
        }
    }

    class Person {
        public int Uid;
        public string Name;
        public string PassWord;

    }
}