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();
}