MangoDB CSharp Driver
阿新 • • 發佈:2017-06-30
sets time 修改 collect ase don like blog 返回
mongodb鏈接配置
![技術分享](/img/fz.gif)
public class MongoConfig { public static MongoServerSettings config = null; static MongoConfig() { config = MongoServerSettings.FromUrl(MongoUrl.Create(conStr)); //最大連接池 config.MaxConnectionPoolSize = 500; //最大閑置時間 config.MaxConnectionIdleTime = TimeSpan.FromSeconds(30); //最大存活時間 config.MaxConnectionLifeTime = TimeSpan.FromSeconds(60); //鏈接時間 config.ConnectTimeout = TimeSpan.FromSeconds(10); //等待隊列大小 config.WaitQueueSize = 50; //socket超時時間 config.SocketTimeout = TimeSpan.FromSeconds(10); //隊列等待時間 config.WaitQueueTimeout = TimeSpan.FromSeconds(60); //操作時間 config.OperationTimeout = TimeSpan.FromSeconds(60); } public static string conStr { get { return ConfigurationManager.AppSettings["connectionString"]; } } public static string mongoDB { get { return ConfigurationManager.AppSettings["mongoDB"]; } } }
![技術分享](/img/fz.gif)
![技術分享](/img/fz.gif)
public class MongoCon : IDisposable { public static MongoServer mongoCon = null; public static MongoDatabase mongo { get; private set; } private bool disposed = false; static MongoCon() { //創建鏈接 mongoCon = new MongoServer(MongoConfig.config); //打開鏈接 mongoCon.Connect(); //獲取mongodb指定數據庫 mongo = mongoCon.GetDatabase(MongoConfig.mongoDB); } protected virtual void Dispose(bool disposing) { if (!this.disposed) { if (disposing) { //釋放鏈接 mongoCon.Disconnect(); } mongoCon = null; } this.disposed = true; } public void Dispose() { Dispose(true); GC.SuppressFinalize(this); } }
![技術分享](/img/fz.gif)
c#操作mongodb增刪改查詳細
![技術分享](/img/fz.gif)
public class DoMongo { private static MongoDatabase mdb = MongoCon.mongo; #region 新增 /// <summary> /// 新增 /// </summary> public static Boolean Insert(String collectionName, BsonDocument document) { MongoCollection<BsonDocument> collection = mdb.GetCollection<BsonDocument>(collectionName); try { collection.Insert(document); return true; } catch { return false; } } /// <summary> /// 新增 /// </summary> public static Boolean Insert<T>(String collectionName, T t) { var collection = mdb.GetCollection<T>(collectionName); try { collection.Insert(t); return true; } catch { return false; } } /// <summary> /// 批量新增 /// </summary> public static WriteConcernResult Insert<T>(String collectionName, List<T> list) { var collection = mdb.GetCollection<T>(collectionName); try { return collection.Insert(list); } catch { return null; } } #endregion #region 查詢 /// <summary> /// 查詢單個對象 /// </summary> public static T GetModel<T>(String collectionName, IMongoQuery query) { MongoCollection<T> collection = mdb.GetCollection<T>(collectionName); try { return collection.FindOneAs<T>(query); } catch { return default(T); } } /// <summary> /// 查詢對象集合 /// </summary> public static List<T> GetList<T>(String collectionName, IMongoQuery query) { MongoCollection<T> collection = mdb.GetCollection<T>(collectionName); try { return collection.FindAs<T>(query).ToList(); } catch { return null; } } /// <summary> /// 查詢對象集合 /// </summary> public static List<T> GetList<T>(String collectionName, IMongoQuery query, int top) { MongoCollection<T> collection = mdb.GetCollection<T>(collectionName); try { return collection.FindAs<T>(query).SetLimit(top).ToList(); } catch { return null; } } /// <summary> /// 查詢對象集合 /// </summary> public static List<T> GetList<T>(String collectionName, IMongoQuery query, string sort, bool isDesc) { MongoCollection<T> collection = mdb.GetCollection<T>(collectionName); try { if (isDesc) { return collection.FindAs<T>(query).SetSortOrder(SortBy.Descending(sort)).ToList(); } else { return collection.FindAs<T>(query).SetSortOrder(SortBy.Ascending(sort)).ToList(); } } catch { return null; } } /// <summary> /// 查詢對象集合 /// </summary> public static List<T> GetList<T>(String collectionName, IMongoQuery query, string[] sort, bool isDesc) { MongoCollection<T> collection = mdb.GetCollection<T>(collectionName); try { if (isDesc) { return collection.FindAs<T>(query).SetSortOrder(SortBy.Descending(sort)).ToList(); } else { return collection.FindAs<T>(query).SetSortOrder(SortBy.Ascending(sort)).ToList(); } } catch { return null; } } /// <summary> /// 查詢對象集合 /// </summary> public static List<T> GetList<T>(String collectionName, IMongoQuery query, string sort, bool isDesc, int top) { MongoCollection<T> collection = mdb.GetCollection<T>(collectionName); try { if (isDesc) { return collection.FindAs<T>(query).SetSortOrder(SortBy.Descending(sort)).SetLimit(top).ToList(); } else { return collection.FindAs<T>(query).SetSortOrder(SortBy.Ascending(sort)).SetLimit(top).ToList(); } } catch { return null; } } /// <summary> /// 查詢對象集合 /// </summary> public static List<T> GetList<T>(String collectionName, IMongoQuery query, string[] sort, bool isDesc, int top) { MongoCollection<T> collection = mdb.GetCollection<T>(collectionName); try { if (isDesc) { return collection.FindAs<T>(query).SetSortOrder(SortBy.Descending(sort)).SetLimit(top).ToList(); } else { return collection.FindAs<T>(query).SetSortOrder(SortBy.Ascending(sort)).SetLimit(top).ToList(); } } catch { return null; } } /// <summary> /// 分頁查詢 /// </summary> public static List<T> GetPageList<T>(String collectionName, IMongoQuery query, string sort, bool isDesc, int index, int pageSize, out long rows) { MongoCollection<T> collection = mdb.GetCollection<T>(collectionName); try { rows = collection.FindAs<T>(query).Count(); if (isDesc) { return collection.FindAs<T>(query).SetSortOrder(SortBy.Descending(sort)).SetSkip(index).SetLimit(pageSize).ToList(); } else { return collection.FindAs<T>(query).SetSortOrder(SortBy.Ascending(sort)).SetSkip(index).SetLimit(pageSize).ToList(); } } catch { rows = 0; return null; } } /// <summary> /// 分頁查詢 /// </summary> public static List<T> GetPageList<T>(String collectionName, IMongoQuery query, string[] sort, bool isDesc, int index, int pageSize, out long rows) { MongoCollection<T> collection = mdb.GetCollection<T>(collectionName); try { rows = collection.FindAs<T>(query).Count(); if (isDesc) { return collection.FindAs<T>(query).SetSortOrder(SortBy.Descending(sort)).SetSkip(index).SetLimit(pageSize).ToList(); } else { return collection.FindAs<T>(query).SetSortOrder(SortBy.Ascending(sort)).SetSkip(index).SetLimit(pageSize).ToList(); } } catch { rows = 0; return null; } } #endregion #region 修改 /// <summary> /// 修改 /// </summary> public static WriteConcernResult Update(String collectionName, IMongoQuery query, QueryDocument update) { MongoCollection<BsonDocument> collection = mdb.GetCollection<BsonDocument>(collectionName); try { var new_doc = new UpdateDocument() { { "$set", update } }; //UpdateFlags設置為Multi時,可批量修改 var result = collection.Update(query, new_doc, UpdateFlags.Multi); return result; } catch { return null; } } #endregion #region 移除 /// <summary> /// 移除匹配的集合 /// </summary> public static Boolean Remove(String collectionName, IMongoQuery query) { MongoCollection<BsonDocument> collection = mdb.GetCollection<BsonDocument>(collectionName); try { collection.Remove(query); return true; } catch { return false; } } /// <summary> /// 移除所有集合 /// </summary> public static Boolean RemoveAll(String collectionName) { MongoCollection<BsonDocument> collection = mdb.GetCollection<BsonDocument>(collectionName); try { collection.RemoveAll(); return true; } catch { return false; } } #endregion #region 其它 /// <summary> /// 是否存在 /// </summary> public static bool IsExist(string collectionName) { MongoCollection<BsonDocument> collection = mdb.GetCollection<BsonDocument>(collectionName); try { return collection.Exists(); } catch { return false; } } /// <summary> /// 總數 /// </summary> public static long Count(string collectionName) { MongoCollection<BsonDocument> collection = mdb.GetCollection<BsonDocument>(collectionName); try { return collection.Count(); } catch { return 0; } } /// <summary> /// 總數 /// </summary> public static long Count(string collectionName, IMongoQuery query) { MongoCollection<BsonDocument> collection = mdb.GetCollection<BsonDocument>(collectionName); try { return collection.Count(query); } catch { return 0; } } #endregion }
![技術分享](/img/fz.gif)
monogodb中where條件操作符號
![技術分享](/img/fz.gif)
Query.And(Query.EQ("name", "a"), Query.EQ("title", "t"));//同時滿足多個條件 Query.EQ("name", "a");//等於 Query.Exists("type", true);//判斷鍵值是否存在 Query.GT("value", 2);//大於> Query.GTE("value", 3);//大於等於>= Query.In("name", "a", "b");//包括指定的所有值,可以指定不同類型的條件和值 Query.LT("value", 9);//小於< Query.LTE("value", 8);//小於等於<= Query.Mod("value", 3, 1);//將查詢值除以第一個給定值,若余數等於第二個給定值則返回該結果 Query.NE("name", "c");//不等於 Query.Nor(Array);//不包括數組中的值 Query.Not("name");//元素條件語句 Query.NotIn("name", "a", 2);//返回與數組中所有條件都不匹配的文檔 Query.Or(Query.EQ("name", "a"), Query.EQ("title", "t"));//滿足其中一個條件 Query.Size("name", 2);//給定鍵的長度 Query.Type("_id", BsonType.ObjectId );//給定鍵的類型 Query.Where(BsonJavaScript);//執行JavaScript Query.Matches("Title",str);//模糊查詢 相當於sql中like -- str可包含正則表達式
MangoDB CSharp Driver