MongoDB的C#驅動只有一些類是線程安全的,其中包含(MongoServer、MongoDatabase、MongoCollection、MongoGridFS),其他的大多數類不是線程安全的。有些場景需要保證數據的正確性,需要將一系列的操作綁定到DB級對象。那麼可以用類似事務控制的方式保證一致...
MongoDB的C#驅動只有一些類是線程安全的,其中包含(MongoServer、MongoDatabase、MongoCollection、MongoGridFS),其他的大多數類不是線程安全的。
有些場景需要保證數據的正確性,需要將一系列的操作綁定到DB級對象。那麼可以用類似事務控制的方式保證一致性。
//事務控制
static void Main(string[] args)
{
//資料庫連接字元串
string connectionString = "mongodb://127.0.0.1:27017";
//得到一個對象實例的連接
var client = new MongoClient(connectionString);
var server = client.GetServer();
//MongoServer server = MongoServer.Create(connectionString);
//指定安全證書
MongoCredentials credential = new MongoCredentials("wander", "123456");
//獲得一個"mongoDB"連接對象
MongoDatabase mydb = server.GetDatabase("test", credential);
//開始事務控制
server.RequestStart(mydb);
//在此添加業務邏輯
//結束事務控制
server.RequestDone();
}
MongoDB實例操作
實例是資料庫最大工作單元,在實例中有資料庫、表等對象,接下來看實例級別操作。
1)判斷MongoDB實例是否存活
//判斷當前實例是否存活
static void Main(string[] args)
{
//資料庫連接字元串
string connectionString = "mongodb://root:[email protected]:27017";
//得到一個對象實例的連接
var client = new MongoClient(connectionString);
var server = client.GetServer();
server.Ping();
}
沒有存活會拋出異常
2)遠程式控制制管理MongoDB實例
//關閉MongoDB實例
static void Main(string[] args)
{
//資料庫連接字元串
string connectionString = "mongodb://root:[email protected]:27017";
//得到一個對象實例的連接
var client = new MongoClient(connectionString);
var server = client.GetServer();
server.Shutdown();
}
註意到沒有證書了麽?這裡需要最高級root用戶來連接,無需指定證書。
3)列出所有的資料庫
static void Main(string[] args)
{
//資料庫連接字元串
string connectionString = "mongodb://root:[email protected]:27017";
//得到一個對象實例的連接
var client = new MongoClient(connectionString);
var server = client.GetServer();
var names = server.GetDatabaseNames();
foreach(var name in names)
{
Console.WriteLine(name);
}
Console.ReadLine();
}
4)判斷資料庫是否存在
//判斷資料庫是否存在
static void Main(string[] args)
{
//資料庫連接字元串
string connectionString = "mongodb://root:[email protected]:27017";
//得到一個對象實例的連接
var client = new MongoClient(connectionString);
var server = client.GetServer();
Console.WriteLine(server.DatabaseExists("test"));
Console.ReadLine();
}