MongoDB samus驅動(2)

上一篇中提到驅動的鏈接方式,這篇給出完整鏈接代碼和使用實例

資料庫完整鏈接

 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"}}

基本上構建查詢文檔就這些了,

分組查詢,聯合查詢,高級查詢下次再說