MongoDB的简单操作(asp.net)
2016-04-07 09:49
549 查看
using System; using System.Collections.Generic; using System.Linq; using System.Web; using MongoDB.Driver; using MongoDB.Bson; using MongoDB.Driver.Builders; namespace web { public class MongoHelper { /// <summary> /// 数据库连接 /// </summary> private static string conn = "mongodb://127.0.0.1:27017"; /// <summary> /// 指定的数据库 /// </summary> private static string dbName = "mydb"; /// <summary> /// 指定的表 /// </summary> private static string tbName = "test"; /// <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); } /// <summary> /// 根据ObjectID 删除 /// </summary> /// <param name="objId"></param> public static void Delete(int objId) { //创建数据连接 MongoServer server = MongoServer.Create(conn); //获取指定数据库 MongoDatabase db = server.GetDatabase(dbName); //获取表 MongoCollection<User> col = db.GetCollection<User>(tbName); IMongoQuery query = Query.EQ("_id", objId); col.Remove(query); } /// <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)); } //<summary> //根据ObjectID 查询 //</summary> public static User SelectOne(int objId) { //创建数据连接 MongoServer server = MongoServer.Create(conn); //获取指定数据库 MongoDatabase db = server.GetDatabase(dbName); //获取表 MongoCollection<User> col = db.GetCollection<User>(tbName); //条件查询 return col.FindOne(Query.EQ("_id", objId)); } //<summary> //查询所有 //</summary> public static List<User> 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()); return list; } } }
相关文章推荐
- ES-MongoDB学习4_mongo-connector原理及改造
- MongoDB的简介及安装
- node.js中如何使用mongodb数据库
- MongoDB快速学习
- mongoDB window平台安装MongoDB
- MongoDB 3.0新增特性一览
- Mongodb的安装、主从配置、replicaSet配置
- mongodb高可用性架构—Replica Set
- java 中 mongodb的各种操作(二)
- mongodb安装添加服务
- MongoDB安全选项导致的“norepl”错误
- mongodb与mysql相比的优缺点
- windows版mongodb不知道安装在哪儿
- MongoDB常用命令
- Linux下MongoDB安装
- Linux下MongoDB安装和启动配置(转载)
- mongoDB添加用户
- java 连接mongodb问题
- MongoDB 索引的使用, 管理 和优化
- Mongodb 术语