2023年NET连接MongoDB数据库实例方法

慎而思之，勤而行之。斯是陋室，惟吾德馨。第第2页/共2页精品文档推荐2023年NET衔接MongoDB数据库实例主意收拾NET衔接MongoDB数据库实例主意

使用代码

让我们从Mongo数据库的一些细节和基本命令开始，并总算推荐如何创建一个可衔接至Mongo数据库的.NETWindows应用。

Mongo数据库

MongoDB是一个跨平台、文档导向的数据库系统，它被归类为“NoSQL”数据库。MongoDB避免了传统的基于表的关系数据库结构，而是使用了带动态模式的类JSON文档。MongoDB将这种格式称为BSON(二进制JSON)。这种动态模式使得特定类型应用中的数据整合更容易、更迅速。MongoDB是自由且开源的软件。

Mongo数据库的特性

Adhoc查询

1标引

2复制

3负载均衡

4文件存贮

5聚合

6服务器端JavaScript执行

7定容集合

用户可从此处下载Mongo数据库，然后将其中内容解压至任一文件夹。文件下载完成后，用户需要配置MongoDB的数据文件夹。做法是在“C:Data”文件夹下创建一个名为“DB”的文件夹。

数据文件夹创建好以后，可以通过用命令行提醒符在“bin”文件夹下运行“mongod.exe”来启动Mongo数据库。

现在数据库已经启动，并正在运行。

创建一个.NET应用

创建一个.NETweb/Windows应用。在这个示例中，我们将用一个容易的.员工表。

开始之前，我们需要确保系统中装有MongoDB的.NET驱动。你可以按下面的步骤来为一个指定的项目安装驱动。

打开VisualStudio的包管理器:

打开包管理器控制台后，用户可以执行下面的命令:

复制代码代码如下:

Install-Packagemongocsharpdriver

在项目中添加对下列命名空间的引用:

复制代码代码如下:

usingMongoDB.Bson;

usingMongoDB.Driver;

//此外，你将频繁的用到下面这些using语句中的一条或多条:

usingMongoDB.Driver.Builders;

usingMongoDB.Driver.GridFS;

usingMongoDB.Driver.Linq;

声明数据库服务器和数据库的变量:

复制代码代码如下:

MongoServer_server;

MongoDatabase_database;

用下面的命令衔接至数据库。在这里，数据库服务器是在本地主机上运行的，端口为：27017，数据库名为“anoop”。

复制代码代码如下:

privatevoidForm1_Load(objectsender,EventArgse)

{

stringconnection=mongodb://localhost:27017;

_server=MongoServer.Create(connection);

_database=_server.GetDatabase(anoop,SafeMode.True);

}

在这里，我们创建了三个使用不同属性集合的类。我们可以设置这些类的属性，并将数据保存至同一个数据库、同一个表。这是无模式数据库的真正优势：插入数据时不检查模式。保存不同的记录时可以用不同的域的集合，而其它的域将默认被视为NULL。

复制代码代码如下:

publicclassUsers1

{

publicObjectIdId{get;set;}

publicstringName{get;set;}

publicintAge{get;set;}

}

publicclassUsers2

{

publicObjectIdId{get;set;}

publicstringName{get;set;}

publicstringLocation{get;set;}

}

publicclassUsers3

{

publicObjectIdId{get;set;}

publicstringName{get;set;}

publicintAge{get;set;}

publicstringLocation{get;set;}

}

privatevoidrbEntity1_CheckedChanged(objectsender,EventArgse)

{

txtName.Enabled=true;

txtAge.Enabled=true;

txtLocation.Enabled=true;

}

privatevoidrbEntity2_CheckedChanged(objectsender,EventArgse)

{

txtName.Enabled=true;

txtAge.Enabled=false;

txtLocation.Enabled=true;

}

privatevoidrbEntity3_CheckedChanged(objectsender,EventArgse)

{

txtName.Enabled=true;

txtAge.Enabled=true;

txtLocation.Enabled=false;

}

privatevoidbtnSave_Click(objectsender,EventArgse)

{

if(rbEntity1.Checked)

{

var_users=_database.GetCollection(users);

varuser=newUsers3{};

user.Age=Convert.ToInt32(txtAge.Text);

user.Name=txtName.Text;

user.Location=txtLocation.Text;

_users.Insert(user);

varid=user.Id;

}

elseif(rbEntity2.Checked)

{

var_users=_database.GetCollection(users);

varuser=newUsers2{};

user.Name=txtName.Text;

user.Location=txtLocation.Text;

_users.Insert(user);

varid=user.Id;

}

elseif(rbEntity3.Checked)

{

var_users=_database.GetCollection(users);

varuser=newUsers1{};

user.Age=Convert.ToInt32(txtAge.Text);

user.Name=txtName.Text;

_users.Insert(user);

varid=user.Id;

}

MessageBox.Show(Userwithname+txtName.Text+created);

}

复制代码代码如下:

///下面的代码辅助你从Mongo数据库中寻找一条现有记录。

_collection=_database.GetCollection(users);

IMongoQueryquery=Query.EQ(Name,Anoop);

Users1_user=_collection.FindAs(query).FirstOrDefault();

MessageBox.Show(_user.Age.ToString());

复制代码代码如下:

///下面的代码辅助你更新Mongo数据库中的一条现有记录。

_collection=_database.GetCollection(users);

IMongoQueryquery=Query.EQ(Name,Anoop);

Users1_user=_collection.FindAs(query).FirstOrDefault();

Message