NET連線MongoDB資料庫例項方法
使用程式碼
讓我們從Mongo資料庫的一些細節和基本命令開始，並最終介紹如何建立一個可連線至Mongo資料庫的.NET Windows應用。
Mongo資料庫
MongoDB 是一個跨平臺、文件導向的資料庫系統，它被歸類為“NoSQL”資料庫。MongoDB避開了傳統的基於表的關係資料庫結構，而是使用了帶動態模式的類JSON文件。MongoDB將這種格式稱為BSON(二進位制JSON)。這種動態模式使得特定型別應用中的資料整合更簡單、更快速。MongoDB是自由且開源的軟體。
Mongo資料庫的特性
Ad hoc 查詢
1 標引
2 複製
3負載均衡
4 檔案存貯
5 聚合
6 伺服器端 JavaScript 執行
7 定容集合
使用者可從 此處 下載Mongo資料庫，然後將其中內容解壓至任一資料夾。 檔案下載完成後，使用者需要配置MongoDB的資料資料夾。做法是在“C:Data”資料夾下建立一個名為“DB”的資料夾。
資料資料夾建立好以後，可以透過用命令列提示符在“bin”資料夾下執行“mongod.exe”來啟動Mongo資料庫。
現在資料庫已經啟動，並正在執行。
建立一個.NET應用
建立一個.NET web/Windows應用。在這個示例中，我們將用一個簡單的.員工表。
開始之前，我們需要確保系統中裝有MongoDB的.NET驅動。你可以按下面的步驟來為一個指定的專案安裝驅動。
開啟Visual Studio的包管理器:
開啟包管理器控制檯後，使用者可以執行下面的命令:
複製程式碼 程式碼如下:
Install-Package mongocsharpdriver
在專案中新增對下列名稱空間的引用:
複製程式碼 程式碼如下:
using MongoDB.Bson;
using MongoDB.Driver;
//此外，你將頻繁的用到下面這些 using 語句中的一條或多條:
using MongoDB.Driver.Builders;
using MongoDB.Driver.GridFS;
using MongoDB.Driver.Linq;
宣告資料庫伺服器和資料庫的變數:
複製程式碼 程式碼如下:
MongoServer _server;
MongoDatabase _database;
用下面的命令連線至資料庫。在這裡，資料庫伺服器是在本地主機上執行的，埠為：27017，資料庫名為“ anoop”。
複製程式碼 程式碼如下:
private void Form1_Load(object sender, EventArgs e)
{
string connection = "mongodb://localhost:27017";
_server = MongoServer.Create(connection);
_database = _server.GetDatabase("anoop", SafeMode.True);
}
在這裡，我們建立了三個使用不同屬性集合的類。我們可以設定這些類的屬性，並將資料儲存至同一個資料庫、同一個表。這是無模式資料庫的真正優勢：插入資料時不檢查模式。儲存不同的記錄時可以用不同的域的集合，而其它的域 將 預設被視為NULL。
複製程式碼 程式碼如下:
public class Users1
{
public ObjectId Id { get; set; }
public string Name { get; set; }
public int Age { get; set; }
}
public class Users2
{
public ObjectId Id { get; set; }
public string Name { get; set; }
public string Location { get; set; }
}
public class Users3
{
public ObjectId Id { get; set; }
public string Name { get; set; }
public int Age { get; set; }
public string Location { get; set; }
}
private void rbEntity1_CheckedChanged(object sender, EventArgs e)
{
txtName.Enabled = true;
txtAge.Enabled = true;
txtLocation.Enabled = true;
}
private void rbEntity2_CheckedChanged(object sender, EventArgs e)
{
txtName.Enabled = true;
txtAge.Enabled = false;
txtLocation.Enabled = true;
}
private void rbEntity3_CheckedChanged(object sender, EventArgs e)
{
txtName.Enabled = true;
txtAge.Enabled = true;
txtLocation.Enabled = false;
}
private void btnSave_Click(object sender, EventArgs e)
{
if (rbEntity1.Checked)
{
var _users = _database.GetCollection("users");
var user = new Users3 { };
user.Age = Convert.ToInt32(txtAge.Text);
user.Name = txtName.Text;
user.Location = txtLocation.Text;
_users.Insert(user);
var id = user.Id;
}
else if (rbEntity2.Checked)
{
var _users = _database.GetCollection("users");
var user = new Users2 { };
user.Name = txtName.Text;
user.Location = txtLocation.Text;
_users.Insert(user);
var id = user.Id;
}
else if (rbEntity3.Checked)
{
var _users = _database.GetCollection("users");
var user = new Users1 { };
user.Age = Convert.ToInt32(txtAge.Text);
user.Name = txtName.Text;
_users.Insert(user);
var id = user.Id;
}
MessageBox.Show("User with name " + txtName.Text + " created");
}
複製程式碼 程式碼如下:
///下面的程式碼幫助你從Mongo資料庫中查詢一條現有記錄。
_collection = _database.GetCollection("users");
IMongoQuery query = Query.EQ("Name", "Anoop");
Users1 _user = _collection.FindAs(query).FirstOrDefault();
MessageBox.Show(_user.Age.ToString());
複製程式碼 程式碼如下:
///下面的程式碼幫助你更新Mongo資料庫中的一條現有記錄。
_collection = _database.GetCollection("users");
IMongoQuery query = Query.EQ("Name", "Anoop");
Users1 _user = _collection.FindAs(query).FirstOrDefault();
MessageBox.Show("Age before :" + _user.Age.ToString());
//更新年齡的值
_user.Age = 30;
//儲存更改
_collection.Save(_user);
MessageBox.Show("Age after :" + _user.Age.ToString());
【NET連線MongoDB資料庫例項方法】相關文章：