• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

C# mongodb [下]

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

  传统的关系数据库一般由数据库(database)、表(table)、记录(record)三个层次概念组成,MongoDB是由数据库(database)、集合(collection)、文档对象(document)三个层次组成。MongoDB对于关系型数据库里的表,但是集合中没有列、行和关系概念,这体现了模式自由的特点。

  在C#中想使用MongoDB我们还需要下载驱动,现在一般比较常见的驱动有官网驱动,samus驱动。samus驱动除了支持一般形式的操作之外,还支持linq方式操纵数据。本文所使用的为官网驱动。官网驱动地址:点击下载

     下载完后我们在下载包中可以得到二个DLL:

  MongoDB.Driver.dll  驱动程序

  MongoDB.Bson.dll    序列化、Json相关

实例代码

新增:

//数据库连接字符串
const string connectionString = "mongodb://127.0.0.1:27017";
//数据库
const string Database = "ck_test_db";

MongoClient client = new MongoClient(connectionString);
MongoServer server = client.GetServer();
MongoDatabase db = server.GetDatabase(Database);
MongoCollection collection = db.GetCollection("student");

//新增
student stud_Add = new student() { name="赵云", code="2001", sex="", age="23" };
collection.Insert<student>(stud_Add);

//查询
QueryDocument query_sel = new QueryDocument { { "name", "赵云" } };
var list = collection.FindAs<student>(query_sel);
foreach (student item in list)
{
    Console.WriteLine("name:{0},code:{1}", item.name, item.code);
}

 

显示结果:

修改:

//数据库连接字符串
const string connectionString = "mongodb://127.0.0.1:27017";
//数据库
const string Database = "ck_test_db";

MongoClient client = new MongoClient(connectionString);
MongoServer server = client.GetServer();
MongoDatabase db = server.GetDatabase(Database);
MongoCollection collection = db.GetCollection("student");
//更新
QueryDocument query_upd = new QueryDocument { { "name", "赵云" } };
IMongoUpdate update = Update.Set("code", "4444");  
collection.Update(query_upd, update);

显示结果:

删除

//数据库连接字符串
const string connectionString = "mongodb://127.0.0.1:27017";
//数据库
const string Database = "ck_test_db";

MongoClient client = new MongoClient(connectionString);
MongoServer server = client.GetServer();
MongoDatabase db = server.GetDatabase(Database);
MongoCollection collection = db.GetCollection("student");
//删除
QueryDocument query_del = new QueryDocument { { "name", "赵云" } };
collection.Remove(query_del);

全量代码:

static void Main(string[] args)
{
    //数据库连接字符串
    const string connectionString = "mongodb://127.0.0.1:27017";
    //数据库
    const string Database = "ck_test_db";

    MongoClient client = new MongoClient(connectionString);
    MongoServer server = client.GetServer();
    MongoDatabase db = server.GetDatabase(Database);
    MongoCollection collection = db.GetCollection("student");

    //新增
    student stud_Add = new student() { name="赵云", code="2001", sex="", age="23" };
    collection.Insert<student>(stud_Add);

    //更新
    QueryDocument query_upd = new QueryDocument { { "name", "赵云" } };
    IMongoUpdate update = Update.Set("code", "4444");  
    collection.Update(query_upd, update);

    //删除
    QueryDocument query_del = new QueryDocument { { "name", "赵云" } };
    collection.Remove(query_del);

    //查询
    QueryDocument query_sel = new QueryDocument { { "name", "赵云" } };
    var list = collection.FindAs<student>(query_sel);
    foreach (student item in list)
    {
        Console.WriteLine("name:{0},code:{1}", item.name, item.code);
    }
}

public class student
{
    public ObjectId _id; //BsonType.ObjectId 这个对应了 MongoDB.Bson.ObjectId 
    public string name { get; set; }
    public string code { get; set; }
    public string sex { get; set; }
    public string age { get; set; }

    /*_id 属性必须要有,否则在更新数据时会报错:“Element '_id' does not match any field or property of class”。*/
}
View Code

基础的增删改查就是上面所述。

实例代码:点击下载

 


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
C#.NET动态调用webservice的三种方式发布时间:2022-07-10
下一篇:
C# 动态加载程序集发布时间:2022-07-10
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap