diff --git a/src/cmap/wire_protocol/responses.ts b/src/cmap/wire_protocol/responses.ts
index e69cf84cfc..6c166afd61 100644
--- a/src/cmap/wire_protocol/responses.ts
+++ b/src/cmap/wire_protocol/responses.ts
@@ -329,3 +329,29 @@ export class ExplainedCursorResponse extends CursorResponse {
     return this.toObject(options);
   }
 }
+
+/**
+ * Client bulk writes have some extra metadata at the top level that needs to be
+ * included in the result returned to the user.
+ */
+export class ClientBulkWriteCursorResponse extends CursorResponse {
+  get insertedCount() {
+    return this.get('nInserted', BSONType.int, true);
+  }
+
+  get upsertedCount() {
+    return this.get('nUpserted', BSONType.int, true);
+  }
+
+  get matchedCount() {
+    return this.get('nMatched', BSONType.int, true);
+  }
+
+  get modifiedCount() {
+    return this.get('nModified', BSONType.int, true);
+  }
+
+  get deletedCount() {
+    return this.get('nDeleted', BSONType.int, true);
+  }
+}
diff --git a/src/cursor/client_bulk_write_cursor.ts b/src/cursor/client_bulk_write_cursor.ts
new file mode 100644
index 0000000000..115f203a76
--- /dev/null
+++ b/src/cursor/client_bulk_write_cursor.ts
@@ -0,0 +1,64 @@
+import type { Document } from '../bson';
+import { type ClientBulkWriteCursorResponse } from '../cmap/wire_protocol/responses';
+import type { MongoClient } from '../mongo_client';
+import { ClientBulkWriteOperation } from '../operations/client_bulk_write/client_bulk_write';
+import { type ClientBulkWriteOptions } from '../operations/client_bulk_write/common';
+import { executeOperation } from '../operations/execute_operation';
+import type { ClientSession } from '../sessions';
+import { mergeOptions, MongoDBNamespace } from '../utils';
+import {
+  AbstractCursor,
+  type AbstractCursorOptions,
+  type InitialCursorResponse
+} from './abstract_cursor';
+
+/** @public */
+export interface ClientBulkWriteCursorOptions
+  extends AbstractCursorOptions,
+    ClientBulkWriteOptions {}
+
+/**
+ * @public
+ */
+export class ClientBulkWriteCursor extends AbstractCursor {
+  public readonly command: Document;
+  /** @internal */
+  private cursorResponse?: ClientBulkWriteCursorResponse;
+  /** @internal */
+  private clientBulkWriteOptions: ClientBulkWriteOptions;
+
+  /** @internal */
+  constructor(client: MongoClient, command: Document, options: ClientBulkWriteOptions = {}) {
+    super(client, new MongoDBNamespace('admin'), options);
+
+    this.command = command;
+    this.clientBulkWriteOptions = options;
+  }
+
+  get response(): ClientBulkWriteCursorResponse {
+    if (this.cursorResponse) return this.response;
+    throw new Error('no cursor response');
+  }
+
+  clone(): ClientBulkWriteCursor {
+    const clonedOptions = mergeOptions({}, this.clientBulkWriteOptions);
+    delete clonedOptions.session;
+    return new ClientBulkWriteCursor(this.client, this.command, {
+      ...clonedOptions
+    });
+  }
+
+  /** @internal */
+  async _initialize(session: ClientSession): Promise<InitialCursorResponse> {
+    const clientBulkWriteOperation = new ClientBulkWriteOperation(this.command, {
+      ...this.clientBulkWriteOptions,
+      ...this.cursorOptions,
+      session
+    });
+
+    const response = await executeOperation(this.client, clientBulkWriteOperation);
+    this.cursorResponse = response;
+
+    return { server: clientBulkWriteOperation.server, session, response };
+  }
+}
diff --git a/src/index.ts b/src/index.ts
index dda026323a..34653143d8 100644
--- a/src/index.ts
+++ b/src/index.ts
@@ -473,6 +473,18 @@ export type {
   AggregateOptions,
   DB_AGGREGATE_COLLECTION
 } from './operations/aggregate';
+export type {
+  AnyClientBulkWriteModel,
+  ClientBulkWriteOptions,
+  ClientBulkWriteResult,
+  ClientDeleteManyModel,
+  ClientDeleteOneModel,
+  ClientInsertOneModel,
+  ClientReplaceOneModel,
+  ClientUpdateManyModel,
+  ClientUpdateOneModel,
+  ClientWriteModel
+} from './operations/client_bulk_write/common';
 export type {
   CollationOptions,
   CommandOperation,
diff --git a/src/mongo_client.ts b/src/mongo_client.ts
index e8aae51639..eed959218f 100644
--- a/src/mongo_client.ts
+++ b/src/mongo_client.ts
@@ -30,6 +30,12 @@ import {
   SeverityLevel
 } from './mongo_logger';
 import { TypedEventEmitter } from './mongo_types';
+import {
+  type AnyClientBulkWriteModel,
+  type ClientBulkWriteOptions,
+  type ClientBulkWriteResult
+} from './operations/client_bulk_write/common';
+import { ClientBulkWriteExecutor } from './operations/client_bulk_write/executor';
 import { executeOperation } from './operations/execute_operation';
 import { RunAdminCommandOperation } from './operations/run_command';
 import type { ReadConcern, ReadConcernLevel, ReadConcernLike } from './read_concern';
@@ -477,6 +483,18 @@ export class MongoClient extends TypedEventEmitter<MongoClientEvents> implements
     return this.s.bsonOptions;
   }
 
