配置增删改查操作

读取和写入设置优先级

您可以在以下级别设置写关注、读关注和读取偏好选项：

• 客户端，为所有操作执行设置默认值，除非被覆盖

• 事务

• Database

• Collection

此列表还指示了选项设置的优先级递增顺序。示例，如果为ACID 事务设立读关注（read concern），它将覆盖从客户端继承的读关注（read concern）设置。

写关注、读关注（read concern）和读取偏好（read preference）选项允许您自定义副本集中数据的因果一致性和可用性。 要查看这些选项的完整列表，请参阅MongoDB Server手册中的以下指南：

• 读取偏好

• 读关注 (read concern)

• 写关注

客户端配置

此示例演示如何通过将 MongoClientSettings实例传递给构造函数来设立MongoClient实例的读取偏好（read preference）、读关注（read concern）和写关注（write concern）。该代码配置以下设置：

• secondary 读取偏好（read preference）：读取操作从从节点(secondary node from replica set)副本集成员检索数据。

• LOCAL 读关注（read concern）：读取操作会返回实例的最新数据，但不保证该数据已写入大多数副本集成员。

• W2 写关注（write concern）：主节点 (primary node in the replica set)副本集成员和一个从节点(secondary node from replica set)成员必须确认写入操作。

val mongoClient = MongoClient(MongoClientSettings.builder()
    .applyConnectionString(ConnectionString("mongodb://localhost:27017/"))
    .readPreference(ReadPreference.secondary())
    .readConcern(ReadConcern.LOCAL)
    .writeConcern(WriteConcern.W2)
    .build())

或者，您可以在连接 URI 中指定读取和写入设置，该 URI 作为参数传递给MongoClient构造函数：

val uriClient = MongoClient("mongodb://localhost:27017/?readPreference=secondary&w=2&readConcernLevel=local")

事务配置

此示例演示如何通过将 TransactionOptions实例传递给 startTransaction() 方法来设立ACID 事务的读取偏好（read preference）、读关注（read concern）和写关注（write concern）。事务在会话中运行，会话是要按顺序运行的相关读取或写入操作的分组。

该示例配置了以下设置：

• primary 读取偏好（read preference）：读取操作从主节点 (primary node in the replica set)副本集成员检索数据。

• MAJORITY 读关注（read concern）：读取操作返回实例已写入大多数副本集成员的最新数据。

• W1 写关注（write concern）：主节点 (primary node in the replica set)副本集成员必须确认写入操作。

val clientSessionFuture = mongoClient.startSession().toFuture()
val clientSession = Await.result(clientSessionFuture, Duration(10, TimeUnit.SECONDS))
val tOptions: TransactionOptions = TransactionOptions.builder()
    .readPreference(ReadPreference.primary())
    .readConcern(ReadConcern.MAJORITY)
    .writeConcern(WriteConcern.W1)
    .build()
clientSession.startTransaction(tOptions)

数据库配置

此示例展示了如何通过将 setter 方法链接到 getDatabase() 方法来设立名为 test_database 的数据库的读取偏好（read preference）、读关注（read concern）和写关注（write concern）。 该代码配置以下设置：

• primaryPreferred 读取偏好（read preference）：读取操作从主节点 (primary node in the replica set)副本集成员检索数据，如果主节点 (primary node in the replica set)不可用，则从从节点(secondary node from replica set)成员检索数据。

• AVAILABLE 读关注（read concern）：读取操作会返回实例的最新数据，但不保证该数据已写入大多数副本集成员。

• MAJORITY 写关注（write concern）：所有副本集成员中的大多数必须确认写入操作。

val database = mongoClient.getDatabase("test_database")
    .withReadPreference(ReadPreference.primaryPreferred())
    .withReadConcern(ReadConcern.AVAILABLE)
    .withWriteConcern(WriteConcern.MAJORITY)

集合配置

此示例展示了如何通过将 setter 方法链接到 getCollection() 方法来设立名为 test_collection 的集合的读取偏好（read preference）、读关注（read concern）和写关注（write concern）。 该代码配置以下设置：

