亚洲免费在线-亚洲免费在线播放-亚洲免费在线观看-亚洲免费在线观看视频-亚洲免费在线看-亚洲免费在线视频

C#實現對mongoDB的簡單增刪查改

系統 2710 0

首先添加所需要驅動包(可通過nuget獲得)

using MongoDB.Bson;
using MongoDB.Driver;
using MongoDB.Driver.Builders;

一、設置配置信息

      
        //
      
      
        連接信息
      
      
        static
      
      
        string
      
       conn = 
      
        "
      
      
        mongodb://localhost
      
      
        "
      
      
        ;

        
      
      
        static
      
      
        string
      
       database = 
      
        "
      
      
        test
      
      
        "
      
      
        ;

        
      
      
        static
      
      
        string
      
       collection = 
      
        "
      
      
        person
      
      
        "
      
      
        ;



        
      
      
        static
      
       MongoServer mongodb = MongoServer.Create(conn);
      
        //
      
      
        連接數據庫
      
      
        static
      
       MongoDatabase db = mongodb.GetDatabase(database);
      
        //
      
      
        選擇數據庫名
      
      
        static
      
       MongoCollection mc = db.GetCollection(collection);
      
        //
      
      
        選擇集合,相當于表
      
    

二、插入數據庫

      
        public
      
      
        static
      
      
        void
      
      
         Insert(Person p)

{

  mc.Insert(p);

}




      
      
        public
      
      
        static
      
      
        void
      
      
         Insert(BsonDocument b)  

{

  mc.Insert(b);

}
      
    

三、更新數據庫

      
        public
      
      
        static
      
      
        void
      
      
         Update(Person p)

        {

            BsonDocument bd 
      
      =
      
         BsonExtensionMethods.ToBsonDocument(p);

            IMongoQuery query 
      
      = Query.EQ(
      
        "
      
      
        _id
      
      
        "
      
      
        , p._id);

            mc.Update(query, 
      
      
        new
      
      
         UpdateDocument(bd));

        }



        
      
      
        public
      
      
        static
      
      
        void
      
      
         Update(QueryDocument q,UpdateDocument u)

        {

            mc.Update(q, u);

        }
      
    

?

四、刪除某條記錄

      
        public
      
      
        static
      
      
        void
      
       Delete(
      
        int
      
      
         id)

 {

     mc.Remove(Query.EQ(
      
      
        "
      
      
        _id
      
      
        "
      
      
        , id));

 }
      
    

五、查詢數據庫

      
        public
      
      
        static
      
       Person Find(
      
        int
      
      
         id)

        {

            
      
      
        return
      
       mc.FindOneAs<Person>(Query.EQ(
      
        "
      
      
        _id
      
      
        "
      
      
        , id));

        }



        
      
      
        public
      
      
        static
      
       MongoCursor<Person>
      
         FindAll()

        {

            
      
      
        return
      
       mc.FindAllAs<Person>
      
        ();

        }



        
      
      
        public
      
      
        static
      
       MongoCursor<Person>
      
         Select(QueryDocument q)

        {

            
      
      
        return
      
       mc.FindAs<Person>
      
        (q);

        }
      
    

六、統計數據個數

      
        public
      
      
        static
      
      
        long
      
      
         Count(QueryDocument q)

  {

       
      
      
        return
      
      
         mc.Count(q);

 }
      
    

七、排序和分頁

      
        public
      
      
        static
      
       MongoCursor<Person> SkipAndLimit(
      
        int
      
       a, 
      
        int
      
      
         b)

        {

            
      
      
        return
      
       mc.FindAllAs<Person>
      
        ().SetSkip(a).SetLimit(b);

        }
      
    

?