+  /**
+   * Executes a client bulk write operation, available on server 8.0+.
+   * @param models - The client bulk write models.
+   * @param options - The client bulk write options.
+   */
+  async bulkWrite(
+    models: AnyClientBulkWriteModel[],
+    options?: ClientBulkWriteOptions
+  ): Promise<ClientBulkWriteResult> {
+    return await new ClientBulkWriteExecutor(this, models, options).execute();
+  }
+
   /**
    * Connect to MongoDB using a url
    *
diff --git a/src/operations/client_bulk_write/client_bulk_write.ts b/src/operations/client_bulk_write/client_bulk_write.ts
new file mode 100644
index 0000000000..36aff6700b
--- /dev/null
+++ b/src/operations/client_bulk_write/client_bulk_write.ts
@@ -0,0 +1,41 @@
+import { type Document } from 'bson';
+
+import { ClientBulkWriteCursorResponse } from '../../cmap/wire_protocol/responses';
+import type { Server } from '../../sdam/server';
+import type { ClientSession } from '../../sessions';
+import { AbstractOperation, Aspect, defineAspects } from '../operation';
+import { type ClientBulkWriteOptions } from './common';
+
+export class ClientBulkWriteOperation extends AbstractOperation<ClientBulkWriteCursorResponse> {
+  command: Document;
+  override options: ClientBulkWriteOptions;
+
+  override get commandName() {
+    return 'bulkWrite' as const;
+  }
+
+  constructor(command: Document, options: ClientBulkWriteOptions) {
+    super(options);
+    this.command = command;
+    this.options = options;
+  }
+
+  override async execute(
+    server: Server,
+    session: ClientSession | undefined
+  ): Promise<ClientBulkWriteCursorResponse> {
+    return await server.command(
+      this.ns,
+      this.command,
+      {
+        ...this.options,
+        ...this.bsonOptions,
+        documentsReturnedIn: 'firstBatch',
+        session
+      },
+      ClientBulkWriteCursorResponse
+    );
+  }
+}
+
+defineAspects(ClientBulkWriteOperation, [Aspect.WRITE_OPERATION]);
diff --git a/src/operations/client_bulk_write/common.ts b/src/operations/client_bulk_write/common.ts
index e76fb5108f..78e16eaa1a 100644
--- a/src/operations/client_bulk_write/common.ts
+++ b/src/operations/client_bulk_write/common.ts
@@ -144,3 +144,77 @@ export type AnyClientBulkWriteModel =
   | ClientUpdateManyModel
   | ClientDeleteOneModel
   | ClientDeleteManyModel;
+
+/** @public */
+export interface ClientBulkWriteResult {
+  /**
+   * The total number of documents inserted across all insert operations.
+   */
+  insertedCount: number;
+  /**
+   * The total number of documents upserted across all update operations.
+   */
+  upsertedCount: number;
+  /**
+   * The total number of documents matched across all update operations.
+   */
+  matchedCount: number;
+  /**
+   * The total number of documents modified across all update operations.
+   */
+  modifiedCount: number;
+  /**
+   * The total number of documents deleted across all delete operations.
+   */
+  deletedCount: number;
+}
+
+export interface VerboseClientBulkWriteResult extends ClientBulkWriteResult {
+  /**
+   * The results of each individual insert operation that was successfully performed.
+   */
+  insertResults: Map<number, ClientInsertOneResult>;
+  /**
+   * The results of each individual update operation that was successfully performed.
+   */
+  updateResults: Map<number, ClientUpdateResult>;
+  /**
+   * The results of each individual delete operation that was successfully performed.
+   */
+  deleteResults: Map<number, ClientDeleteResult>;
+}
+
+export interface ClientInsertOneResult {
+  /**
+   * The _id of the inserted document.
+   */
+  insertedId: any;
+}
+
+export interface ClientUpdateResult {
+  /**
+   * The number of documents that matched the filter.
+   */
+  matchedCount: number;
+
+  /**
+   * The number of documents that were modified.
+   */
+  modifiedCount: number;
+
+  /**
+   * The _id field of the upserted document if an upsert occurred.
+   *
+   * It MUST be possible to discern between a BSON Null upserted ID value and this field being
+   * unset. If necessary, drivers MAY add a didUpsert boolean field to differentiate between
+   * these two cases.
+   */
+  upsertedId?: any;
+}
+
+export interface ClientDeleteResult {
+  /**
+   * The number of documents that were deleted.
+   */
+  deletedCount: number;
+}
diff --git a/src/operations/client_bulk_write/executor.ts b/src/operations/client_bulk_write/executor.ts
new file mode 100644
index 0000000000..71c34cf956
--- /dev/null
+++ b/src/operations/client_bulk_write/executor.ts
@@ -0,0 +1,42 @@
+import { ClientBulkWriteCursor } from '../../cursor/client_bulk_write_cursor';
+import { type MongoClient } from '../../mongo_client';
+import { ClientBulkWriteCommandBuilder } from './command_builder';
+import {
+  type AnyClientBulkWriteModel,
+  type ClientBulkWriteOptions,
+  type ClientBulkWriteResult
+} from './common';
+import { ClientBulkWriteResultsMerger } from './results_merger';
+
+/**
+ * Responsible for executing a client bulk write.
+ * @internal
+ */
+export class ClientBulkWriteExecutor {
+  client: MongoClient;
+  options: ClientBulkWriteOptions;
+  operations: AnyClientBulkWriteModel[];
+
+  constructor(
+    client: MongoClient,
+    operations: AnyClientBulkWriteModel[],
+    options?: ClientBulkWriteOptions
+  ) {
+    this.client = client;
+    this.options = options || {};
+    this.operations = operations;
+  }
+
+  async execute(): Promise<ClientBulkWriteResult> {
+    const commmandBuilder = new ClientBulkWriteCommandBuilder(this.operations, this.options);
+    const commands = commmandBuilder.buildCommands();
+    const resultsMerger = new ClientBulkWriteResultsMerger(this.options);
+    for (const command of commands) {
+      const cursor = new ClientBulkWriteCursor(this.client, command, this.options);
+      for (const docs of await cursor.toArray()) {
+        resultsMerger.merge(cursor.response, docs);
+      }
+    }
+    return resultsMerger.result;
+  }
+}
diff --git a/src/operations/client_bulk_write/results_merger.ts b/src/operations/client_bulk_write/results_merger.ts
new file mode 100644
index 0000000000..8a0475aa68
--- /dev/null
+++ b/src/operations/client_bulk_write/results_merger.ts
@@ -0,0 +1,52 @@
+import { type Document } from '../../bson';
+import { type ClientBulkWriteCursorResponse } from '../../cmap/wire_protocol/responses';
+import {
+  type ClientBulkWriteOptions,
+  type ClientBulkWriteResult,
+  type VerboseClientBulkWriteResult
+} from './common';
+
+/**
+ * Merges client bulk write cursor responses together into a single result.
+ * @internal
+ */
+export class ClientBulkWriteResultsMerger {
+  result: ClientBulkWriteResult | VerboseClientBulkWriteResult;
+  options: ClientBulkWriteOptions;
+
+  /**
+   * Instantiate the merger.
+   * @param options - The options.
+   */
+  constructor(options: ClientBulkWriteOptions) {
+    this.options = options;
+    this.result = {
+      insertedCount: 0,
+      upsertedCount: 0,
+      matchedCount: 0,
+      modifiedCount: 0,
+      deletedCount: 0
+    };
+  }
+
+  /**
+   * Merge the results in the cursor to the existing result.
+   * @param response - The cursor response.
+   * @param documents - The documents in the cursor.
+   * @returns The current result.
+   */
+  merge(response: ClientBulkWriteCursorResponse, documents: Document[]): ClientBulkWriteResult {
+    // Update the counts from the cursor response.
+    this.result.insertedCount += response.insertedCount;
+    this.result.upsertedCount += response.upsertedCount;
+    this.result.matchedCount += response.matchedCount;
+    this.result.modifiedCount += response.modifiedCount;
+    this.result.deletedCount += response.deletedCount;
+
+    // Iterate all the documents in the cursor and update the result.
+    for (const document of documents) {
+      document;
+    }
+    return this.result;
+  }
+}
diff --git a/test/integration/crud/crud.spec.test.ts b/test/integration/crud/crud.spec.test.ts
index 912fbcb1ef..d100cb9323 100644
--- a/test/integration/crud/crud.spec.test.ts
+++ b/test/integration/crud/crud.spec.test.ts
@@ -5,8 +5,6 @@ import { runUnifiedSuite } from '../../tools/unified-spec-runner/runner';
 
 const clientBulkWriteTests = new RegExp(
   [
-    'client bulk write delete with collation',
-    'client bulk write delete with hint',
     'client bulkWrite operations support errorResponse assertions',
     'an individual operation fails during an ordered bulkWrite',
     'an individual operation fails during an unordered bulkWrite',
@@ -14,8 +12,7 @@ const clientBulkWriteTests = new RegExp(
     'a top-level failure occurs during a bulkWrite',
     'a bulk write with only errors does not report a partial result',
     'an empty list of write models is a client-side error',
-    'a write concern error occurs during a bulkWrite',
-    'client bulkWrite'
+    'a write concern error occurs during a bulkWrite'
   ].join('|')
 );
 
diff --git a/test/mongodb.ts b/test/mongodb.ts
index 8aeb97b592..3503412304 100644
--- a/test/mongodb.ts
+++ b/test/mongodb.ts
@@ -158,6 +158,7 @@ export * from '../src/operations/aggregate';
 export * from '../src/operations/bulk_write';
 export * from '../src/operations/client_bulk_write/command_builder';
 export * from '../src/operations/client_bulk_write/common';
+export * from '../src/operations/client_bulk_write/results_merger';
 export * from '../src/operations/collections';
 export * from '../src/operations/command';
 export * from '../src/operations/count';
diff --git a/test/spec/command-logging-and-monitoring/monitoring/unacknowledged-client-bulkWrite.json b/test/spec/command-logging-and-monitoring/monitoring/unacknowledged-client-bulkWrite.json
new file mode 100644
index 0000000000..1099b6a1e9
--- /dev/null
+++ b/test/spec/command-logging-and-monitoring/monitoring/unacknowledged-client-bulkWrite.json
@@ -0,0 +1,218 @@
+{
+  "description": "unacknowledged-client-bulkWrite",
+  "schemaVersion": "1.7",
+  "runOnRequirements": [
+    {
+      "minServerVersion": "8.0"
+    }
+  ],
+  "createEntities": [
+    {
+      "client": {
+        "id": "client",
+        "useMultipleMongoses": false,
+        "observeEvents": [
+          "commandStartedEvent",
+          "commandSucceededEvent",
+          "commandFailedEvent"
+        ],
+        "uriOptions": {
+          "w": 0
+        }
+      }
+    },
+    {
+      "database": {
+        "id": "database",
+        "client": "client",
+        "databaseName": "command-monitoring-tests"
+      }
+    },
+    {
+      "collection": {
+        "id": "collection",
+        "database": "database",
+        "collectionName": "test"
+      }
+    }
+  ],
+  "initialData": [
+    {
+      "collectionName": "test",
+      "databaseName": "command-monitoring-tests",
+      "documents": [
+        {
+          "_id": 1,
+          "x": 11
+        },
+        {
+          "_id": 2,
+          "x": 22
+        },
+        {
+          "_id": 3,
+          "x": 33
+        }
+      ]
+    }
+  ],
+  "_yamlAnchors": {
+    "namespace": "command-monitoring-tests.test"
+  },
+  "tests": [
+    {
+      "description": "A successful mixed client bulkWrite",
+      "operations": [
+        {
+          "object": "client",
+          "name": "clientBulkWrite",
+          "arguments": {
+            "models": [
+              {
+                "insertOne": {
+                  "namespace": "command-monitoring-tests.test",
+                  "document": {
+                    "_id": 4,
+                    "x": 44
+                  }
+                }
+              },
+              {
+                "updateOne": {
+                  "namespace": "command-monitoring-tests.test",
+                  "filter": {
+                    "_id": 3
+                  },
+                  "update": {
+                    "$set": {
+                      "x": 333
+                    }
+                  }
+                }
+              }
+            ]
+          },
+          "expectResult": {
+            "insertedCount": {
+              "$$unsetOrMatches": 0
+            },
+            "upsertedCount": {
+              "$$unsetOrMatches": 0
+            },
+            "matchedCount": {
+              "$$unsetOrMatches": 0
+            },
+            "modifiedCount": {
+              "$$unsetOrMatches": 0
+            },
+            "deletedCount": {
+              "$$unsetOrMatches": 0
+            },
+            "insertResults": {
+              "$$unsetOrMatches": {}
+            },
+            "updateResults": {
+              "$$unsetOrMatches": {}
+            },
+            "deleteResults": {
+              "$$unsetOrMatches": {}
+            }
+          }
+        },
+        {
+          "object": "collection",
+          "name": "find",
+          "arguments": {
+            "filter": {}
+          },
+          "expectResult": [
+            {
+              "_id": 1,
+              "x": 11
+            },
+            {
+              "_id": 2,
+              "x": 22
+            },
+            {
+              "_id": 3,
+              "x": 333
+            },
+            {
+              "_id": 4,
+              "x": 44
+            }
+          ]
+        }
+      ],
+      "expectEvents": [
+        {
+          "client": "client",
+          "ignoreExtraEvents": true,
+          "events": [
+            {
+              "commandStartedEvent": {
+                "commandName": "bulkWrite",
+                "databaseName": "admin",
+                "command": {
+                  "bulkWrite": 1,
+                  "errorsOnly": true,
+                  "ordered": true,
+                  "ops": [
+                    {
+                      "insert": 0,
+                      "document": {
+                        "_id": 4,
+                        "x": 44
+                      }
+                    },
+                    {
+                      "update": 0,
+                      "filter": {
+                        "_id": 3
+                      },
+                      "updateMods": {
+                        "$set": {
+                          "x": 333
+                        }
+                      },
+                      "multi": false
+                    }
+                  ],
+                  "nsInfo": [
+                    {
+                      "ns": "command-monitoring-tests.test"
+                    }
+                  ]
+                }
+              }
+            },
+            {
+              "commandSucceededEvent": {
+                "commandName": "bulkWrite",
+                "reply": {
+                  "ok": 1,
+                  "nInserted": {
+                    "$$exists": false
+                  },
+                  "nMatched": {
+                    "$$exists": false
+                  },
+                  "nModified": {
+                    "$$exists": false
+                  },
+                  "nUpserted": {
+                    "$$exists": false
+                  },
+                  "nDeleted": {
+                    "$$exists": false
+                  }
+                }
+              }
+            }
+          ]
+        }
+      ]
+    }
+  ]
+}
diff --git a/test/spec/command-logging-and-monitoring/monitoring/unacknowledged-client-bulkWrite.yml b/test/spec/command-logging-and-monitoring/monitoring/unacknowledged-client-bulkWrite.yml
new file mode 100644
index 0000000000..fcc6b7b3ec
--- /dev/null
+++ b/test/spec/command-logging-and-monitoring/monitoring/unacknowledged-client-bulkWrite.yml
@@ -0,0 +1,109 @@
+description: "unacknowledged-client-bulkWrite"
+
+schemaVersion: "1.7"
+
+runOnRequirements:
+  - minServerVersion: "8.0"
+
+createEntities:
+  - client:
+      id: &client client
+      useMultipleMongoses: false
+      observeEvents:
+        - commandStartedEvent
+        - commandSucceededEvent
+        - commandFailedEvent
+      uriOptions:
+        w: 0
+  - database:
+      id: &database database
+      client: *client
+      databaseName: &databaseName command-monitoring-tests
+  - collection:
+      id: &collection collection
+      database: *database
+      collectionName: &collectionName test
+
+initialData:
+  - collectionName: *collectionName
+    databaseName: *databaseName
+    documents:
+      - { _id: 1, x: 11 }
+      - { _id: 2, x: 22 }
+      - { _id: 3, x: 33 }
+
+_yamlAnchors:
+  namespace: &namespace "command-monitoring-tests.test"
+
+tests:
+  - description: 'A successful mixed client bulkWrite'
+    operations:
+      - object: *client
+        name: clientBulkWrite
+        arguments:
+          models:
+            - insertOne:
+                namespace: *namespace
+                document: { _id: 4, x: 44 }
+            - updateOne:
+                namespace: *namespace
+                filter: { _id: 3 }
+                update: { $set: { x: 333 } }
+        expectResult:
+          insertedCount:
+            $$unsetOrMatches: 0
+          upsertedCount:
+            $$unsetOrMatches: 0
+          matchedCount:
+            $$unsetOrMatches: 0
+          modifiedCount:
+            $$unsetOrMatches: 0
+          deletedCount:
+            $$unsetOrMatches: 0
+          insertResults:
+            $$unsetOrMatches: {}
+          updateResults:
+            $$unsetOrMatches: {}
+          deleteResults:
+            $$unsetOrMatches: {}
+      # Force completion of the w:0 write by executing a find on the same connection
+      - object: *collection
+        name: find
+        arguments:
+          filter: {}
+        expectResult:
+          - { _id: 1, x: 11 }
+          - { _id: 2, x: 22 }
+          - { _id: 3, x: 333 }
+          - { _id: 4, x: 44 }
+
+    expectEvents:
+      -
+        client: *client
+        ignoreExtraEvents: true
+        events:
+          - commandStartedEvent:
+              commandName: bulkWrite
+              databaseName: admin
+              command:
+                bulkWrite: 1
+                errorsOnly: true
+                ordered: true
+                ops:
+                  - insert: 0
+                    document: { _id: 4, x: 44 }
+                  - update: 0
+                    filter: { _id: 3 }
+                    updateMods: { $set: { x: 333 } }
+                    multi: false
+                nsInfo:
+                  - ns: *namespace
+          - commandSucceededEvent:
+              commandName: bulkWrite
+              reply:
+                ok: 1
+                nInserted: { $$exists: false }
+                nMatched: { $$exists: false }
+                nModified: { $$exists: false }
+                nUpserted: { $$exists: false }
+                nDeleted: { $$exists: false }
diff --git a/test/spec/server-selection/logging/operation-id.json b/test/spec/server-selection/logging/operation-id.json
index 276e4b8d6d..6cdbcb3f5a 100644
--- a/test/spec/server-selection/logging/operation-id.json
+++ b/test/spec/server-selection/logging/operation-id.json
@@ -47,6 +47,9 @@
       }
     }
   ],
