C#中使用1.7版本驅動操作MongoDB簡單例子

2020-01-24 02:12:38

字體：大中小

來源：轉載

供稿：網友

//創建數據庫鏈接
//在1.7的版本驅動中這樣寫是會報 MongoServer方法已過時的
//MongoServer server = MongoDB.Driver.MongoServer.Create(strconn);

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

//插入一個實體
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/
將一個引用添加到c#司機dll

右鍵單擊引用文件夾在Visual Studio的解決方案探險家和選擇添加參考…… 。導航到文件夾 c#驅動程序dll被安裝并添加一個引用以下 dll:

復制代碼代碼如下:

    MongoDB.Bson.dll
    MongoDB.Driver.dll

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

作為一個最低需要使用語句如下:

復制代碼代碼如下:

using MongoDB.Bson;
using MongoDB.Driver;

此外,您會經常添加一個或多個使用聲明:

復制代碼代碼如下:

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

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

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

復制代碼代碼如下:

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

如果你想將客戶端對象存儲在一個全局變量。 MongoClient 是線程安全的。
對服務器對象的引用

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

復制代碼代碼如下:

var server = client.GetServer();

到一個數據庫對象的引用

去到一個數據庫對象的引用從服務器對象,寫這樣的:

復制代碼代碼如下:

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

如果您使用多個數據庫,調用 GetDatabase 再次為每個您想要使用數據庫。
BsonDocument 對象模型與您自己的域類

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

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

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

因為它是如此容易使用自己的域類快速啟動將假設你要這樣做。 c#驅動程序提供,他們可以處理您的域類:

有一個無參數的構造函數
定義公共讀/寫數據的字段或屬性存儲在數據庫中

這些需求在本質上是相同的。net的實施 XmlSerializer。

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

考慮下面的類定義:

復制代碼代碼如下:

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

public string Name { get; set; }
}

對一組對象的引用

你會得到一個包含引用集合實體文件是這樣的:

復制代碼代碼如下:

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

插入文檔

插入一個實體 :

復制代碼代碼如下:

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)

找到一個現有的文檔

在這個示例中,我們將讀回實體假設我們知道 ID 值:

復制代碼代碼如下:

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

查詢<單位> .EQ 使用查詢< T > 構建器類來構建查詢。 lambda表達式 E = > e.Id 是翻譯 _ID 。這是字段的名稱存儲在數據庫中。

請注意

通常的名稱字段在數據庫中是完全相同的正如它的名字域類中的字段或屬性,但是 ID 是一個例外,映射到嗎 _ID 在數據庫中。

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

你可以保存更改現有的文檔如下:

復制代碼代碼如下:

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

更新現有的文檔

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

復制代碼代碼如下:

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 > 構建器輕松地構建更新修飾符。
刪除一個現有的文檔

刪除一個現有的文檔集合你寫:

復制代碼代碼如下:

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

你不需要調用連接或斷開連接

c#司機有一個連接池使用連接到服務器效率。不需要電話連接或斷開 ; 讓司機照顧連接(調用連接是無害的,但是打電話呢斷開是不好的,因為它關閉連接池中的連接)。
完整的示例程序

復制代碼代碼如下:

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#中的預處理器指令詳解

下一篇：C#無法打開計算機“.”上的 IISADMIN 服務的解決方法