数据文件夹创建好以后,可以通过用命令行提示符在“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());
精彩评论