+  "_yamlAnchors": {
+    "namespace": "logging-tests.server-selection"
+  },
   "tests": [
     {
       "description": "Successful bulkWrite operation: log messages have operationIds",
@@ -224,6 +227,190 @@
           ]
         }
       ]
+    },
+    {
+      "description": "Successful client bulkWrite operation: log messages have operationIds",
+      "runOnRequirements": [
+        {
+          "minServerVersion": "8.0"
+        }
+      ],
+      "operations": [
+        {
+          "name": "waitForEvent",
+          "object": "testRunner",
+          "arguments": {
+            "client": "client",
+            "event": {
+              "topologyDescriptionChangedEvent": {}
+            },
+            "count": 2
+          }
+        },
+        {
+          "name": "clientBulkWrite",
+          "object": "client",
+          "arguments": {
+            "models": [
+              {
+                "insertOne": {
+                  "namespace": "logging-tests.server-selection",
+                  "document": {
+                    "x": 1
+                  }
+                }
+              }
+            ]
+          }
+        }
+      ],
+      "expectLogMessages": [
+        {
+          "client": "client",
+          "messages": [
+            {
+              "level": "debug",
+              "component": "serverSelection",
+              "data": {
+                "message": "Server selection started",
+                "operationId": {
+                  "$$type": [
+                    "int",
+                    "long"
+                  ]
+                },
+                "operation": "bulkWrite"
+              }
+            },
+            {
+              "level": "debug",
+              "component": "serverSelection",
+              "data": {
+                "message": "Server selection succeeded",
+                "operationId": {
+                  "$$type": [
+                    "int",
+                    "long"
+                  ]
+                },
+                "operation": "bulkWrite"
+              }
+            }
+          ]
+        }
+      ]
+    },
+    {
+      "description": "Failed client bulkWrite operation: log messages have operationIds",
+      "runOnRequirements": [
+        {
+          "minServerVersion": "8.0"
+        }
+      ],
+      "operations": [
+        {
+          "name": "failPoint",
+          "object": "testRunner",
+          "arguments": {
+            "client": "failPointClient",
+            "failPoint": {
+              "configureFailPoint": "failCommand",
+              "mode": "alwaysOn",
+              "data": {
+                "failCommands": [
+                  "hello",
+                  "ismaster"
+                ],
+                "appName": "loggingClient",
+                "closeConnection": true
+              }
+            }
+          }
+        },
+        {
+          "name": "waitForEvent",
+          "object": "testRunner",
+          "arguments": {
+            "client": "client",
+            "event": {
+              "serverDescriptionChangedEvent": {
+                "newDescription": {
+                  "type": "Unknown"
+                }
+              }
+            },
+            "count": 1
+          }
+        },
+        {
+          "name": "bulkWrite",
+          "object": "client",
+          "arguments": {
+            "models": [
+              {
+                "insertOne": {
+                  "namespace": "logging-tests.server-selection",
+                  "document": {
+                    "x": 1
+                  }
+                }
+              }
+            ]
+          },
+          "expectError": {
+            "isClientError": true
+          }
+        }
+      ],
+      "expectLogMessages": [
+        {
+          "client": "client",
+          "messages": [
+            {
+              "level": "debug",
+              "component": "serverSelection",
+              "data": {
+                "message": "Server selection started",
+                "operationId": {
+                  "$$type": [
+                    "int",
+                    "long"
+                  ]
+                },
+                "operation": "bulkWrite"
+              }
+            },
+            {
+              "level": "info",
+              "component": "serverSelection",
+              "data": {
+                "message": "Waiting for suitable server to become available",
+                "operationId": {
+                  "$$type": [
+                    "int",
+                    "long"
+                  ]
+                },
+                "operation": "bulkWrite"
+              }
+            },
+            {
+              "level": "debug",
+              "component": "serverSelection",
+              "data": {
+                "message": "Server selection failed",
+                "operationId": {
+                  "$$type": [
+                    "int",
+                    "long"
+                  ]
+                },
+                "operation": "bulkWrite"
+              }
+            }
+          ]
+        }
+      ]
     }
   ]
 }
