SERVER-43299 Make explain for write commands send databaseVersion

1 files changed, 7 insertions, 1 deletions

diff --git a/src/mongo/s/commands/cluster_write_cmd.cpp b/src/mongo/s/commands/cluster_write_cmd.cpp
index c3d8081a816..6fd2853dcba 100644
--- a/src/mongo/s/commands/cluster_write_cmd.cpp
+++ b/src/mongo/s/commands/cluster_write_cmd.cpp
@@ -366,7 +366,13 @@ private:
         // Assemble requests
         std::vector<AsyncRequestsSender::Request> requests;
         for (const auto& endpoint : swEndpoints.getValue()) {
-            requests.emplace_back(endpoint.shardName, command);
+            BSONObj cmdObjWithVersions = BSONObj(command);
+            if (endpoint.databaseVersion) {
+                cmdObjWithVersions =
+                    appendDbVersionIfPresent(cmdObjWithVersions, *endpoint.databaseVersion);
+            }
+            cmdObjWithVersions = appendShardVersion(cmdObjWithVersions, endpoint.shardVersion);
+            requests.emplace_back(endpoint.shardName, cmdObjWithVersions);
         }
 
         // Send the requests.