.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<users3 />("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<users2 />("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<users1 />("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<users1 />("users");
imongoquery query = query.eq("name", "anoop");
users1 _user = _collection.findas<users1 />(query).firstordefault();
messagebox.show(_user.age.tostring());

///下面的代码帮助你更新mongo数据库中的一条现有记录。
_collection = _database.getcollection<users1 />("users");
imongoquery query = query.eq("name", "anoop");
users1 _user = _collection.findas<users1 />(query).firstordefault();
messagebox.show("age before update :" + _user.age.tostring());
//更新年龄的值
_user.age = 30;

//保存更改           
_collection.save(_user);
messagebox.show("age after update :" + _user.age.tostring());