diff --git a/test/spec/server-selection/logging/operation-id.yml b/test/spec/server-selection/logging/operation-id.yml
index 430e81a58b..24e48f9410 100644
--- a/test/spec/server-selection/logging/operation-id.yml
+++ b/test/spec/server-selection/logging/operation-id.yml
@@ -30,6 +30,9 @@ createEntities:
   - client:
       id: &failPointClient failPointClient
 
+_yamlAnchors:
+  namespace: &namespace "logging-tests.server-selection"
+
 tests:
   - description: "Successful bulkWrite operation: log messages have operationIds"
     operations:
@@ -122,3 +125,97 @@ tests:
               operationId: { $$type: [int, long] }
               operation: insert
 
+  - description: "Successful client bulkWrite operation: log messages have operationIds"
+    runOnRequirements:
+      - minServerVersion: "8.0" # required for bulkWrite command
+    operations:
+      # ensure we've discovered the server so it is immediately available
+      # and no extra "waiting for suitable server" messages are emitted.
+      # expected topology events reflect initial server discovery and server connect event.
+      - name: waitForEvent
+        object: testRunner
+        arguments:
+          client: *client
+          event:
+            topologyDescriptionChangedEvent: {}
+          count: 2
+      - name: clientBulkWrite
+        object: *client
+        arguments:
+          models:
+            - insertOne:
+                namespace: *namespace
+                document: { x: 1 }
+    expectLogMessages:
+      - client: *client
+        messages:
+          - level: debug
+            component: serverSelection
+            data:
+              message: "Server selection started"
+              operationId: { $$type: [int, long] }
+              operation: bulkWrite
+          - level: debug
+            component: serverSelection
+            data:
+              message: "Server selection succeeded"
+              operationId: { $$type: [int, long] }
+              operation: bulkWrite
+
+  - description: "Failed client bulkWrite operation: log messages have operationIds"
+    runOnRequirements:
+      - minServerVersion: "8.0" # required for bulkWrite command
+    operations:
+      # fail all hello/legacy hello commands for the main client.
+      - name: failPoint
+        object: testRunner
+        arguments:
+          client: *failPointClient
+          failPoint:
+            configureFailPoint: failCommand
+            mode: alwaysOn
+            data:
+              failCommands: ["hello", "ismaster"]
+              appName: *appName
+              closeConnection: true
+      # wait until we've marked the server unknown due
+      # to a failed heartbeat.
+      - name: waitForEvent
+        object: testRunner
+        arguments:
+          client: *client
+          event:
+            serverDescriptionChangedEvent:
+              newDescription:
+                type: Unknown
+          count: 1
+      - name: bulkWrite
+        object: *client
+        arguments:
+          models:
+            - insertOne:
+                namespace: *namespace
+                document: { x: 1 }
+        expectError:
+          isClientError: true # server selection timeout
+    expectLogMessages:
+      - client: *client
+        messages:
+          - level: debug
+            component: serverSelection
+            data:
+              message: "Server selection started"
+              operationId: { $$type: [int, long] }
+              operation: bulkWrite
+          - level: info
+            component: serverSelection
+            data:
+              message: "Waiting for suitable server to become available"
+              operationId: { $$type: [int, long] }
+              operation: bulkWrite
+          - level: debug
+            component: serverSelection
+            data:
+              message: "Server selection failed"
+              operationId: { $$type: [int, long] }
+              operation: bulkWrite
diff --git a/test/spec/transactions/unified/client-bulkWrite.json b/test/spec/transactions/unified/client-bulkWrite.json
new file mode 100644
index 0000000000..f8f1d97169
--- /dev/null
+++ b/test/spec/transactions/unified/client-bulkWrite.json
@@ -0,0 +1,592 @@
+{
+  "description": "client bulkWrite transactions",
+  "schemaVersion": "1.3",
+  "runOnRequirements": [
+    {
+      "minServerVersion": "8.0",
+      "topologies": [
+        "replicaset",
+        "sharded",
+        "load-balanced"
+      ]
+    }
+  ],
+  "createEntities": [
+    {
+      "client": {
+        "id": "client0",
+        "observeEvents": [
+          "commandStartedEvent"
+        ]
+      }
+    },
+    {
+      "database": {
+        "id": "database0",
+        "client": "client0",
+        "databaseName": "transaction-tests"
+      }
+    },
+    {
+      "collection": {
+        "id": "collection0",
+        "database": "database0",
+        "collectionName": "coll0"
+      }
+    },
+    {
+      "session": {
+        "id": "session0",
+        "client": "client0"
+      }
+    },
+    {
+      "client": {
+        "id": "client_with_wmajority",
+        "uriOptions": {
+          "w": "majority"
+        },
+        "observeEvents": [
+          "commandStartedEvent"
+        ]
+      }
+    },
+    {
+      "session": {
+        "id": "session_with_wmajority",
+        "client": "client_with_wmajority"
+      }
+    }
+  ],
+  "_yamlAnchors": {
+    "namespace": "transaction-tests.coll0"
+  },
+  "initialData": [
+    {
+      "databaseName": "transaction-tests",
+      "collectionName": "coll0",
+      "documents": [
+        {
+          "_id": 1,
+          "x": 11
+        },
+        {
+          "_id": 2,
+          "x": 22
+        },
+        {
+          "_id": 3,
+          "x": 33
+        },
+        {
+          "_id": 5,
+          "x": 55
+        },
+        {
+          "_id": 6,
+          "x": 66
+        },
+        {
+          "_id": 7,
+          "x": 77
+        }
+      ]
+    }
+  ],
+  "tests": [
+    {
+      "description": "client bulkWrite in a transaction",
+      "operations": [
+        {
+          "object": "session0",
+          "name": "startTransaction"
+        },
+        {
+          "object": "client0",
+          "name": "clientBulkWrite",
+          "arguments": {
+            "session": "session0",
+            "models": [
+              {
+                "insertOne": {
+                  "namespace": "transaction-tests.coll0",
+                  "document": {
+                    "_id": 8,
+                    "x": 88
+                  }
+                }
+              },
+              {
+                "updateOne": {
+                  "namespace": "transaction-tests.coll0",
+                  "filter": {
+                    "_id": 1
+                  },
+                  "update": {
+                    "$inc": {
+                      "x": 1
+                    }
+                  }
+                }
+              },
+              {
+                "updateMany": {
+                  "namespace": "transaction-tests.coll0",
+                  "filter": {
+                    "$and": [
+                      {
+                        "_id": {
+                          "$gt": 1
+                        }
+                      },
+                      {
+                        "_id": {
+                          "$lte": 3
+                        }
+                      }
+                    ]
+                  },
+                  "update": {
+                    "$inc": {
+                      "x": 2
+                    }
+                  }
+                }
+              },
+              {
+                "replaceOne": {
+                  "namespace": "transaction-tests.coll0",
+                  "filter": {
+                    "_id": 4
+                  },
+                  "replacement": {
+                    "x": 44
+                  },
+                  "upsert": true
+                }
+              },
+              {
+                "deleteOne": {
+                  "namespace": "transaction-tests.coll0",
+                  "filter": {
+                    "_id": 5
+                  }
+                }
+              },
+              {
+                "deleteMany": {
+                  "namespace": "transaction-tests.coll0",
+                  "filter": {
+                    "$and": [
+                      {
+                        "_id": {
+                          "$gt": 5
+                        }
+                      },
+                      {
+                        "_id": {
+                          "$lte": 7
+                        }
+                      }
+                    ]
+                  }
+                }
+              }
+            ],
+            "verboseResults": true
+          },
+          "expectResult": {
+            "insertedCount": 1,
+            "upsertedCount": 1,
+            "matchedCount": 3,
+            "modifiedCount": 3,
+            "deletedCount": 3,
+            "insertResults": {
+              "0": {
+                "insertedId": 8
+              }
+            },
+            "updateResults": {
+              "1": {
+                "matchedCount": 1,
+                "modifiedCount": 1,
+                "upsertedId": {
+                  "$$exists": false
+                }
+              },
+              "2": {
+                "matchedCount": 2,
+                "modifiedCount": 2,
+                "upsertedId": {
+                  "$$exists": false
+                }
+              },
+              "3": {
+                "matchedCount": 1,
+                "modifiedCount": 0,
+                "upsertedId": 4
+              }
+            },
+            "deleteResults": {
+              "4": {
+                "deletedCount": 1
+              },
+              "5": {
+                "deletedCount": 2
+              }
+            }
+          }
+        },
+        {
+          "object": "session0",
+          "name": "commitTransaction"
+        }
+      ],
+      "expectEvents": [
+        {
+          "client": "client0",
+          "events": [
+            {
+              "commandStartedEvent": {
+                "commandName": "bulkWrite",
+                "databaseName": "admin",
+                "command": {
+                  "lsid": {
+                    "$$sessionLsid": "session0"
+                  },
+                  "txnNumber": 1,
+                  "startTransaction": true,
+                  "autocommit": false,
+                  "writeConcern": {
+                    "$$exists": false
+                  },
+                  "bulkWrite": 1,
+                  "errorsOnly": false,
+                  "ordered": true,
+                  "ops": [
+                    {
+                      "insert": 0,
+                      "document": {
+                        "_id": 8,
+                        "x": 88
+                      }
+                    },
+                    {
+                      "update": 0,
+                      "filter": {
+                        "_id": 1
+                      },
+                      "updateMods": {
+                        "$inc": {
+                          "x": 1
+                        }
+                      },
+                      "multi": false
+                    },
+                    {
+                      "update": 0,
+                      "filter": {
+                        "$and": [
+                          {
+                            "_id": {
+                              "$gt": 1
+                            }
+                          },
+                          {
+                            "_id": {
+                              "$lte": 3
+                            }
+                          }
+                        ]
+                      },
+                      "updateMods": {
+                        "$inc": {
+                          "x": 2
+                        }
+                      },
+                      "multi": true
+                    },
+                    {
+                      "update": 0,
+                      "filter": {
+                        "_id": 4
+                      },
+                      "updateMods": {
+                        "x": 44
+                      },
+                      "upsert": true,
+                      "multi": false
+                    },
+                    {
+                      "delete": 0,
+                      "filter": {
+                        "_id": 5
+                      },
+                      "multi": false
+                    },
+                    {
+                      "delete": 0,
+                      "filter": {
+                        "$and": [
+                          {
+                            "_id": {
+                              "$gt": 5
+                            }
+                          },
+                          {
+                            "_id": {
+                              "$lte": 7
+                            }
+                          }
+                        ]
+                      },
+                      "multi": true
+                    }
+                  ],
+                  "nsInfo": [
+                    {
+                      "ns": "transaction-tests.coll0"
+                    }
+                  ]
+                }
+              }
+            },
+            {
+              "commandStartedEvent": {
+                "commandName": "commitTransaction",
+                "databaseName": "admin",
+                "command": {
+                  "commitTransaction": 1,
+                  "lsid": {
+                    "$$sessionLsid": "session0"
+                  },
+                  "txnNumber": 1,
+                  "startTransaction": {
+                    "$$exists": false
+                  },
+                  "autocommit": false,
+                  "writeConcern": {
+                    "$$exists": false
+                  }
+                }
+              }
+            }
+          ]
+        }
+      ],
+      "outcome": [
+        {
+          "collectionName": "coll0",
+          "databaseName": "transaction-tests",
+          "documents": [
+            {
+              "_id": 1,
+              "x": 12
+            },
+            {
+              "_id": 2,
+              "x": 24
+            },
+            {
+              "_id": 3,
+              "x": 35
+            },
+            {
+              "_id": 4,
+              "x": 44
+            },
+            {
+              "_id": 8,
+              "x": 88
+            }
+          ]
+        }
+      ]
+    },
+    {
+      "description": "client writeConcern ignored for client bulkWrite in transaction",
+      "operations": [
+        {
+          "object": "session_with_wmajority",
+          "name": "startTransaction",
+          "arguments": {
+            "writeConcern": {
+              "w": 1
+            }
+          }
+        },
+        {
+          "object": "client_with_wmajority",
+          "name": "clientBulkWrite",
+          "arguments": {
+            "session": "session_with_wmajority",
+            "models": [
+              {
+                "insertOne": {
+                  "namespace": "transaction-tests.coll0",
+                  "document": {
+                    "_id": 8,
+                    "x": 88
+                  }
+                }
+              }
+            ]
+          },
+          "expectResult": {
+            "insertedCount": 1,
+            "upsertedCount": 0,
+            "matchedCount": 0,
+            "modifiedCount": 0,
+            "deletedCount": 0,
+            "insertResults": {
+              "$$unsetOrMatches": {}
+            },
+            "updateResults": {
+              "$$unsetOrMatches": {}
+            },
+            "deleteResults": {
+              "$$unsetOrMatches": {}
+            }
+          }
+        },
+        {
+          "object": "session_with_wmajority",
+          "name": "commitTransaction"
+        }
+      ],
+      "expectEvents": [
+        {
+          "client": "client_with_wmajority",
+          "events": [
+            {
+              "commandStartedEvent": {
+                "commandName": "bulkWrite",
+                "databaseName": "admin",
+                "command": {
+                  "lsid": {
+                    "$$sessionLsid": "session_with_wmajority"
+                  },
+                  "txnNumber": 1,
+                  "startTransaction": true,
+                  "autocommit": false,
+                  "writeConcern": {
+                    "$$exists": false
+                  },
+                  "bulkWrite": 1,
+                  "errorsOnly": true,
+                  "ordered": true,
+                  "ops": [
+                    {
+                      "insert": 0,
+                      "document": {
+                        "_id": 8,
+                        "x": 88
+                      }
+                    }
+                  ],
+                  "nsInfo": [
+                    {
+                      "ns": "transaction-tests.coll0"
+                    }
+                  ]
+                }
+              }
+            },
+            {
+              "commandStartedEvent": {
+                "command": {
+                  "commitTransaction": 1,
+                  "lsid": {
+                    "$$sessionLsid": "session_with_wmajority"
+                  },
+                  "txnNumber": {
+                    "$numberLong": "1"
+                  },
+                  "startTransaction": {
+                    "$$exists": false
+                  },
+                  "autocommit": false,
+                  "writeConcern": {
+                    "w": 1
+                  }
+                },
+                "commandName": "commitTransaction",
+                "databaseName": "admin"
+              }
+            }
+          ]
+        }
+      ],
+      "outcome": [
+        {
+          "collectionName": "coll0",
+          "databaseName": "transaction-tests",
+          "documents": [
+            {
+              "_id": 1,
+              "x": 11
+            },
+            {
+              "_id": 2,
+              "x": 22
+            },
+            {
+              "_id": 3,
+              "x": 33
+            },
+            {
+              "_id": 5,
+              "x": 55
+            },
+            {
+              "_id": 6,
+              "x": 66
+            },
+            {
+              "_id": 7,
+              "x": 77
+            },
+            {
+              "_id": 8,
+              "x": 88
+            }
+          ]
+        }
+      ]
+    },
+    {
+      "description": "client bulkWrite with writeConcern in a transaction causes a transaction error",
+      "operations": [
+        {
+          "object": "session0",
+          "name": "startTransaction"
+        },
+        {
+          "object": "client0",
+          "name": "clientBulkWrite",
+          "arguments": {
+            "session": "session0",
+            "writeConcern": {
+              "w": 1
+            },
+            "models": [
+              {
+                "insertOne": {
+                  "namespace": "transaction-tests.coll0",
+                  "document": {
+                    "_id": 8,
+                    "x": 88
+                  }
+                }
+              }
+            ]
+          },
+          "expectError": {
+            "isClientError": true,
+            "errorContains": "Cannot set write concern after starting a transaction"
+          }
+        }
+      ]
+    }
+  ]
+}
diff --git a/test/spec/transactions/unified/client-bulkWrite.yml b/test/spec/transactions/unified/client-bulkWrite.yml
new file mode 100644
index 0000000000..eda2babbe7
--- /dev/null
+++ b/test/spec/transactions/unified/client-bulkWrite.yml
@@ -0,0 +1,262 @@
+description: "client bulkWrite transactions"
+schemaVersion: "1.3"
+runOnRequirements:
+  - minServerVersion: "8.0"
+    topologies:
+      - replicaset
+      - sharded
+      - load-balanced
+
+createEntities:
+  - client:
+      id: &client0 client0
+      observeEvents: [ commandStartedEvent ]
+  - database:
+      id: &database0 database0
+      client: *client0
+      databaseName: &database0Name transaction-tests
+  - collection:
+      id: &collection0 collection0
+      database: *database0
+      collectionName: &collection0Name coll0
+  - session:
+      id: &session0 session0
+      client: *client0
+  - client:
+      id: &client_with_wmajority client_with_wmajority
+      uriOptions:
+        w: majority
+      observeEvents:
+        - commandStartedEvent
+  - session:
+      id: &session_with_wmajority session_with_wmajority
+      client: *client_with_wmajority
+
+_yamlAnchors:
+  namespace: &namespace "transaction-tests.coll0"
+
+initialData:
+  - databaseName: *database0Name
+    collectionName: *collection0Name
+    documents:
+      - { _id: 1, x: 11 }
+      - { _id: 2, x: 22 }
+      - { _id: 3, x: 33 }
+      - { _id: 5, x: 55 }
+      - { _id: 6, x: 66 }
+      - { _id: 7, x: 77 }
+
+tests:
+  - description: "client bulkWrite in a transaction"
+    operations:
+      - object: *session0
+        name: startTransaction
+      - object: *client0
+        name: clientBulkWrite
+        arguments:
+          session: *session0
+          models:
+            - insertOne:
+                namespace: *namespace
+                document: { _id: 8, x: 88 }
+            - updateOne:
+                namespace: *namespace
+                filter: { _id: 1 }
+                update: { $inc: { x: 1 } }
+            - updateMany:
+                namespace: *namespace
+                filter:
+                  $and: [ { _id: { $gt: 1 } }, { _id: { $lte: 3 } } ]
+                update: { $inc: { x: 2 } }
+            - replaceOne:
+                namespace: *namespace
+                filter: { _id: 4 }
+                replacement: { x: 44 }
+                upsert: true
+            - deleteOne:
+                namespace: *namespace
+                filter: { _id: 5 }
+            - deleteMany:
+                namespace: *namespace
+                filter:
+                  $and: [ { _id: { $gt: 5 } }, { _id: { $lte: 7 } } ]
+          verboseResults: true
+        expectResult:
+          insertedCount: 1
+          upsertedCount: 1
+          matchedCount: 3
+          modifiedCount: 3
+          deletedCount: 3
+          insertResults:
+            0:
+              insertedId: 8
+          updateResults:
+            1:
+              matchedCount: 1
+              modifiedCount: 1
+              upsertedId: { $$exists: false }
+            2:
+              matchedCount: 2
+              modifiedCount: 2
+              upsertedId: { $$exists: false }
+            3:
+              matchedCount: 1
+              modifiedCount: 0
+              upsertedId: 4
+          deleteResults:
+            4:
+              deletedCount: 1
+            5:
+              deletedCount: 2
+      - object: *session0
+        name: commitTransaction
+    expectEvents:
+      - client: *client0
+        events:
+          - commandStartedEvent:
+              commandName: bulkWrite
+              databaseName: admin
+              command:
+                lsid: { $$sessionLsid: *session0 }
+                txnNumber: 1
+                startTransaction: true
+                autocommit: false
+                writeConcern: { $$exists: false }
+                bulkWrite: 1
+                errorsOnly: false
+                ordered: true
+                ops:
+                  - insert: 0
+                    document: { _id: 8, x: 88 }
+                  - update: 0
+                    filter: { _id: 1 }
+                    updateMods: { $inc: { x: 1 } }
+                    multi: false
+                  - update: 0
+                    filter:
+                      $and: [ { _id: { $gt: 1 } }, { _id: { $lte: 3 } } ]
+                    updateMods: { $inc: { x: 2 } }
+                    multi: true
+                  - update: 0
+                    filter: { _id: 4 }
+                    updateMods: { x: 44 }
+                    upsert: true
+                    multi: false
+                  - delete: 0
+                    filter: { _id: 5 }
+                    multi: false
+                  - delete: 0
+                    filter:
+                      $and: [ { _id: { $gt: 5 } }, { _id: { $lte: 7 } } ]
+                    multi: true
+                nsInfo:
+                  - ns: *namespace
+          - commandStartedEvent:
+              commandName: commitTransaction
+              databaseName: admin
+              command:
+                commitTransaction: 1
+                lsid: { $$sessionLsid: *session0 }
+                txnNumber: 1
+                startTransaction: { $$exists: false }
+                autocommit: false
+                writeConcern: { $$exists: false }
+    outcome:
+      - collectionName: *collection0Name
+        databaseName: *database0Name
+        documents:
+          - { _id: 1, x: 12 }
+          - { _id: 2, x: 24 }
+          - { _id: 3, x: 35 }
+          - { _id: 4, x: 44 }
+          - { _id: 8, x: 88 }
+  - description: 'client writeConcern ignored for client bulkWrite in transaction'
+    operations:
+      - object: *session_with_wmajority
+        name: startTransaction
+        arguments:
+          writeConcern:
+            w: 1
+      - object: *client_with_wmajority
+        name: clientBulkWrite
+        arguments:
+          session: *session_with_wmajority
+          models:
+            - insertOne:
+                namespace: *namespace
+                document: { _id: 8, x: 88 }
+        expectResult:
+          insertedCount: 1
+          upsertedCount: 0
+          matchedCount: 0
+          modifiedCount: 0
+          deletedCount: 0
+          insertResults:
+            $$unsetOrMatches: {}
+          updateResults:
+            $$unsetOrMatches: {}
+          deleteResults:
+            $$unsetOrMatches: {}
+      - object: *session_with_wmajority
+        name: commitTransaction
+    expectEvents:
+      -
+        client: *client_with_wmajority
+        events:
+          - commandStartedEvent:
+              commandName: bulkWrite
+              databaseName: admin
+              command:
+                lsid: { $$sessionLsid: *session_with_wmajority }
+                txnNumber: 1
+                startTransaction: true
+                autocommit: false
+                writeConcern: { $$exists: false }
+                bulkWrite: 1
+                errorsOnly: true
+                ordered: true
+                ops:
+                  - insert: 0
+                    document: { _id: 8, x: 88 }
+                nsInfo:
+                  - ns: *namespace
+          -
+            commandStartedEvent:
+              command:
+                commitTransaction: 1
+                lsid: { $$sessionLsid: *session_with_wmajority }
+                txnNumber: { $numberLong: '1' }
+                startTransaction: { $$exists: false }
+                autocommit: false
+                writeConcern:
+                  w: 1
+              commandName: commitTransaction
+              databaseName: admin
+    outcome:
+      - collectionName: *collection0Name
+        databaseName: *database0Name
+        documents:
+          - { _id: 1, x: 11 }
+          - { _id: 2, x: 22 }
+          - { _id: 3, x: 33 }
+          - { _id: 5, x: 55 }
+          - { _id: 6, x: 66 }
+          - { _id: 7, x: 77 }
+          - { _id: 8, x: 88 }
+  - description: "client bulkWrite with writeConcern in a transaction causes a transaction error"
+    operations:
+      - object: *session0
+        name: startTransaction
+      - object: *client0
+        name: clientBulkWrite
+        arguments:
+          session: *session0
+          writeConcern:
+            w: 1
+          models:
+            - insertOne:
+                namespace: *namespace
+                document: { _id: 8, x: 88 }
+        expectError:
+          isClientError: true
+          errorContains: "Cannot set write concern after starting a transaction"
diff --git a/test/spec/transactions/unified/mongos-pin-auto.json b/test/spec/transactions/unified/mongos-pin-auto.json
index 93eac8bb77..27db520401 100644
--- a/test/spec/transactions/unified/mongos-pin-auto.json
+++ b/test/spec/transactions/unified/mongos-pin-auto.json
@@ -2004,6 +2004,104 @@
         }
       ]
     },
