fix: MS SQL has unusual CREATE SCHEMA syntax

Fixes #185
cube-js · Aug 17, 2019 · 16b8c87 · 16b8c87
1 parent e31a80c
commit 16b8c87
Showing 1 changed file with 12 additions and 0 deletions.
diff --git 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;