八、應用與示例

      
        static
      
      
        void
      
       Main(
      
        string
      
      
        [] args)

        {

            mongodb.Connect();



            
      
      
        //
      
      
        var person = Find(124);

            
      
      
        //
      
      
        Console.WriteLine(person.Name);



            
      
      
        //
      
      
        person.Name = "guizhu";

            
      
      
        //
      
      
        Update(person);

            
      
      
        //
      
      
        Console.WriteLine(person.Name);
      
      
        var
      
       query = 
      
        new
      
       QueryDocument { { 
      
        "
      
      
        _id
      
      
        "
      
      ,
      
        13
      
      
        } };

            
      
      
        var
      
       update = 
      
        new
      
       UpdateDocument { { 
      
        "
      
      
        $set
      
      
        "
      
      , 
      
        new
      
       QueryDocument { { 
      
        "
      
      
        PassWord
      
      
        "
      
      , 
      
        "
      
      
        aaaaa
      
      
        "
      
      
         } } } };

            Update(query,update);



            
      
      
        //
      
      
        對象插入

            
      
      
        //
      
      
        Person p = new Person { _id = 12, Name = "hello", PassWord = "4444" };

            
      
      
        //
      
      
        Insert(p);



            
      
      
        //
      
      
        BsonDocument 插入

            
      
      
        //
      
      
        BsonDocument b = new BsonDocument();

            
      
      
        //
      
      
        b.Add("_id", 13);

            
      
      
        //
      
      
        b.Add("Name", "world");

            
      
      
        //
      
      
        b.Add("PassWord", "6666");

            
      
      
        //
      
      
        Insert(b);



            
      
      
        //
      
      
        var p= FindAll();

            
      
      
        //
      
      
        foreach (var person in p)

            
      
      
        //
      
      
        {

            
      
      
        //
      
      
            Console.WriteLine(person.Name);

            
      
      
        //
      
      
        }



            
      
      
        //
      
      
        QueryDocument query = new QueryDocument();

            
      
      
        //
      
      
        BsonDocument b = new BsonDocument();

            
      
      
        //
      
      
        b.Add("$gte", 123);

            
      
      
        //
      
      
        b.Add("$lt", 125);

            
      
      
        //
      
      
        query.Add("_id", b);

            
      
      
        //
      
      
        var p=Select(query);

            
      
      
        //
      
      
        foreach (var person in p)

            
      
      
        //
      
      
        {

            
      
      
        //
      
      
            Console.WriteLine(person.Name);

            
      
      
        //
      
      
        }



            
      
      
        //
      
      
        Console.WriteLine(Count(query));



            
      
      
        //
      
      
        FieldsDocument f = new FieldsDocument();

            
      
      
        //
      
      
        f.Add("Name", 1);

            
      
      
        //
      
      
        MongoCursor<Person> m = mc.FindAs<Person>(query).SetFields(f);

            
      
      
        //
      
      
        foreach (var person in p)

            
      
      
        //
      
      
        {

            
      
      
        //
      
      
            Console.WriteLine(person.Name);

            
      
      
        //
      
      
        }





            
      
      
        //
      
      
        SortByDocument s = new SortByDocument();

            
      
      
        //
      
      
        s.Add("_id", 1);
      
      
        //
      
      
        -1=DESC

            
      
      
        //
      
      
        var p = Sort(s);

            
      
      
        //
      
      
        foreach (var person in p)

            
      
      
        //
      
      
        {

            
      
      
        //
      
      
            Console.WriteLine(person.Name);

            
      
      
        //
      
      
        }



            
      
      
        //
      
      
        var p = SkipAndLimit(1, 3);

            
      
      
        //
      
      
        foreach (var person in p)

            
      
      
        //
      
      
        {

            
      
      
        //
      
      
            Console.WriteLine(person.Name);

            
      
      
        //
      
      
        }

            

            
      
      
        //
      
      
        Delete(12);
      
      

            Console.WriteLine(
      
        "
      
      
        完成
      
      
        "
      
      
        );

            Console.ReadLine();

        }
      
    

?

      
        class
      
      
         Person

    {

        
      
      
        public
      
      
        int
      
      
         _id;

        
      
      
        public
      
      
        string
      
      
         Name;

        
      
      
        public
      
      
        string
      
      
         PassWord;



    }
      
    

源碼下載地址:鏈接:http://pan.baidu.com/s/1c0tlXZi 密碼:1es5

C#實現對mongoDB的簡單增刪查改


更多文章、技術交流、商務合作、聯系博主

微信掃碼或搜索:z360901061

微信掃一掃加我為好友

QQ號聯系: 360901061

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點擊下面給點支持吧,站長非常感激您!手機微信長按不能支付解決辦法:請將微信支付二維碼保存到相冊,切換到微信,然后點擊微信右上角掃一掃功能,選擇支付二維碼完成支付。

【本文對您有幫助就好】

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描上面二維碼支持博主2元、5元、10元、自定義金額等您想捐的金額吧,站長會非常 感謝您的哦!!!

發表我的評論
最新評論 總共0條評論
主站蜘蛛池模板: 九九99九九在线精品视频 | 最新午夜韩国理论片77网 | 欧美一级人与动毛片免费播放 | 高清欧美一级在线观看 | 日本a∨在线播放高清 | 成人在线亚洲 | 国产精品欧美亚洲区 | 草草免费观看视频在线 | 日韩午夜伦 | 色偷偷久久一区二区三区 | 日本在线色视频 | 激情综合在线观看 | 久草在线视频免费 | 愉拍自拍| 久久国产乱子伦精品免费一 | 91精品成人免费国产片 | 国产 日韩 一区 | 久久成人国产精品青青 | 亚洲精品在线播放视频 | 久久久夜间小视频 | 在线精品国产第一页 | 韩国午夜剧场 | 国产成人精品三区 | 亚洲综合欧美日韩 | 国产末成年女av片 | 18在线观看| 中文字幕在线免费视频 | 精品一区二区久久久久久久网精 | 99久久免费费视频在线观看 | 香蕉久久国产 | a一级日本特黄aaa大片 | 成人另类| 久久这里只有精品免费视频 | 国产做受视频激情播放 | 色综合小说天天综合网 | 欧美性xxxx偷拍 | 激情五月婷婷综合网 | 国产成人丝袜精品自啪在线 | 久久三级视频 | 久久久久久综合一区中文字幕 | 日日操日日 |