Mongodb-使用C#Drivers实现增删改查(二)

2015-11-21 01:52:10 · 作者: · 浏览: 13
nect(); } } }

6.实现增删改查

6.1 了解

如果你看前面的在命令行下操作mongodb的话,就开始6.3吧!

6.2 建立连接

实例化 连接类,声明数据库名,和集合名!
            string dbname = "student";
            string colName = "yuan";
            Connection conn = new Connection(dbname);

6.3 创建集合

调用创建方法
         bool type= conn.createCollection(colName);
            if (type)
            {
                Console.WriteLine("创建成功!");
            }
            else 
            {
                Console.WriteLine("创建失败!");
            }

            Console.ReadKey();

6.4 插入单条信息

      BsonDocument bson = new BsonDocument("name","csdn");
            bool type= conn.insert(colName, bson);
            if (type)
            {
                Console.WriteLine("增加数据成功!");
            }
            else
            {
                Console.WriteLine("增加数据成功失败!");
            }

6.5 插入多条信息

  Dictionary
  
    dic=new Dictionary
   
    (); dic.Add("name","ming"); dic.Add("age","23"); dic.Add("collage","hpu"); dic.Add("sno","31120907"); Dictionary
    
      dic1 = new Dictionary
     
      (); dic1.Add("name", "zhuo"); dic1.Add("age", "10"); dic1.Add("collage", "hpu"); dic1.Add("sno", "31120908"); List
      
        list = new List
       
        () { new BsonDocument(dic), new BsonDocument(dic1) }; bool type=conn.insert(colName, list); if (type) { Console.WriteLine("增加数据成功!"); } else { Console.WriteLine("增加数据成功失败!"); } Console.ReadKey();
       
      
     
    
   
  

6.6 简单查询

     MongoCursor
  
    cursor = conn.select(colName, null);
            foreach (BsonDocument bson in cursor)
            {
                Console.WriteLine(bson.ToString());
            }
            Console.ReadKey();
  

结果如下: \

6.7 条件查询

    //条件查询
            QueryDocument query = new QueryDocument("collage", "hpu");
            MongoCursor
  
    cursor = conn.select(colName, query);
            foreach (BsonDocument bson in cursor)
            {
                Console.WriteLine(bson.ToString());
            }
            Console.ReadKey();
  

结果如下: \

6.8 修改操作

    QueryDocument query = new QueryDocument("name", "zhuo");
            Dictionary
  
    dic1 = new Dictionary
   
    (); dic1.Add("name", "zhuo"); dic1.Add("age", "23"); dic1.Add("collage", "hpu"); dic1.Add("sno", "31120908"); UpdateDocument upd = new UpdateDocument(dic1); bool type = conn.update(colName, query, upd); if (type) { Console.WriteLine("修改数据成功!"); } else { Console.WriteLine("修改数据失败!"); } //查看修改信息 QueryDocument query1 = new QueryDocument("name", "zhuo"); MongoCursor
    
      cursor = conn.select(colName, query1); foreach (BsonDocument bson in cursor) { Console.WriteLine(bson.ToString()); } Console.ReadKey();
    
   
  

结果如下: \

6.9 删除操作


            //先查询下全部
            Console.WriteLine("我是全部");
            MongoCursor
  
    cursor = conn.select(colName, null);
            foreach (BsonDocument bson in cursor)
            {
                Console.WriteLine(bson.ToString());
            }

            //删除age等于23的
            QueryDocument query = new QueryDocument("age","23");
            //第三个参数 为0时删除满足条件的所有,为其他数字是,仅删除1条
            bool type=conn.delete(colName, query, 1);

            Console.WriteLine("我是删除后的!");
            MongoCursor
   
     cursor1 = conn.select(colName, null); foreach (BsonDocument bson in cursor1) { Console.WriteLine(bson.ToString()); }
   
  

效果图如下:

\

7.总结 :这里仅仅演示了简单的增删改查,后面,大量的条件查询,还行练习

8. demo 下载

?