但是對於更新后的版本網上資料更多是針對老版本，有些API在新版本中是被廢棄掉的。本文將介紹C#如何對window下Mongodb3.4進行簡單的增刪改查。
1、下載Mongodb，下載地址如下：
https://www.mongodb.com/download-center?jmp=nav#community
安裝成功后(我這里是安裝在D盤)，需要在D盤中(如果安裝在C盤，就在C盤中)創建一個Data文件夾，然后在Data文件夾中新建一個db文件夾，如下圖所示：
2、運行Mongodb服務
在Mongodb文件夾bin中，可以找到mongod.exe(服務端)和mongo.exe(客戶端)，我們需要用cmd以管理員身份運行mongod.exe，運行結果如圖所示：
這樣Monodb服務就開啟成功(mongodb默認分配的端口號都是27017)
我們再以相同的方式運行mongo.exe,運行結果如圖所示:
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;
}
}
轉載於:https://www.cnblogs.com/liaocheng/p/5087453.html
原文鏈接：https://blog.csdn.net/m0_37044279/article/details/76863470