筆者這里采用的是mongoDB官網(wǎng)推薦使用.net驅(qū)動:
http://mongodb.github.io/mongo-csharp-driver/2.0/getting_started/quick_tour/
有關(guān)于MongoDB的安裝讀者可以參考其他的博客,對于基本的學(xué)習(xí)來說并不需要進(jìn)行過多的配置。
創(chuàng)建連接
這一步驟跟ADO.NET連接到數(shù)據(jù)庫的步驟是一樣的,ADO.NET是利用SqlConnection連接數(shù)據(jù)庫,而MongoDB則使用MongoClient連接,并在構(gòu)造函數(shù)中將連接字符傳遞進(jìn)去,當(dāng)然可以不傳遞,那么默認(rèn)就是連接本地的計(jì)算機(jī)的默認(rèn)端口(27017),比如下面的三種連接方式:
var client = new MongoClient();var client1 = new MongoClient("mongodb://localhost:27017");var client2 = new MongoClient("mongodb://localhost:27017,localhost:27018,localhost:27019");獲取數(shù)據(jù)庫
為了獲取數(shù)據(jù)庫,只需要調(diào)用MongoClient對象的GetDatabase方法,并傳入數(shù)據(jù)庫名稱即可,如果數(shù)據(jù)庫存在則直接返回,否則就創(chuàng)建該數(shù)據(jù)庫并返回,比如下面的這段代碼將創(chuàng)建名為“foo”的數(shù)據(jù)庫:
var database = client.GetDatabase("foo");現(xiàn)在database變量就指向了foo數(shù)據(jù)庫了。
獲取鏈表
雖然叫獲取鏈表,但是實(shí)際上就是獲取數(shù)據(jù)庫中的表,我們可以通過上面database的GetCollection<TDocument>方法獲取,比如下面的代碼我們將獲取一個名為“bar”的表:
var collection = database.GetCollection<BsonDocument>("bar");我們傳入的泛型參數(shù)為BsonDocument,這個是自帶的,可以動態(tài)的容納各種格式的數(shù)據(jù),當(dāng)然這里還是建議讀者使用POCO。
插入一個文檔
利用collection對象,我們可以將文檔插入其中,比如下面的json格式數(shù)據(jù):
{ "name": "MongoDB", "type": "database", "count": 1, "info": { x: 203, y: 102 }}下面我們利用BsonDocument對象組織上面的JSON格式的數(shù)據(jù):
var document = new BsonDocument{ {"name","MongoDB"}, {"type","Database"}, {"count",1}, {"info",new BsonDocument{ {"x",203}, {"y",102} } }};然后我們利用collection對象的InsertOneAsync將上面的數(shù)據(jù)插入其中:
collection.InsertOneAsync(doc);
我們都知道Async為后綴的方法都是支持異步的,但是筆者是在控制臺項(xiàng)目中演示的所以沒有加上這個await,如果讀者實(shí)在其他的環(huán)境中測試的可以根據(jù)情況加上。
插入多個文檔
如果需要一次性插入多個文檔,我們可以通過InsertManyAsync方法,比如下面的示例我們將插入100條數(shù)據(jù):
var documents = Enumerable.Range(0, 100).Select(x => new BsonDocument("counter", x));collection.InsertManyAsync(documents);統(tǒng)計(jì)文檔數(shù)量
通過上面的步驟我們已經(jīng)插入了101條數(shù)據(jù),如果在實(shí)際開發(fā)中我們需要統(tǒng)計(jì)數(shù)據(jù)的數(shù)量就可以通過調(diào)用CountAsync方法,比如下面的代碼:
var count = collection.CountAsync(new BsonDocument());Console.WriteLine(count.Result);
查詢鏈表
利用Find方法我們可以對鏈表進(jìn)行查詢,F(xiàn)ind方法將返回給我們IFindFluent<TDocument,TProjection>對象,該接口屬于鏈?zhǔn)浇涌?,所以能夠提供給我們類似jquery那樣的鏈?zhǔn)阶兂煞绞饺タ刂撇樵儾僮鳌?/p>
查詢鏈表首條數(shù)據(jù)
為了獲取第一條數(shù)據(jù)我們可以通過調(diào)用FirstOrDefaultAsync方法,該方法會返回第一條數(shù)據(jù),如果不存在數(shù)據(jù)則會返回null,比如下面的代碼將會顯示鏈表中的第一條數(shù)據(jù):
var firstDoc = collection.Find(new BsonDocument()).FirstOrDefaultAsync();Console.WriteLine(firstDoc.Result.ToString());
如果讀者注意最后的輸出,會發(fā)現(xiàn)一個_id字段,但是我們并沒有插入這個字段,這個字段是mongoDB自動加入的,相信很多人都知道它的作用,這里就不詳細(xì)解釋額。
查詢鏈表中所有數(shù)據(jù)
如果想將鏈表中所有的數(shù)據(jù)都返回可以在Find操作之后調(diào)用ToListAsync方法就可以,將會直接返回List<T>類型的結(jié)果,比如下面的這段代碼:
var documents = collection.Find(new BsonDocument()).ToListAsync().Result;
針對數(shù)量較少的數(shù)據(jù)情況下,上面這種方式是沒有問題,但如果我們需要處理大量的數(shù)據(jù),那么我們就不能使用上面的這種方式,就需要利用下面的方式,通過ForEachAsync來完成,因?yàn)檫@個方法會在每條數(shù)據(jù)返回的時候執(zhí)行一個回調(diào),從而達(dá)到并發(fā)處理的目的,比如下面這段代碼就演示了如何使用:
collection.Find(new BsonDocument()).ForEachAsync(x => Console.WriteLine(x));
通過條件查詢單條數(shù)據(jù)
我們可以在調(diào)用Find方法的時候傳入一個過濾條件,從而在鏈表中查詢我們希望的數(shù)據(jù),比如下面這個例子我們將查詢字段“counter”的值為71的數(shù)據(jù):
var filter = Builders<BsonDocument>.Filter.Eq("counter", 71);var document = collection.Find(filter).FirstAsync().Result;Console.WriteLine(document);這里我們需要通過Builders的靜態(tài)對象Filter中的各種條件方法來構(gòu)造條件,然后在調(diào)用Find方法的將其傳入即可。
通過條件查詢多條數(shù)據(jù)
我們也可以獲取多條數(shù)據(jù),比如下面這個例子,我們將搜索出所有“counter”的值大于50的數(shù)據(jù):
var filter = Builders<BsonDocument>.Filter.Gt("counter", 50);var document = collection.Find(filter).ForEachAsync(x => Console.WriteLine(x));當(dāng)然我們也可以給定一個范圍,比如50到70之間:
var filterBuilder = Builders<BsonDocument>.Filter;var filter = filterBuilder.Gt("counter", 50) & filterBuilder.Lt("counter", 70);collection.Find(filter).ForEachAsync(x => Console.WriteLine(x));對數(shù)據(jù)排序
下面我們將在查詢的基礎(chǔ)之上加上排序,排序只需要在在調(diào)用Sort方法時傳入對應(yīng)的參數(shù)即可,比如下面的例子,我們將對鏈表先進(jìn)行查詢,然后排序:
var filter = Builders<BsonDocument>.Filter.Exists("counter");var sort = Builders<BsonDocument>.Sort.Descending("counter");var documnt = collection.Find(filter).Sort(sort).FirstAsync().Result;對字段投射
許多時候我們并不需要文檔中的所有數(shù)據(jù),這就好比在SQL中我們都會只把我們需要的數(shù)據(jù)select出來,而不會把表中的所有字段的數(shù)據(jù)都拿出來,自然MongoDB也可以讓我這樣做,我們只需要跟過濾和排序一樣利用Projection構(gòu)造器來構(gòu)造然后傳遞給Project方法中就可以了,下面這個例子中我們將排除“_id”字段:
var projection = Builders<BsonDocument>.Projection.Exclude("_id");var document = collection.Find(new BsonDocument()).Project(projection).FirstAsync().Result;Console.WriteLine(document);更新文檔
MongoDB擁有很多更新操作,下面我們將會介紹幾個簡單的并且常用的更新操作。
如果我們需要更新一個對象(如果條件不匹配那么可能是0條),可以使用UpdateOneAsync方法,并執(zhí)行過濾條件和需要更新到的文檔,比如下面我們將“counter”為1的數(shù)據(jù)中的“counter”更新為110:
var filter = Builders<BsonDocument>.Filter.Eq("counter", 1);var updated = Builders<BsonDocument>.Update.Set("counter", 110);var result = collection.UpdateOneAsync(filter, updated).Result;如果我們需要批量的更新,我們可以調(diào)用UpdateManyAsync即可。比如我們需要將“counter”小于10的數(shù)據(jù)中的“counter”累加100,那么我們就可以像下面這樣來寫:
var filter = Builders<BsonDocument>.Filter.Lt("counter", 10);var updated = Builders<BsonDocument>.Update.Inc("counter", 100);var result = collection.UpdateManyAsync(filter, updated).Result;刪除文檔
作為基礎(chǔ)部分這也是最后一個部分了,利用上面的過濾,然后調(diào)用DeleteOneAsync或DeleteManyAsync方法就可以了,比如下面的列子就是刪除“counter”大于100的所有數(shù)據(jù):
var filter = Builders<BsonDocument>.Filter.Gt("counter", 100);var resut = collection.DeleteManyAsync(filter).Result;到此為止,MongoDB的基礎(chǔ)部分就結(jié)束了。希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持VEVB武林網(wǎng)。
新聞熱點(diǎn)
疑難解答
圖片精選