+    {
+      "description": "remain pinned after non-transient Interrupted error on clientBulkWrite bulkWrite",
+      "operations": [
+        {
+          "object": "session0",
+          "name": "startTransaction"
+        },
+        {
+          "object": "collection0",
+          "name": "insertOne",
+          "arguments": {
+            "session": "session0",
+            "document": {
+              "_id": 3
+            }
+          },
+          "expectResult": {
+            "$$unsetOrMatches": {
+              "insertedId": {
+                "$$unsetOrMatches": 3
+              }
+            }
+          }
+        },
+        {
+          "name": "targetedFailPoint",
+          "object": "testRunner",
+          "arguments": {
+            "session": "session0",
+            "failPoint": {
+              "configureFailPoint": "failCommand",
+              "mode": {
+                "times": 1
+              },
+              "data": {
+                "failCommands": [
+                  "bulkWrite"
+                ],
+                "errorCode": 11601
+              }
+            }
+          }
+        },
+        {
+          "name": "clientBulkWrite",
+          "object": "client0",
+          "arguments": {
+            "session": "session0",
+            "models": [
+              {
+                "insertOne": {
+                  "namespace": "database0.collection0",
+                  "document": {
+                    "_id": 8,
+                    "x": 88
+                  }
+                }
+              }
+            ]
+          },
+          "expectError": {
+            "errorLabelsOmit": [
+              "TransientTransactionError"
+            ]
+          }
+        },
+        {
+          "object": "testRunner",
+          "name": "assertSessionPinned",
+          "arguments": {
+            "session": "session0"
+          }
+        },
+        {
+          "object": "session0",
+          "name": "abortTransaction"
+        }
+      ],
+      "outcome": [
+        {
+          "collectionName": "test",
+          "databaseName": "transaction-tests",
+          "documents": [
+            {
+              "_id": 1
+            },
+            {
+              "_id": 2
+            }
+          ]
+        }
+      ],
+      "runOnRequirements": [
+        {
+          "minServerVersion": "8.0"
+        }
+      ]
+    },
     {
       "description": "unpin after transient connection error on insertOne insert",
       "operations": [
@@ -5175,6 +5273,202 @@
           ]
         }
       ]
