fix: add directConnection options to MongoDB connection (#9955)

a-fournier · afournier · web-flow · commit e0165e75ee81 · 2023-04-17T21:03:00.000+05:00
Co-authored-by: afournier &lt;afournier@solocal.com&gt;
diff --git a/docs/data-source-options.md b/docs/data-source-options.md
@@ -506,6 +506,8 @@ Different RDBMS-es have their own specific options.
 
 -   `authMechanism` - Sets the authentication mechanism that MongoDB will use to authenticate the connection.
 
+-   `directConnection` - Specifies whether to force dispatch all operations to the specified host.
+
 ## `sql.js` data source options
 
 -   `database`: The raw UInt8Array database that should be imported.
diff --git a/docs/zh_CN/connection-options.md b/docs/zh_CN/connection-options.md
@@ -375,6 +375,8 @@
 
 - `authMechanism` - 设置MongoDB用于验证连接的身份验证机制。 
 
+- `directConnection` - 指定是否强制将所有操作分派到指定的主机。 
+
 > 注： 由于译者对MongoDB理解不够深入，故一些翻译直接使用了机翻，因此会有些词不达意，如有更好的翻译选项，请提交PR进行完善。
 
 ## `sql.js`
diff --git a/src/driver/mongodb/MongoConnectionOptions.ts b/src/driver/mongodb/MongoConnectionOptions.ts
@@ -46,6 +46,11 @@ export interface MongoConnectionOptions extends BaseDataSourceOptions {
      */
     readonly database?: string
 
+    /**
+     * Specifies whether to force dispatch all operations to the specified host. Default: false
+     */
+    readonly directConnection?: boolean
+
     /**
      * The driver object
      * This defaults to require("mongodb")
diff --git a/src/driver/mongodb/MongoDriver.ts b/src/driver/mongodb/MongoDriver.ts
@@ -217,6 +217,7 @@ export class MongoDriver implements Driver {
         "useUnifiedTopology",
         "autoEncryption",
         "retryWrites",
+        "directConnection",
     ]
 
     cteCapabilities: CteCapabilities = {

Original file line number	Diff line number	Diff line change
`@@ -217,6 +217,7 @@ export class MongoDriver implements Driver {`
`217`	`217`	`"useUnifiedTopology",`
`218`	`218`	`"autoEncryption",`
`219`	`219`	`"retryWrites",`
	`220`	`+ "directConnection",`
`220`	`221`	`]`
`221`	`222`
`222`	`223`	`cteCapabilities: CteCapabilities = {`