MongoDB C# 驱动
读书笔记 C# Driver 之前看了Bson类库,现在学习C# Driver Thread safety(多线程问题) 只有少部分的C# Driver类是多线程安全的。比如MongoClient,MongoServer,MongoDatabase, MongoCollection 以及MongoGridFS。一般常用的类存在多线程问题,包括MongoCurs
读书笔记
C# Driver
之前看了Bson类库,现在学习C# Driver
Thread safety(多线程问题)
只有少部分的C# Driver类是多线程安全的。比如MongoClient,MongoServer,MongoDatabase, MongoCollection 以及MongoGridFS。一般常用的类存在多线程问题,包括MongoCursor以及Bson类库中的所有类(除了其中的BsonSymbolTable是线程安全的)。
所有的类的静态属性值和函数方法都不会引起多线程问题。
MongoClient类
这个类提供使用MongoDB server的基本对象。与MongoDB server服务进行链接的时候,client自动进行连接。(使用了连接池来进行更有效的连接)
在连接一个副本集的时候,有且只用一个MongoClient实例。
When you are connecting to a replica set you will still use only one instance of MongoClient, which represents the replica set as a whole. The driver automatically finds all the members of the replica set and identifies the current primary.
这个类的实例不会引起多线程问题。
除非其他设置,在默认设置情况下,所有操作需要一个WriteConcern,一个写入确定语句。另外,默认情况下,所有的写操作会锁定,直到server知道要进行写操作。
Connection strings
最简单的数据库连接是使用Connection string。标准的Connection string如下:
mongodb://[username:password@]hostname[:port][/[database][?options]]在使用认证的mongodb服务器上,username和password必须填写。
port号码是可选的。默认的是27017.
如果要连接多个服务器,可以直接填写多个服务器名(以及需要的端口号),并且以‘,’分割。如下:
mongodb://server1,server2:27017,server2:27018上面这段connection string 连接了三个数据库服务,由于多数据库服务是模糊不清的,不能分辨服务是否复本集,或者是多数据库服务。drive驱动会跳过connection string的语法检查,直接连接进数据库服务器,让server自己检查他们的类别。还有一些办法在连接的时候就指定数据服务器的类别,就是在connection string里面直接描述。如下:
mongodb://server1,server2:27017,server2:27018/?connect=replicaset可用的连接模式包括:automatic (默认), direct, replica set, 以及shardrouter。连接的规则如下:
1、如果指定了某种连接模式,则直接使用否则使用默认的automatic。
2、如果在connection string中有replica set name,则使用replica set模式
3、如果connection string中仅有一个服务器,则使用direct模式
4、另外,连接服务之后,服务决定连接的模式
注意:如果有多服务器列表连接,其中有一个是复本集的一个,而其他不是,则连接模式将成为non-deterministic(未决定)。确定connection string中没有混合服务类型。
当连接模式指定成为replica set,美国服务器,但是driver接口还是会找到primary服务器,即使该服务器不在connection连接列表中。直到connection列表中的一个服务器的回应(这个回应包括replica set以及现有的primary服务)。另外,即使在初始化语句完成之后,其他次级服务器也会被发现,并且自动加入到混合集群。这样,香港服务器,如果你有添加以及删除,移动replica set,driver接口会自己处理这些改变。
顺便提到,假设你想要直接连接入一个replica set并且无论它是否是现在的primary(也许只是想监控下它的运行状态或者进行只读语句),可以使用下面连接语句:
mongodb://server2/?connect=direct;readpreference=nearest可以在下面的链接获取比较齐全的connection string文档
更加深入地额:
SSL Support
这些不感兴趣,大概是driver连接的一个设置
通过在connection string里面加入“ssl=true”选项来设置
mongodb://server2/?ssl=true在默认的情况下,server是通过本地的受信任的证书机构获取许可。在一些测试环境下面,测试server没有签署证书,为了缓解这个情况,香港虚拟主机,可以使用在connection string里面添加“sslverifycertificate=false”来屏蔽所有certificate errors(认证错误)。
Authentication
MongoDB支持两种认证方式。一种是在程序执行时,调用特定的方法。在执行特定的方法时,认证将会被使用。另外一种健壮的方法是在MongoCredentialsStore存储认证信息。
下面是一个例子,使用credential store来确定admin和“foo”数据库的认证信息。除了使用“admin”以及“foo”连接入数据库,还可以使用默认的认证“test”。
var url = new MongoUrl("mongodb://test:user@localhost:27017"); var settings = MongoClientSettings.FromUrl(url); var adminCredentials = new MongoCredentials("admin", "user", true); settings.CredentialsStore.Add("admin", adminCredentials); var fooCredentials = new MongoCredentials("foo", "user", false); settings.CredentialsStore.Add("foo", fooCredentials); var client = new MongoClient(settings); 我感觉类似SQL语句: foo.* ; GetServer method 在MongoClient实例中调用GetServer方法获取MongoServer的实例。 MongoServer class使用MongoServer类可以进行更多的控制操作。它使用了先进的技术通过一个单个的socket获取数据库以及进行一系列的数据库操作,并且保持数据库的一致性。
GetDatabase method
通过这个方法访问数据库
例子代码:
MongoClient client = new MongoClient(); // connect to localhost MongoServer server = client.GetServer(); MongoDatabase test = server.GetDatabase("test"); MongoCredentials credentials = new MongoCredentials("username", "password"); MongoDatabase salaries = server.GetDatabase("salaries", credentials);