+    },
+    {
+      "description": "unpin after transient connection error on clientBulkWrite bulkWrite",
+      "operations": [
+        {
+          "object": "session0",
+          "name": "startTransaction"
+        },
+        {
+          "object": "collection0",
+          "name": "insertOne",
+          "arguments": {
+            "session": "session0",
+            "document": {
+              "_id": 3
+            }
+          },
+          "expectResult": {
+            "$$unsetOrMatches": {
+              "insertedId": {
+                "$$unsetOrMatches": 3
+              }
+            }
+          }
+        },
+        {
+          "name": "targetedFailPoint",
+          "object": "testRunner",
+          "arguments": {
+            "session": "session0",
+            "failPoint": {
+              "configureFailPoint": "failCommand",
+              "mode": {
+                "times": 1
+              },
+              "data": {
+                "failCommands": [
+                  "bulkWrite"
+                ],
+                "closeConnection": true
+              }
+            }
+          }
+        },
+        {
+          "name": "clientBulkWrite",
+          "object": "client0",
+          "arguments": {
+            "session": "session0",
+            "models": [
+              {
+                "insertOne": {
+                  "namespace": "database0.collection0",
+                  "document": {
+                    "_id": 8,
+                    "x": 88
+                  }
+                }
+              }
+            ]
+          },
+          "expectError": {
+            "errorLabelsContain": [
+              "TransientTransactionError"
+            ]
+          }
+        },
+        {
+          "object": "testRunner",
+          "name": "assertSessionUnpinned",
+          "arguments": {
+            "session": "session0"
+          }
+        },
+        {
+          "object": "session0",
+          "name": "abortTransaction"
+        }
+      ],
+      "outcome": [
+        {
+          "collectionName": "test",
+          "databaseName": "transaction-tests",
+          "documents": [
+            {
+              "_id": 1
+            },
+            {
+              "_id": 2
+            }
+          ]
+        }
+      ],
+      "runOnRequirements": [
+        {
+          "minServerVersion": "8.0"
+        }
+      ]
+    },
+    {
+      "description": "unpin after transient ShutdownInProgress error on clientBulkWrite bulkWrite",
+      "operations": [
+        {
+          "object": "session0",
+          "name": "startTransaction"
+        },
+        {
+          "object": "collection0",
+          "name": "insertOne",
+          "arguments": {
+            "session": "session0",
+            "document": {
+              "_id": 3
+            }
+          },
+          "expectResult": {
+            "$$unsetOrMatches": {
+              "insertedId": {
+                "$$unsetOrMatches": 3
+              }
+            }
+          }
+        },
+        {
+          "name": "targetedFailPoint",
+          "object": "testRunner",
+          "arguments": {
+            "session": "session0",
+            "failPoint": {
+              "configureFailPoint": "failCommand",
+              "mode": {
+                "times": 1
+              },
+              "data": {
+                "failCommands": [
+                  "bulkWrite"
+                ],
+                "errorCode": 91
+              }
+            }
+          }
+        },
+        {
+          "name": "clientBulkWrite",
+          "object": "client0",
+          "arguments": {
+            "session": "session0",
+            "models": [
+              {
+                "insertOne": {
+                  "namespace": "database0.collection0",
+                  "document": {
+                    "_id": 8,
+                    "x": 88
+                  }
+                }
+              }
+            ]
+          },
+          "expectError": {
+            "errorLabelsContain": [
+              "TransientTransactionError"
+            ]
+          }
+        },
+        {
+          "object": "testRunner",
+          "name": "assertSessionUnpinned",
+          "arguments": {
+            "session": "session0"
+          }
+        },
+        {
+          "object": "session0",
+          "name": "abortTransaction"
+        }
+      ],
+      "outcome": [
+        {
+          "collectionName": "test",
+          "databaseName": "transaction-tests",
+          "documents": [
+            {
+              "_id": 1
+            },
+            {
+              "_id": 2
+            }
+          ]
+        }
+      ],
+      "runOnRequirements": [
+        {
+          "minServerVersion": "8.0"
+        }
+      ]
     }
   ]
 }
