Mongodb c#增刪改查

寫在前面

最近項目需要，就研究了下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可參考官網的東西。

說這些不如先上個例子，先上手實踐一下。

         /// <summary>
        /// 連接字符串
        /// </summary>
        private static readonly string _connectionString = "mongodb://sa:sa@192.168.1.105:27017/Test_mongo";
        private static readonly string _dbName = "Test_mongo";

在c#中使用Mongodb需要引入如下的dll
采用Nuget進行安裝就可以了。

增刪改查的代碼如下：

       /// <summary>
        /// 新增
        /// </summary>
        /// <param name="customer"></param>
        private static void Insert(Customer customer)
        {
            //創建mogodb對象
            using (Mongo mongo = new Mongo(_connectionString))
            {
                //連接mongodb
                mongo.Connect();
                //獲得要操作的數據庫
                var db = mongo.GetDatabase(_dbName);
                //獲取要操作的Collection
                var collection = db.GetCollection<Customer>();
                collection.Insert(customer);              
            }
        }
        /// <summary>
        /// 批量添加
        /// </summary>
        /// <param name="lstCustomer"></param>
        private static void InsertList(List<Customer> lstCustomer)
        {
            using (Mongo mongo = new Mongo(_connectionString))
            {
                mongo.Connect();
                var db = mongo.GetDatabase(_dbName);
                var collection = db.GetCollection<Customer>();
                collection.Insert(lstCustomer);
            }
        }
        /// <summary>
        /// 更新
        /// </summary>
        /// <param name="customer"></param>
        private static void Update(Customer customer)
        {
            using (Mongo mongo = new Mongo(_connectionString))
            {
                mongo.Connect();
                var db = mongo.GetDatabase(_dbName);
                var collection = db.GetCollection<Customer>();
                //更新對象
                collection.Update(customer, (x => x.CustomerID == customer.CustomerID));
            }
        }
        /// <summary>
        /// 獲取所有的customer
        /// </summary>
        /// <returns></returns>
        private static IList<Customer> GetList()
        {
            using (Mongo mongo = new Mongo(_connectionString))
            {
                mongo.Connect();
                var db = mongo.GetDatabase(_dbName);
                var collection = db.GetCollection<Customer>();
                ICursor<Customer> mogoCollection = collection.FindAll();
              
                return mogoCollection.Documents.ToList();
            }
        }
        /// <summary>
        /// 根據id獲取單個對象
        /// </summary>
        /// <param name="customerId"></param>
        /// <returns></returns>
        private static Customer GetById(string customerId)
        {
            using (Mongo mongo = new Mongo(_connectionString))
            {
                mongo.Connect();
                var db = mongo.GetDatabase(_dbName);
                var collection = db.GetCollection<Customer>();
                return collection.FindOne(x => x.CustomerID == customerId);
            }
        }
    }
    [Serializable]
    class Customer
    {
        [MongoId]
        public string CustomerID { set; get; }
        public string CustomerName { set; get; }
        public string ContactName { set; get; }
        public string Address { set; get; }
        public string PostalCode { set; get; }
        public string Tel { set; get; }
    }

測試

static void Main(string[] args)
        {
            #region 批量插入
            //List<Customer> list = new List<Customer>();
            //for (int i = 0; i < 100; i++)
            //{
            //    Customer customer = new Customer()
            //    {
            //        CustomerID = Guid.NewGuid().ToString(),
            //        Address = "北京" + i.ToString(),
            //        CustomerName = "wolfy" + i.ToString(),
            //        Tel = "123" + i.ToString(),
            //        PostalCode = "221212" + i.ToString(),
            //        ContactName = "wolfy" + i.ToString()
            //    };
            //    list.Add(customer);
            //}
            //InsertList(list); 
            #endregion
            #region 更新
            //更新需要先將該對象查詢出，然后更新修改的值，不然其他的值為null
            //Update(new Customer() { CustomerID = "08dca525-fb6d-4984-a55f-53723a6ce39c", ContactName = "wolfy22222" });
            #endregion
            #region 查詢單個對象和集合
            //Customer customer = GetById("8211501b-4341-4acb-b2fa-d6a714765443");
            //Console.WriteLine(new JavaScriptSerializer().Serialize(customer));
            List<Customer> customers = GetList().ToList();
            Console.WriteLine(new JavaScriptSerializer().Serialize(customers));
            #endregion
            Console.Read();
        }

總結    

到這里就結束了，這里弄了一個簡單例子，算是快速上手的例子。