上一篇中提到驅動的鏈接方式,這篇給出完整鏈接代碼和使用實例 資料庫完整鏈接 添加數據: 更新數據: 更新,除了Update還有一個UpdateAll方法,不做過多解釋. 增,刪,改 沒什麼可說,主要說下查詢 簡單數據查詢: 靈活查詢: 可以看出只要給Find傳遞Document,然後接受數據就可以了 ...
上一篇中提到驅動的鏈接方式,這篇給出完整鏈接代碼和使用實例
資料庫完整鏈接
1 static IMongo _mongo = null; 2 public MongoDrive()//這個類集成了 IDisposable 介面 3 { 4 if (_mongo == null) 5 { 6 var connectionString = new MongoConnectionStringBuilder() 7 { 8 ConnectionTimeout = TimeSpan.FromSeconds(30), 9 ConnectionLifetime = TimeSpan.FromSeconds(10), 10 MinimumPoolSize = 1, 11 MaximumPoolSize = 10, 12 Pooled = true, 13 }; 14 connectionString.AddServer(new MongoServerEndPoint("127.0.0.1", 27017)); 15 var config = new mongo.Configuration.MongoConfiguration(); 16 config.ConnectionString = connectionString.ToString(); 17 config.ReadLocalTime = false; 18 _mongo = new Mongo(config); 19 _mongo.Connect(); 20 } 21 } 22 23 public static IMongo Driver 24 { 25 get 26 { 27 return _mongo; 28 } 29 }
添加數據:
1 using (IDocumentDrive db = new MongoDB.MongoDrive()) 2 { 3 db.Driver.Collection("docs").Insert( 4 new Document("uid",123456) 5 .Merge("uName","admin") 6 .Merge("age",new Document("去年八月",DateTime.Now))//Document 值為任何類型, 7 .Merge("addtime", DateTime.UtcNow) 8 ); 9 }
Document 為samus驅動定義好的,實際是 IDictionary<string, object> 的封裝.
刪除數據:
1 using (IDocumentDrive db = new MongoDB.MongoDrive()) 2 { 3 db.Driver.Collection("docs").Remove(new mongo.Document("uid", 123456));//刪除 UID = 123456 的文檔 4 }
更新數據:
1 using (IDocumentDrive db = new MongoDB.MongoDrive()) 2 { 3 db.Driver.Collection("docs").Update(new mongo.Document("uName", "drop attr"), new mongo.Document("uid", 123456)); 4 }
更新,除了Update還有一個UpdateAll方法,不做過多解釋.
增,刪,改 沒什麼可說,主要說下查詢
簡單數據查詢:
Document doc = db.Collection("docs").FindOne(new mongo.Document("uid",12346));//查詢出一個文檔,其數據保護文檔全部屬性及其子文檔,查找不到數據為 null,返回值為Document類型
使用時:
var age = doc["age"] //因為Document是Dictionary,所以可以直接使用中索引器取值
doc["uName"] = "mongdb samus";//賦值也是使用索引器
db.Collection("docs").Update(doc , new mongo.Document("uid", 123456));//之後更新這個文檔
db.Collection("docs").FindAll().Documents//FindAll 自然就是查詢全部文檔,FindAll()只返回了游標,調用FindAll().Documents才能正式獲取到值,
FindAll().Sort().Skip().Limit()//FindAll 還有幾個其他方法,Sort:排序 Skip:跳過條數 Limit:取值條數
Sort("age", MongoDB.IndexOrder.Descending)//排序
Skip(27)//跳過 27 條
Limit(28)//取 28 條
FindAndModify:這個函數類似 UPDATE,
FindAndModify(新文檔結構,搜索條件,returnNew=true/false)//根據條件搜索文檔,找到則修改文檔為新文檔格式,並返迴文檔,返回的是新文檔,還是修改前的舊文檔,根據returnNew參數決定
還有其他參數如:upsert,是只更新第一個匹配項,還是更新全部匹配項
靈活查詢:
db.Collection("docs").Find(new Document("age", 27)).Documents;
Find:函數在項目里用的最多,主要是比較靈活.重載也比較多.
Find(new Document("age", 27), int limit, int skip)//分頁查詢
Find(new Document("age", 27))//條件查詢
和FindAll 函數一樣,也是要調用 Documents 才能正常取值,否則只能取到游標.
Find(Document)//這種形式會返迴文檔全部結構,當查詢用戶時會返回用戶密碼,此時需要傳遞第二個參數
Find(new Document("age", 27),new Document("age", "").Merge("uid","空字元串即可"))//此時返回的文檔格式 只包含 age和uid 兩個屬性
可以看出只要給Find傳遞Document,然後接受數據就可以了.那麼複雜的肯定是如何構建Document,
下麵說下怎麼構建比較常用的查詢條件.
samus驅動有一個Op類.裡面定義了條件運算符函數,可以直接使用.
示例:
Op.GreaterThan(27)//生成的是mongoDB 的$gt //大於
Op.GreaterThanOrEqual(27)//生成的是mongoDB 的$gte //大於等於
Op.In(new string[]{"123465","123457","132458"})// IN 操作
根據名字可以直接看出具體是什麼意思,不全都寫註釋了.
Op里沒有現成Like函數,我擴展了下:
1 public static Document Like(string key) 2 { 3 return new Document().Merge(new Op().Add("$regex", key)).Merge(new Op().Add("$options", "$i")); 4 }
如何使用Op構建條件查詢:
//只做示例,條件肯定是永遠無法滿足的,勿糾結這個
new Document("uid","123456") //uid=123456 .Merge("age",Op.GreaterThan(27)) // 並且 age > 27
.Merge("addtime",Op.GreaterThan(DateTime.Now)) // 並且 addtime > 當前時間 說明:Op.GreaterThan可以比較不同類型,不一定非是 int
.Merge("age",new Document(Op.GreaterThan(15).Merge(Op.LessThanOrEqual(40)))) //並且 ( age>15 && age <40 )
.Merge("uid",new Document("$nin",new string[]{"123","124","124"})) //並且uid 不在 數組中 .
.Merge("uid",new Document("$in",new string[]{"666","777","888"})) //並且uid 在 666,777,888 中.
.Merge("face.big","http://www.salsnet.win/1.jpg")//搜索子文檔:文檔格式大概為{'uName':'abc',"face":{"small":"111.jpg","big":"222.jpg"}}
基本上構建查詢文檔就這些了,
分組查詢,聯合查詢,高級查詢下次再說