diff --git a/test/spec/transactions/unified/mongos-pin-auto.yml b/test/spec/transactions/unified/mongos-pin-auto.yml
index 7a76347555..a80dd62031 100644
--- a/test/spec/transactions/unified/mongos-pin-auto.yml
+++ b/test/spec/transactions/unified/mongos-pin-auto.yml
@@ -676,6 +676,36 @@ tests:
       - *abortTransaction
     outcome: *outcome
 
+  - description: remain pinned after non-transient Interrupted error on clientBulkWrite bulkWrite
+    operations:
+      - *startTransaction
+      - *initialCommand
+      - name: targetedFailPoint
+        object: testRunner
+        arguments:
+          session: *session0
+          failPoint:
+            configureFailPoint: failCommand
+            mode: {times: 1}
+            data:
+              failCommands: ["bulkWrite"]
+              errorCode: 11601
+      - name: clientBulkWrite
+        object: *client0
+        arguments:
+          session: *session0
+          models:
+          - insertOne:
+              namespace: database0.collection0
+              document: { _id: 8, x: 88 }
+        expectError:
+          errorLabelsOmit: ["TransientTransactionError"]
+      - *assertSessionPinned
+      - *abortTransaction
+    outcome: *outcome
+    runOnRequirements:
+      - minServerVersion: "8.0" # `bulkWrite` added to server 8.0"
+
   - description: unpin after transient connection error on insertOne insert
     operations:
       - *startTransaction
@@ -1614,3 +1644,63 @@ tests:
       - *abortTransaction
     outcome: *outcome
 
+  - description: unpin after transient connection error on clientBulkWrite bulkWrite
+    operations:
+      - *startTransaction
+      - *initialCommand
+      - name: targetedFailPoint
+        object: testRunner
+        arguments:
+          session: *session0
+          failPoint:
+            configureFailPoint: failCommand
+            mode: {times: 1}
+            data:
+              failCommands: ["bulkWrite"]
+              closeConnection: true
+      - name: clientBulkWrite
+        object: *client0
+        arguments:
+          session: *session0
+          models:
+          - insertOne:
+              namespace: database0.collection0
+              document: { _id: 8, x: 88 }
+        expectError:
+          errorLabelsContain: ["TransientTransactionError"]
+      - *assertSessionUnpinned
+      - *abortTransaction
+    outcome: *outcome
+    runOnRequirements:
+      - minServerVersion: "8.0" # `bulkWrite` added to server 8.0"
+
+  - description: unpin after transient ShutdownInProgress error on clientBulkWrite bulkWrite
+    operations:
+      - *startTransaction
+      - *initialCommand
+      - name: targetedFailPoint
+        object: testRunner
+        arguments:
+          session: *session0
+          failPoint:
+            configureFailPoint: failCommand
+            mode: {times: 1}
+            data:
+              failCommands: ["bulkWrite"]
+              errorCode: 91
+      - name: clientBulkWrite
+        object: *client0
+        arguments:
+          session: *session0
+          models:
+          - insertOne:
+              namespace: database0.collection0
+              document: { _id: 8, x: 88 }
+        expectError:
+          errorLabelsContain: ["TransientTransactionError"]
+      - *assertSessionUnpinned
+      - *abortTransaction
+    outcome: *outcome
+    runOnRequirements:
+      - minServerVersion: "8.0" # `bulkWrite` added to server 8.0"
+
diff --git a/test/spec/versioned-api/crud-api-version-1.json b/test/spec/versioned-api/crud-api-version-1.json
index a387d0587e..fe668620f8 100644
--- a/test/spec/versioned-api/crud-api-version-1.json
+++ b/test/spec/versioned-api/crud-api-version-1.json
@@ -50,7 +50,8 @@
         },
         "apiDeprecationErrors": true
       }
