nect(); } } }
6.实现增删改查
6.1 了解
如果你看前面的在命令行下操作mongodb的话,就开始6.3吧!
6.2 建立连接
实例化 连接类,声明数据库名,和集合名!
string dbname = "student";
string colName = "yuan";
Connection conn = new Connection(dbname);
6.3 创建集合
调用创建方法
bool type= conn.createCollection(colName);
if (type)
{
Console.WriteLine("创建成功!");
}
else
{
Console.WriteLine("创建失败!");
}
Console.ReadKey();
6.4 插入单条信息
BsonDocument bson = new BsonDocument("name","csdn");
bool type= conn.insert(colName, bson);
if (type)
{
Console.WriteLine("增加数据成功!");
}
else
{
Console.WriteLine("增加数据成功失败!");
}
6.5 插入多条信息
Dictionary
dic=new Dictionary
(); dic.Add("name","ming"); dic.Add("age","23"); dic.Add("collage","hpu"); dic.Add("sno","31120907"); Dictionary
dic1 = new Dictionary
(); dic1.Add("name", "zhuo"); dic1.Add("age", "10"); dic1.Add("collage", "hpu"); dic1.Add("sno", "31120908"); List
list = new List
() { new BsonDocument(dic), new BsonDocument(dic1) }; bool type=conn.insert(colName, list); if (type) { Console.WriteLine("增加数据成功!"); } else { Console.WriteLine("增加数据成功失败!"); } Console.ReadKey();
6.6 简单查询
MongoCursor
cursor = conn.select(colName, null);
foreach (BsonDocument bson in cursor)
{
Console.WriteLine(bson.ToString());
}
Console.ReadKey();
结果如下:
6.7 条件查询
//条件查询
QueryDocument query = new QueryDocument("collage", "hpu");
MongoCursor
cursor = conn.select(colName, query);
foreach (BsonDocument bson in cursor)
{
Console.WriteLine(bson.ToString());
}
Console.ReadKey();
结果如下:
6.8 修改操作
QueryDocument query = new QueryDocument("name", "zhuo");
Dictionary
dic1 = new Dictionary
(); dic1.Add("name", "zhuo"); dic1.Add("age", "23"); dic1.Add("collage", "hpu"); dic1.Add("sno", "31120908"); UpdateDocument upd = new UpdateDocument(dic1); bool type = conn.update(colName, query, upd); if (type) { Console.WriteLine("修改数据成功!"); } else { Console.WriteLine("修改数据失败!"); } //查看修改信息 QueryDocument query1 = new QueryDocument("name", "zhuo"); MongoCursor
cursor = conn.select(colName, query1); foreach (BsonDocument bson in cursor) { Console.WriteLine(bson.ToString()); } Console.ReadKey();
结果如下:
6.9 删除操作
//先查询下全部
Console.WriteLine("我是全部");
MongoCursor
cursor = conn.select(colName, null);
foreach (BsonDocument bson in cursor)
{
Console.WriteLine(bson.ToString());
}
//删除age等于23的
QueryDocument query = new QueryDocument("age","23");
//第三个参数 为0时删除满足条件的所有,为其他数字是,仅删除1条
bool type=conn.delete(colName, query, 1);
Console.WriteLine("我是删除后的!");
MongoCursor
cursor1 = conn.select(colName, null); foreach (BsonDocument bson in cursor1) { Console.WriteLine(bson.ToString()); }
效果图如下:

7.总结 :这里仅仅演示了简单的增删改查,后面,大量的条件查询,还行练习
8. demo 下载
?