C# 对MongoDB 进行增删改查的简单操作
2023-09-27 14:28:19 时间
C# 对MongoDB 进行增删改查的简单操作
下面演示下C#操作MongoDB驱动的简单的增删改查代码
运用到的MongoDB支持的C#驱动,当前版本为1.6.0
1,连接数据库
/// <summary> /// 数据库连接 /// </summary> private const string conn = "mongodb://127.0.0.1:27017"; /// <summary> /// 指定的数据库 /// </summary> private const string dbName = "mongodb_name"; /// <summary> /// 指定的表 /// </summary> private const string tbName = "table_text"; //创建数据连接 MongoServer server = MongoServer.Create(conn); //获取指定数据库 MongoDatabase db = server.GetDatabase(dbName); //获取表 MongoCollection col = db.GetCollection(tbName);
2、插入数据
因为MongoDB没有表的概念,所以自插入数据之前定义好自己的数据模型
User.cs
下面是添加数据的代码
/// <summary> /// 添加 /// </summary> /// <param name="text">内容</param> /// <param name="articleId">文章ID</param> /// <param name="channelId">频道ID</param> /// <returns></returns> public static void Add(User t) { //创建数据连接 MongoServer server = MongoServer.Create(conn); //获取指定数据库 MongoDatabase db = server.GetDatabase(dbName); //获取表 MongoCollection col = db.GetCollection(tbName); //插入 col.Insert(t); }
3、删除操作
/// <summary> /// 根据ObjectID 删除 /// </summary> /// <param name="objId"></param> public static void Delete(string objId) { //创建数据连接 MongoServer server = MongoServer.Create(conn); //获取指定数据库 MongoDatabase db = server.GetDatabase(dbName); //获取表 MongoCollection<User> col = db.GetCollection<User>(tbName); IMongoQuery query = Query.EQ("_id", new ObjectId(objId)); col.Remove(query); }
4、修改
/// <summary> /// 根据ObjectID 修改 /// </summary> public static void Update(User t) { //创建数据连接 MongoServer server = MongoServer.Create(conn); //获取指定数据库 MongoDatabase db = server.GetDatabase(dbName); //获取表 MongoCollection<User> col = db.GetCollection<User>(tbName); BsonDocument bd = BsonExtensionMethods.ToBsonDocument(t); IMongoQuery query = Query.EQ("_id", t.Id); col.Update(query, new UpdateDocument(bd)); }
5、条件查询(简单)
/// <summary> /// 根据ObjectID 查询 /// </summary> public static User TuCao SelectOne(string objId) { //创建数据连接 MongoServer server = MongoServer.Create(conn); //获取指定数据库 MongoDatabase db = server.GetDatabase(dbName); //获取表 MongoCollection<User> col = db.GetCollection<User>(tbName); //条件查询 return col.FindOne(Query.EQ("_id", new ObjectId(objId))); }
6、查询全部
/// <summary> /// 查询所有 /// </summary> public static void SelectAll() { List<User> list = new List<User>(); //创建数据连接 MongoServer server = MongoServer.Create(conn); //获取指定数据库 MongoDatabase db = server.GetDatabase(dbName); //获取表 MongoCollection<User> col = db.GetCollection<User>(tbName); //查询全部 list.AddRange(col.FindAll()); //-------------------------------- foreach (User t in col.FindAll()) { string id = t.Id.ToString(); string text = t.Text; DateTime dt = t.Createdate; } }
相关文章
- C#如何调用DOS命令
- 【转】MongoDB C# / .NET Driver 中IMongoQuery的内部实现Query的用法
- C#.NET 大型企业信息化系统集成快速开发平台 4.1 版本 - 面向数据库SQL语句的应用开发二
- C#实现基于广度优先BFS求解无权图最短路径----完整程序展示
- c#网络通信框架networkcomms内核解析之一 消息传送
- C#基础篇 - 正则表达式入门
- C# 连接MongoDB,含用户验证
- OpenCvSharp (C# OpenCV) 指针方法读取和修改图像像素值(附源码)
- C# 可选参数 命名参数
- C#开发微信公众平台-就这么简单(附Demo)
- Unity3d 着色器Shader的[Toggle]组件C#脚本控制问题解决方法
- .NET(C#)使用委托(delegate)和Func<in T, out TResult>作为方法返回值
- 2018-9-30-C#-winforms-输入颜色转换颜色名
- C# 通过编程的方法在桌面创建回收站快捷方式