-    ]
+    ],
+    "namespace": "versioned-api-tests.test"
   },
   "initialData": [
     {
@@ -426,6 +427,85 @@
         }
       ]
     },
+    {
+      "description": "client bulkWrite appends declared API version",
+      "runOnRequirements": [
+        {
+          "minServerVersion": "8.0"
+        }
+      ],
+      "operations": [
+        {
+          "name": "clientBulkWrite",
+          "object": "client",
+          "arguments": {
+            "models": [
+              {
+                "insertOne": {
+                  "namespace": "versioned-api-tests.test",
+                  "document": {
+                    "_id": 6,
+                    "x": 6
+                  }
+                }
+              }
+            ],
+            "verboseResults": true
+          },
+          "expectResult": {
+            "insertedCount": 1,
+            "upsertedCount": 0,
+            "matchedCount": 0,
+            "modifiedCount": 0,
+            "deletedCount": 0,
+            "insertResults": {
+              "0": {
+                "insertedId": 6
+              }
+            },
+            "updateResults": {},
+            "deleteResults": {}
+          }
+        }
+      ],
+      "expectEvents": [
+        {
+          "client": "client",
+          "events": [
+            {
+              "commandStartedEvent": {
+                "commandName": "bulkWrite",
+                "databaseName": "admin",
+                "command": {
+                  "bulkWrite": 1,
+                  "errorsOnly": false,
+                  "ordered": true,
+                  "ops": [
+                    {
+                      "insert": 0,
+                      "document": {
+                        "_id": 6,
+                        "x": 6
+                      }
+                    }
+                  ],
+                  "nsInfo": [
+                    {
+                      "ns": "versioned-api-tests.test"
+                    }
+                  ],
+                  "apiVersion": "1",
+                  "apiStrict": {
+                    "$$unsetOrMatches": false
+                  },
+                  "apiDeprecationErrors": true
+                }
+              }
+            }
+          ]
+        }
+      ]
+    },
     {
       "description": "countDocuments appends declared API version",
       "operations": [
diff --git a/test/spec/versioned-api/crud-api-version-1.yml b/test/spec/versioned-api/crud-api-version-1.yml
index 50135c1458..cb9b45e57b 100644
--- a/test/spec/versioned-api/crud-api-version-1.yml
+++ b/test/spec/versioned-api/crud-api-version-1.yml
@@ -34,6 +34,7 @@ _yamlAnchors:
       apiVersion: "1"
       apiStrict: { $$unsetOrMatches: false }
       apiDeprecationErrors: true
+  namespace: &namespace "versioned-api-tests.test"
 
 initialData:
   - collectionName: *collectionName
@@ -155,6 +156,46 @@ tests:
                     multi: { $$unsetOrMatches: false }
                     upsert: true
                 <<: *expectedApiVersion
+  
+  - description: "client bulkWrite appends declared API version"
+    runOnRequirements:
+      - minServerVersion: "8.0" # `bulkWrite` added to server 8.0
+    operations:
+      - name: clientBulkWrite
+        object: *client
+        arguments:
+          models:
+            - insertOne:
+                namespace: *namespace
+                document: { _id: 6, x: 6 }
+          verboseResults: true
+        expectResult:
+          insertedCount: 1
+          upsertedCount: 0
+          matchedCount: 0
+          modifiedCount: 0
+          deletedCount: 0
+          insertResults:
+            0:
+              insertedId: 6
+          updateResults: {}
+          deleteResults: {}
+    expectEvents:
+      - client: *client
+        events:
+          - commandStartedEvent:
+              commandName: bulkWrite
+              databaseName: admin
+              command:
+                bulkWrite: 1
+                errorsOnly: false
+                ordered: true
+                ops:
+                  - insert: 0
+                    document: { _id: 6, x: 6 }
+                nsInfo:
+                  - { ns: *namespace }
+                <<: *expectedApiVersion
 
   - description: "countDocuments appends declared API version"
     operations:
diff --git a/test/tools/unified-spec-runner/operations.ts b/test/tools/unified-spec-runner/operations.ts
index 51d458a185..9cc67174f3 100644
--- a/test/tools/unified-spec-runner/operations.ts
+++ b/test/tools/unified-spec-runner/operations.ts
@@ -202,6 +202,16 @@ operations.set('bulkWrite', async ({ entities, operation }) => {
   return collection.bulkWrite(requests, opts);
 });
 
+operations.set('clientBulkWrite', async ({ entities, operation }) => {
+  const client = entities.getEntity('client', operation.object);
+  const { models, ...opts } = operation.arguments!;
+  const bulkWriteModels = models.map(model => {
+    const name = Object.keys(model)[0];
+    return { name: name, ...model[name] };
+  });
+  return client.bulkWrite(bulkWriteModels, opts);
+});
+
 // The entity exists for the name but can potentially have the wrong
 // type (stream/cursor) which will also throw an exception even when
 // telling getEntity() to ignore checking existence.
diff --git a/test/unit/operations/client_bulk_write/results_merger.test.ts b/test/unit/operations/client_bulk_write/results_merger.test.ts
new file mode 100644
index 0000000000..dd661bd67a
--- /dev/null
+++ b/test/unit/operations/client_bulk_write/results_merger.test.ts
@@ -0,0 +1,96 @@
+import { expect } from 'chai';
+
+import {
+  BSON,
+  ClientBulkWriteCursorResponse,
+  type ClientBulkWriteResult,
+  ClientBulkWriteResultsMerger,
+  Long
+} from '../../../mongodb';
+
+describe('ClientBulkWriteResultsMerger', function () {
+  describe('#constructor', function () {
+    const resultsMerger = new ClientBulkWriteResultsMerger({});
+
+    it('initializes the result', function () {
+      expect(resultsMerger.result).to.deep.equal({
+        insertedCount: 0,
+        upsertedCount: 0,
+        matchedCount: 0,
+        modifiedCount: 0,
+        deletedCount: 0
+      });
+    });
+  });
+
+  describe('#merge', function () {
+    context('when the bulk write is acknowledged', function () {
+      context('when requesting verbose results', function () {
+        // An example verbose response from the server without errors:
+        // {
+        //   cursor: {
+        //     id: Long('0'),
+        //     firstBatch: [ { ok: 1, idx: 0, n: 1 }, { ok: 1, idx: 1, n: 1 } ],
+        //     ns: 'admin.$cmd.bulkWrite'
+        //   },
+        //   nErrors: 0,
+        //   nInserted: 2,
+        //   nMatched: 0,
+        //   nModified: 0,
+        //   nUpserted: 0,
+        //   nDeleted: 0,
+        //   ok: 1
+        // }
+        context('when there are no errors', function () {
+          const documents = [
+            { ok: 1, idx: 0, n: 1 }, // Insert
+            { ok: 1, idx: 1, n: 1, nModified: 1 }, // Update match
+            { ok: 1, idx: 2, n: 1 }, // Update no match with upsert
+            { ok: 1, idx: 3, n: 1 } // Delete
+          ];
+          const serverResponse = {
+            cursor: {
+              id: new Long('0'),
+              firstBatch: documents,
+              ns: 'admin.$cmd.bulkWrite'
+            },
+            nErrors: 0,
+            nInserted: 1,
+            nMatched: 1,
+            nModified: 1,
+            nUpserted: 1,
+            nDeleted: 1,
+            ok: 1
+          };
+          const response = new ClientBulkWriteCursorResponse(BSON.serialize(serverResponse), 0);
+          const merger = new ClientBulkWriteResultsMerger({});
+          let result: ClientBulkWriteResult;
+
+          before(function () {
+            result = merger.merge(response, documents);
+          });
+
+          it('merges the inserted count', function () {
+            expect(result.insertedCount).to.equal(1);
+          });
+
+          it('merges the upserted count', function () {
+            expect(result.upsertedCount).to.equal(1);
+          });
+
+          it('merges the matched count', function () {
+            expect(result.matchedCount).to.equal(1);
+          });
+
+          it('merges the modified count', function () {
+            expect(result.modifiedCount).to.equal(1);
+          });
+
+          it('merges the deleted count', function () {
+            expect(result.deletedCount).to.equal(1);
+          });
+        });
+      });
+    });
+  });
+});