C#版的mongodb最新的官方驱动2.4.0版本

时间 2019-11-16

标签 c# mongodb 最新官方驱动 2.4.0 版本栏目 C# 繁體版

原文原文链接

已经升级了mongodb至最新的3.4的版本，我想一想也该把驱动升到最新的了，我用的驱动仍是1.7的版本呢，以前几回想升级，都是由于升级驱动须要改动的代码太大了，升级的成本很高，因此懒得动，就这么的用了几年了。可是如今出了不少新功能，若是不升级的话，根本用不了，好比Lookup等功能。想一想咬牙就升级了。驱动DLL一换，就发现代码全报错了。之前的IMongoQuery等方法全用不了的。有一些方法也不见了，在修改的过程当中，只能写边修改边写代码测试，一个一个测试它提供的新方法。等了解了新的驱动后，以为改动仍是很是大的，将Query，Update等都集成到了一个叫Builders的类中了，把Update中有关SetWrapped的方法全删了，最后试了半天，才发现，SetWrapped的方法，能够直接用新方法中的Set就能够搞定了，而AddToSetWrapped方法只须要用AddToSet方法就好了。程序员

带给个人最大震憾是，新的写法能够彻底用LINQ搞定，终于不用再去管mongodb的那个实体类的映射了，在操做中，彻底用类的字段就能够搞定，我把的一个类的方法贴出来供你们参考一下。mongodb

    public class Content
    {
        [BsonId]
        public ObjectId Id { get; set; }
        [BsonElement("t")]
        public string Title { get; set; } 

        [BsonElement("d")]
        public string Detail { get; set; } 

        [BsonElement("a")]
        public string Author { get; set; } 


        [BsonElement("ct")]
        public double CreateTime { get; set; } 

        [BsonElement("click")]
        public int Click { get; set; } 

        [BsonElement("img")]
        public string Img { get; set; }

        [BsonElement("f")]
        public bool IsFinished { get; set; } 

        [BsonElement("type")]
        public int Type { get; set; } 
    }

老的操做类的土鳖方法是这样的数据库

   public class ContentInfo : DBBase
    {
        public static void InsertContent(string title, string detail, string author, string img, int type)
        {
            Content k = new Content
            {
                Author = author,
                Detail = detail,
                Img = img,
                Title = title,
                Click = 0,
                Type = type,
                CreateTime = ((DateTime.Now.ToUniversalTime().Ticks - 621355968000000000) / 10000000)
            };
            try
            {
                var collection = _database.GetCollection<Content>("content");
                collection.Insert(k);
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
            }
        }


        public static void UpdateContent(string id, string title, string detail, string author, string img, int type)
        {
            var collection = _database.GetCollection<Content>("content");
            IMongoQuery query = Query.EQ("_id", new ObjectId(id));
            UpdateBuilder up = new UpdateBuilder();
            up.Set("t", title);
            up.Set("d", detail);
            up.Set("a", author);
            up.Set("img", img);
            up.Set("type", type);
            collection.Update(query, up, UpdateFlags.Upsert);
        }


        public static Content Get(string id)
        {
            var collection = _database.GetCollection<Content>("content");
            IMongoQuery query = Query.EQ("_id", new ObjectId(id));
            IMongoUpdate update = Update.Inc("click", 1);
            collection.Update(query, update);
            var results = collection.FindOneAs<Content>(query);
            return results;
        }
        public static List<Content> GetContentList(int pageIndex, int pageSize, out int count, bool isShow = true)
        {

            var collection = _database.GetCollection<Content>("content");
            IMongoQuery query = Query.GT("click", -100);
            if (isShow)
            {
                query = Query.And(query, Query.EQ("f", true));
            }

            SortByDocument sort = new SortByDocument { { "ct", -1 } };
            var num = collection.Count(query);
            count = Convert.ToInt32(num);
            var results = collection.FindAs<Content>(query).SetSortOrder(sort).SetSkip((pageIndex - 1) * pageSize).SetLimit(pageSize);
            return results.ToList();

        }

        public static List<Content> GetContentTypeList(int type, int pageIndex, int pageSize, out int count)
        {

            var collection = _database.GetCollection<Content>("content");
            IMongoQuery query = Query.GT("click", -100);

            query = Query.And(query, Query.EQ("f", true));
            query = Query.And(query, Query.EQ("type", type));

            SortByDocument sort = new SortByDocument { { "ct", -1 } };
            var num = collection.Count(query);
            count = Convert.ToInt32(num);
            var results = collection.FindAs<Content>(query).SetSortOrder(sort).SetSkip((pageIndex - 1) * pageSize).SetLimit(pageSize);
            return results.ToList();

        }



        public static List<Content> GetContentSiteMap()
        {
            var collection = _database.GetCollection<Content>("content");
            IMongoQuery query = Query.GT("click", -100);

            query = Query.And(query, Query.EQ("f", true));


            SortByDocument sort = new SortByDocument { { "ct", -1 } };
            FieldsDocument fd = new FieldsDocument();
            fd.Add("d", 0);
            var results = collection.FindAs<Content>(query).SetFields(fd).SetSortOrder(sort);
            return results.ToList();
        }




        public static void UpdateContentTrue(string id)
        {
            var collection = _database.GetCollection<Content>("content");
            IMongoQuery query = Query.EQ("_id", new ObjectId(id));
            UpdateBuilder up = new UpdateBuilder();
            up.Set("f", true);
            up.Set("ct", ((DateTime.Now.ToUniversalTime().Ticks - 621355968000000000) / 10000000));
            collection.Update(query, up, UpdateFlags.Upsert);
        }
　　}

而新的方法是这样的：app

   public class ContentInfo : DBBase
    {
        public static void InsertContent(string title, string detail, string author, string img, int type)
        {
            Content k = new Content
            {
                Author = author,
                Detail = detail,
                Img = img,
                Title = title,
                Click = 0,
                Type = type,
                CreateTime = ((DateTime.Now.ToUniversalTime().Ticks - 621355968000000000) / 10000000)
            };
            try
            {
                var collection = _database.GetCollection<Content>("content");
                collection.InsertOne(k);
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
            }
        }


        public static void UpdateContent(string id, string title, string detail, string author, string img, int type)
        {
            var collection = _database.GetCollection<Content>("content");
            var filter = Builders<Content>.Filter.Eq(x => x.Id, new ObjectId(id));
            var up = Builders<Content>.Update
            .Set(x => x.Title, title)
            .Set(x => x.Detail, detail)
            .Set(x => x.Author, author)
            .Set(x => x.Img, img)
            .Set(x => x.Type, type);

            collection.UpdateOneAsync(filter, up);
        }


        public static Content Get(string id)
        {
            var collection = _database.GetCollection<Content>("content");
            var filter = Builders<Content>.Filter.Eq(x => x.Id, new ObjectId(id));
            var up = Builders<Content>.Update.Inc(x => x.Click, 1);
            var results = collection.FindOneAndUpdate(filter, up);
            return results;
        }
        public static List<Content> GetContentList(int pageIndex, int pageSize, out int count, bool isShow = true)
        {

            var collection = _database.GetCollection<Content>("content");

            var builder = Builders<Content>.Filter;
            var filter = builder.Gt(x => x.Click, -100);

            if (isShow)
            {
                filter = builder.And(filter, builder.Eq(x => x.IsFinished, true));
            }

            var sort = Builders<Content>.Sort.Descending(x => x.CreateTime);



            var num = collection.Count(filter);
            count = Convert.ToInt32(num);
            var results = collection.Find(filter).Sort(sort).Skip((pageIndex - 1) * pageSize).Limit(pageSize);
            return results.ToList();

        }

        public static List<Content> GetContentTypeList(int type, int pageIndex, int pageSize, out int count)
        {

            var collection = _database.GetCollection<Content>("content");
            var filter = Builders<Content>.Filter.Where(x => x.Click > -100 && x.IsFinished == true && x.Type == type);

            var sort = Builders<Content>.Sort.Descending(x => x.CreateTime);

            var num = collection.Count(filter);
            count = Convert.ToInt32(num);
            var results = collection.Find(filter).Sort(sort).Skip((pageIndex - 1) * pageSize).Limit(pageSize);
            return results.ToList();

        }



        public static List<Content> GetContentSiteMap()
        {
            var collection = _database.GetCollection<Content>("content");
            var filter = Builders<Content>.Filter.Where(x => x.Click > -100 && x.IsFinished == true);

            var sort = Builders<Content>.Sort.Descending(x => x.CreateTime);

            var project = Builders<Content>.Projection.Exclude(x => x.Detail);

            var results = collection.Find(filter).Project<Content>(project).Sort(sort);
            return results.ToList();
        }




        public static void UpdateContentTrue(string id)
        {
            var collection = _database.GetCollection<Content>("content");
            var filter = Builders<Content>.Filter.Eq(x => x.Id, new ObjectId(id));
            var up = Builders<Content>.Update
                .Set(x => x.IsFinished, true)
                .Set(x => x.CreateTime, ((DateTime.Now.ToUniversalTime().Ticks - 621355968000000000) / 10000000));

            var results = collection.FindOneAndUpdate(filter, up);
        }

    }

新的里面已经彻底看不到了mongodb数据库中的字段名了，彻底能够用lambda表达式完成这些操做了，对程序员来讲，操做简便了，不须要再去对照映射关系了，也下降了一些程序员的入门门槛，有些基础的操做，程序员甚至不须要了解mongodb，只要会写LINQ就能够完成了。这么多的好处，我以为将数据库和驱动都升级到最新版仍是挺值的。可是注意，1.X版本的驱动和2.X版本的驱动是彻底不同的，是破坏性升级，若是想要更换这个驱动，代码是必定要从新写的，因此你们也别光看到好处，也要计算一下成本。测试