diff --git a/packages/cubejs-mssql-driver/driver/MSSqlDriver.js b/packages/cubejs-mssql-driver/driver/MSSqlDriver.js
index b03b4ebdda974..b3f5245d7b9eb 100644
--- a/packages/cubejs-mssql-driver/driver/MSSqlDriver.js
+++ b/packages/cubejs-mssql-driver/driver/MSSqlDriver.js
@@ -60,6 +60,18 @@ class MSSqlDriver extends BaseDriver {
   param(paramIndex) {
     return `@_${paramIndex + 1}`;
   }
+
+  createSchemaIfNotExists(schemaName) {
+    return this.query(
+      `SELECT schema_name FROM information_schema.schemata WHERE schema_name = ${this.param(0)}`,
+      [schemaName]
+    ).then((schemas) => {
+      if (schemas.length === 0) {
+        return this.query(`CREATE SCHEMA ${schemaName}`);
+      }
+      return null;
+    });
+  }
 }
 
 module.exports = MSSqlDriver;