C#中使用1.7版本驅(qū)動(dòng)操作MongoDB簡單例子

2020-01-24 02:12:38

字體：大中小

供稿：網(wǎng)友

//創(chuàng)建數(shù)據(jù)庫鏈接
//在1.7的版本驅(qū)動(dòng)中這樣寫是會(huì)報(bào) MongoServer方法已過時(shí)的
//MongoServer server = MongoDB.Driver.MongoServer.Create(strconn);

//帶有用戶名，密碼的如下寫法，不帶的則直接ip+端口就可以
const string connectionString = "mongodb://city:liyang@192.168.1.211:27017";
//得到一個(gè)客戶端對象的引用 GetServer()對服務(wù)器對象的引用
var Server = new MongoClient(connectionString).GetServer();
//到一個(gè)數(shù)據(jù)庫對象的引用
var client = Server.GetDatabase("City");
//對一組對象的引用
var collection = client.GetCollection<citys>("citys");

//插入一個(gè) 實(shí)體
for (int i = 0; i < dt.Rows.Count; i++)
{
    collection.Insert(new citys
    {
        province = dt.Rows[i][0].ToString(),
        city = dt.Rows[i][1].ToString(),
        county = dt.Rows[i][2].ToString(),
        areacode = "0" + dt.Rows[i][3].ToString(),
        postalcode = dt.Rows[i][3].ToString()
    });
}

以下是git上的幫助文檔地址是：http://docs.mongodb.org/ecosystem/tutorial/getting-started-with-csharp-driver/
將一個(gè)引用添加到c#司機(jī)dll

右鍵單擊引用文件夾在Visual Studio的解決方案探險(xiǎn)家和選擇添加參考…… 。導(dǎo)航到文件夾 c#驅(qū)動(dòng)程序dll被安裝并添加一個(gè)引用以下 dll:

復(fù)制代碼代碼如下:

    MongoDB.Bson.dll
    MongoDB.Driver.dll

作為一種替代方法可以使用 NuGet 包管理器添加c# 驅(qū)動(dòng)程序包來您的解決方案。
添加所需的使用語句

作為一個(gè)最低需要使用語句如下:

復(fù)制代碼代碼如下:

using MongoDB.Bson;
using MongoDB.Driver;

此外,您會(huì)經(jīng)常添加一個(gè)或多個(gè)使用聲明:

復(fù)制代碼代碼如下:

using MongoDB.Driver.Builders;
using MongoDB.Driver.GridFS;
using MongoDB.Driver.Linq;

還有其他名稱空間,只會(huì)在特殊的需要用例。
得到一個(gè)客戶端對象的引用

最簡單的方法獲得一個(gè)客戶對象的引用是使用連接字符串:

復(fù)制代碼代碼如下:

var connectionString = "mongodb://localhost";
var client = new MongoClient(connectionString);

如果你想將客戶端對象存儲(chǔ)在一個(gè)全局變量。 MongoClient 是線程安全的。
對服務(wù)器對象的引用

要從客戶端到服務(wù)器對象的引用對象,寫這樣的:

復(fù)制代碼代碼如下:

var server = client.GetServer();

到一個(gè)數(shù)據(jù)庫對象的引用

去到一個(gè)數(shù)據(jù)庫對象的引用從服務(wù)器對象,寫這樣的:

復(fù)制代碼代碼如下:

var database = server.GetDatabase("test"); // "test" is the name of the database

如果您使用多個(gè)數(shù)據(jù)庫,調(diào)用 GetDatabase 再次為每個(gè) 您想要使用數(shù)據(jù)庫。
BsonDocument 對象模型與您自己的域類

有兩種方法可以處理集合:

使用 BsonDocument 對象模型
使用自己的域類

您將使用 BsonDocument 當(dāng)數(shù)據(jù)對象模型工作是如此的自由形式,它將是困難的或不可能的定義的域類。

因?yàn)樗侨绱巳菀资褂米约旱挠蝾?快速啟動(dòng)將假設(shè)你要這樣做。 c#驅(qū)動(dòng)程序提供,他們可以處理您的域類:

有一個(gè)無參數(shù)的構(gòu)造函數(shù)
定義公共讀/寫數(shù)據(jù)的字段或?qū)傩?存儲(chǔ)在數(shù)據(jù)庫中

這些需求在本質(zhì)上是相同的。net的實(shí)施 XmlSerializer。

