Merge pull request #570 from liquibase/DAT-18785

Override getDatabaseProductVersion() to find actual Mongo version (DAT-18785)

src/main/java/liquibase/ext/mongodb/database/MongoLiquibaseDatabase.java

@@ -33,6 +33,7 @@
 import liquibase.nosql.database.AbstractNoSqlDatabase;
 import lombok.NoArgsConstructor;
 import lombok.Setter;
+import org.bson.Document;
 
 import static liquibase.nosql.executor.NoSqlExecutor.EXECUTOR_NAME;
 
@@ -74,6 +75,19 @@ public String getDatabaseProductName() {
         return MONGODB_PRODUCT_NAME;
     }
 
+    @Override
+    public String getDatabaseProductVersion() {
+        String unknownVersion = "Unknown";
+        try {
+            Document document = getMongoDatabase().runCommand(new Document("buildInfo", 1));
+            String version = document.getString("version");
+            return version != null ? version : unknownVersion;
+        } catch (Exception unableToDetermineVersion) {
+            Scope.getCurrentScope().getLog(getClass()).warning("Unable to determine mongo database version!", unableToDetermineVersion);
+            return unknownVersion;
+        }
+    }
+
     /**
      * Returns an all-lower-case short name of the product.  Used for end-user selecting of database type
      * such as the DBMS precondition.

src/test/java/liquibase/ext/mongodb/change/AbstractMongoChangeTest.java

@@ -30,6 +30,11 @@ public abstract class AbstractMongoChangeTest {
 
     @BeforeEach
     void setUp() {
-        database = new MongoLiquibaseDatabase();
+        database = new MongoLiquibaseDatabase() {
+            @Override
+            public String getDatabaseProductVersion() {
+                return "test";
+            }
+        };
     }
 }