• secondaryPreferred 读取偏好（read preference）：读取操作从从节点(secondary node from replica set)副本集拟节点检索数据，如果没有可用的从节点(secondary node from replica set)节点，则从主节点 (primary node in the replica set)节点检索数据。

• AVAILABLE 读关注（read concern）：读取操作会返回实例的最新数据，但不保证该数据已写入大多数副本集成员。

• UNACKNOWLEDGED 写关注（write concern）：副本设立成员不需要确认写入操作。

val collection = database.getCollection("test_collection")
    .withReadPreference(ReadPreference.secondaryPreferred())
    .withReadConcern(ReadConcern.AVAILABLE)
    .withWriteConcern(WriteConcern.UNACKNOWLEDGED)

分片集群

您可以在连接到分片集群时指定读取偏好（read preference）。MongoDB使用分片按键范围划分数据集，并将数据分布到多个数据库实例。分片集群（或分片的部署中的节点设立）包括以下组件：

• 分片：包含分片的数据子集的副本副本集。

• Mongos：一种查询路由器，在应用程序和分片集群之间提供接口。

• 配置服务器：存储集群配置设置和元数据的服务器。

从副本集分片读取时，mongos 会应用您指定的读取偏好（read preference）。对于每个操作，都会重新评估读取偏好（read preference）。

以下示例展示了如何连接到分片集群并在连接字符串中指定 secondary读取偏好（read preference）：

val mongosClient = MongoClient("mongodb://user:password@mongos1.example.com,mongos2.example.com/?readPreference=secondary")

标签集

在MongoDB Server中，您可以根据您选择的任何条件将键值标签应用副本集成员。然后，您可以使用这些标签来定位一个或多个成员以执行读取操作。

默认情况下，Scala 驱动程序在选择要读取的节点时会忽略标签。要指示 Scala 驱动程序优先选择某些标签，请将标签作为列表传递给您的读取偏好 setter 方法。

假设您连接到一个副本集，其中包含托管在美国多个数据中心的节点。您希望驱动程序优先按以下顺序从从节点副本集成员中读取：

1. 来自 纽约数据中心 的节点，标记为 ("dc", "ny")

2. 来自旧金山数据中心的节点，标记为 ("dc", "sf")

3. 任何从从节点(secondary node from replica set)

此代码示例会将表示前面副本集成员的标签列表传递给 ReadPreference.secondary() setter 方法。 然后，代码将读取偏好（read preference）信息传递给 withReadPreference() 方法，以在数据库上设立读取顺序：

val tag1 = new TagSet(new Tag("dc", "ny"))
val tag2 = new TagSet(new Tag("dc", "sf"))
val tag3 = new TagSet()
val readPreference = ReadPreference.secondary(List(tag1, tag2, tag3).asJava)
val database = mongoClient.getDatabase("test_database")
                          .withReadPreference(readPreference)

负载均衡

连接到分片集群或副本集时， Scala驾驶员使用负载均衡来处理读取和写入请求。负载均衡允许驾驶员将这些请求分发到多台服务器，从而避免任何一台服务器不堪重负，确保最佳性能。

连接到分片集群时， Scala驾驶员会计算网络往返时间最短的实例，从而确定最接近的mongos 实例。然后，驾驶员通过将此mongos 实例的平均往返时间与 localThresholdMS 值相加来确定延迟窗口。驾驶员在延迟窗口内的最多两个随机mongos 实例之间对请求进行负载均衡。对于每个请求，驾驶员会通过确定其operationCount 值来选择具有较低操作负载的服务器。

连接到副本集时， Scala驾驶员首先根据读取偏好（read preference）副本集成员。然后，驾驶员执行与上一段所述相同的进程。计算延迟窗口后，驾驶员最多选择两个处于该窗口内的随机副本集节点，并选择具有较低 operationCount 值的节点来接收请求。

val client = MongoClient(MongoClientSettings.builder()
    .applyConnectionString(ConnectionString("mongodb://localhost:27017/"))
    .applyToClusterSettings(builder => builder
        .localThreshold(35, TimeUnit.MILLISECONDS)
    )
    .build())

val connectionString = "mongodb://localhost:27017/?replicaSet=repl0&localThresholdMS=35"
val client = MongoClient(connectionString)