此外,如果您的域類將被用作根文檔必須包含一個(gè) ID 字段或?qū)傩?通常是命名 ID 盡管你可以覆蓋,如果必要)。通常情況下, ID 將類型的 ObjectId ,但沒有限制的類型的成員。

考慮下面的類定義:

復(fù)制代碼代碼如下:

public class Entity
{
public ObjectId Id { get; set; }

public string Name { get; set; }
}

對一組對象的引用

你會(huì)得到一個(gè)包含引用集合實(shí)體文件是這樣的:

復(fù)制代碼代碼如下:

// "entities" is the name of the collection
var collection = database.GetCollection<Entity>("entities");

插入文檔

插入一個(gè) 實(shí)體 :

復(fù)制代碼代碼如下:

var entity = new Entity { Name = "Tom" };
collection.Insert(entity);
var id = entity.Id; // Insert will set the Id if necessary (as it was in this example)

找到一個(gè)現(xiàn)有的文檔

在這個(gè)示例中,我們將讀回實(shí)體假設(shè)我們知道 ID 值:

復(fù)制代碼代碼如下:

var query = Query<Entity>.EQ(e => e.Id, id);
var entity = collection.FindOne(query);

查詢<單位> .EQ 使用查詢< T > 構(gòu)建器類來構(gòu)建查詢。 lambda表達(dá)式 E = > e.Id 是翻譯 _ID 。這是字段的名稱存儲(chǔ)在數(shù)據(jù)庫中。

請注意

通常的名稱字段在數(shù)據(jù)庫中是完全相同的正如它的名字域類中的字段或?qū)傩?但是 ID 是一個(gè)例外,映射到嗎 _ID 在數(shù)據(jù)庫中。

其他查詢操作符包括: GT , 一種 , 在 , LT , LTE , 附近 , 東北 , 和 , 或 (和其他一些更多專業(yè)的)。
保存一個(gè)文檔

你可以保存更改現(xiàn)有的文檔如下:

復(fù)制代碼代碼如下:

entity.Name = "Dick";
collection.Save(entity);

更新現(xiàn)有的文檔

另一種選擇保存是更新。所不同的是, 保存將整個(gè)文檔發(fā)送回服務(wù)器,但是更新發(fā)的變化。例如:

復(fù)制代碼代碼如下:

var query = Query<Entity>.EQ(e => e.Id, id);
var update = Update<Entity>.Set(e => e.Name, "Harry"); // update modifiers
collection.Update(query, update);

下面的例子使用了更新< T > 構(gòu)建器輕松地構(gòu)建更新修飾符。
刪除一個(gè)現(xiàn)有的文檔

刪除一個(gè)現(xiàn)有的文檔集合你寫:

復(fù)制代碼代碼如下:

var query = Query<Entity>.EQ(e => e.Id, id);
collection.Remove(query);

你不需要調(diào)用連接或斷開連接

c#司機(jī)有一個(gè)連接池使用連接到服務(wù)器效率。不需要電話連接或斷開 ; 讓司機(jī)照顧連接(調(diào)用連接是無害的,但是打電話呢斷開是不好的,因?yàn)樗P(guān)閉連接池中的連接)。
完整的示例程序

復(fù)制代碼代碼如下:

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

using MongoDB.Bson;
using MongoDB.Driver;
using MongoDB.Driver.Builders;

namespace ConsoleApplication1
{
    public class Entity
    {
        public ObjectId Id { get; set; }
        public string Name { get; set; }
    }

    class Program
    {
        static void Main(string[] args)
        {
            var connectionString = "mongodb://localhost";
            var client = new MongoClient(connectionString);
            var server = client.GetServer();
            var database = server.GetDatabase("test");
            var collection = database.GetCollection<Entity>("entities");

            var entity = new Entity { Name = "Tom" };
            collection.Insert(entity);
            var id = entity.Id;

var query = Query<Entity>.EQ(e => e.Id, id);
entity = collection.FindOne(query);

entity.Name = "Dick";
collection.Save(entity);

var update = Update<Entity>.Set(e => e.Name, "Harry");
collection.Update(query, update);

            collection.Remove(query);
        }
    }
}

上一篇：C#中的預(yù)處理器指令詳解

下一篇：C#無法打開計(jì)算機(jī)“.”上的 IISADMIN 服務(wù)的解決方法