运用到的MongoDB支持的C#驱动,当前版本为1.6.0
下载地址:
1,连接数据库
////// 数据库连接 /// private const string conn = "mongodb://127.0.0.1:27017"; ////// 指定的数据库 /// private const string dbName = "mongodb_name"; ////// 指定的表 /// 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
下面是添加数据的代码
////// 添加 /// /// 内容 /// 文章ID /// 频道ID ///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、删除操作
////// 根据ObjectID 删除 /// /// public static void Delete(string objId) { //创建数据连接 MongoServer server = MongoServer.Create(conn); //获取指定数据库 MongoDatabase db = server.GetDatabase(dbName); //获取表 MongoCollectioncol = db.GetCollection (tbName); IMongoQuery query = Query.EQ("_id", new ObjectId(objId)); col.Remove(query); }
4、修改
////// 根据ObjectID 修改 /// public static void Update(User t) { //创建数据连接 MongoServer server = MongoServer.Create(conn); //获取指定数据库 MongoDatabase db = server.GetDatabase(dbName); //获取表 MongoCollectioncol = db.GetCollection (tbName); BsonDocument bd = BsonExtensionMethods.ToBsonDocument(t); IMongoQuery query = Query.EQ("_id", t.Id); col.Update(query, new UpdateDocument(bd)); }
5、条件查询(简单)
////// 根据ObjectID 查询 /// public static TuCao SelectOne(string objId) { //创建数据连接 MongoServer server = MongoServer.Create(conn); //获取指定数据库 MongoDatabase db = server.GetDatabase(dbName); //获取表 MongoCollectioncol = db.GetCollection (tbName); //条件查询 return col.FindOne(Query.EQ("_id", new ObjectId(objId))); }
6、查询全部
////// 查询所有 /// public static void SelectAll() { Listlist = new List (); //创建数据连接 MongoServer server = MongoServer.Create(conn); //获取指定数据库 MongoDatabase db = server.GetDatabase(dbName); //获取表 MongoCollection col = db.GetCollection (tbName); //查询全部 list.AddRange(col.FindAll()); //-------------------------------- foreach (TuCao t in col.FindAll()) { string id = t.Id.ToString(); string text = t.Text; DateTime dt = t.Createdate; } }