added pddev-migratedbdown and change -d option to use postgrator.json database if not supplied

Author: thardy-pd

package-lock.json

@@ -6,6 +6,7 @@
   "bin": {
     "pddev": "pddev.js",
     "pddev-migratedb": "pddev-migratedb.js",
+    "pddev-migratedbdown": "pddev-migratedbdown.js",
     "pddev-nukedb": "pddev-nukedb.js",
     "pddev-rebuilddb": "pddev-rebuilddb.js",
     "pddev-restoredb": "pddev-restoredb.js",

package.json

@@ -0,0 +1,36 @@
+#!/usr/bin/env node
+'use strict';
+const args = require('args');
+const sql = require('mssql/msnodesqlv8');
+const SqlService = require('./sql/sqlService');
+
+(async () => {
+  const postgratorConfig = await require('./postgratorConfig');
+  const sqlService = new SqlService();
+  const options = args.parse(process.argv);
+
+  // this is whatever is typed just after this subcommand: pddev-migratedbdown 5
+  const version = args.sub[0]; // would be 5 from above example
+
+  let dbPool = {};
+
+  try {
+    const sqlDbConnectionOptions = {
+      connectionString: `Driver=SQL Server;Server=(local);Database=${postgratorConfig.database};Trusted_Connection=true;`,
+    };
+
+    dbPool = await new sql.ConnectionPool(sqlDbConnectionOptions).connect();
+    console.log(`connected to ${postgratorConfig.database}...`);
+
+    let result = await sqlService.runScript(dbPool, sqlService.scriptNames.migrateDown, `migrating down to version ${version}...`, {version: version});
+  }
+  catch (err) {
+    console.log(err);
+  }
+  finally {
+    if (dbPool && dbPool.close) {
+      dbPool.close();
+    }
+  }
+
+})();

pddev-migratedbdown.js

@@ -3,18 +3,18 @@
 const sql = require('mssql/msnodesqlv8');
 const args = require('args');
 const SqlService = require('./sql/sqlService');
-const SqlMigrationService = require('./sqlMigrationService');
 const config = require('./config.json');
 
 args.option('databaseName', 'The database you want to act on');
 
 (async () => {
+  const postgratorConfig = await require('./postgratorConfig');
   const sqlService = new SqlService();
-  const sqlMigrationService = new SqlMigrationService();
   // console.log(process.argv);
   const options = args.parse(process.argv);
+  const databaseName = options.databaseName ? options.databaseName : postgratorConfig.database;
 
-  //const sqlScripts = await sqlService.transformSqlScripts({ databaseName: options.databaseName }); //await require('./sqlScripts/sqlScriptService')({ databaseName: options.databaseName });
+  //const sqlScripts = await sqlService.transformSqlScripts({ databaseName: databaseName }); //await require('./sqlScripts/sqlScriptService')({ databaseName: databaseName });
 
   let masterPool = {};
   let dbPool = {};
@@ -33,13 +33,13 @@ args.option('databaseName', 'The database you want to act on');
     //   }
     // };
     const sqlDbConnectionOptions = {
-      connectionString: `Driver=SQL Server;Server=(local);Database=${options.databaseName};Trusted_Connection=true;`,
+      connectionString: `Driver=SQL Server;Server=(local);Database=${databaseName};Trusted_Connection=true;`,
     };
 
     masterPool = await new sql.ConnectionPool(sqlMasterConnectionOptions).connect();
     console.log('connected to master using instance ${c}...');
 
-    await sqlService.nukeDb(masterPool, sqlDbConnectionOptions, {databaseName: options.databaseName, username: config.username, password: config.password});
+    await sqlService.nukeDb(masterPool, sqlDbConnectionOptions, {databaseName: databaseName, username: config.username, password: config.password});
   }
   catch (err) {
     console.log(err);

pddev-nukedb.js

@@ -9,10 +9,12 @@ const config = require('./config.json');
 args.option('databaseName', 'The database you want to act on');
 
 (async () => {
+  const postgratorConfig = await require('./postgratorConfig');
   const sqlService = new SqlService();
   const sqlMigrationService = new SqlMigrationService();
   // console.log(process.argv);
   const options = args.parse(process.argv);
+  const databaseName = options.databaseName ? options.databaseName : postgratorConfig.database;
 
   let masterPool = {};
   let dbPool = {};
@@ -31,14 +33,14 @@ args.option('databaseName', 'The database you want to act on');
     //   }
     // };
     const sqlDbConnectionOptions = {
-      connectionString: `Driver=SQL Server;Server=(local);Database=${options.databaseName};Trusted_Connection=true;`,
+      connectionString: `Driver=SQL Server;Server=(local);Database=${databaseName};Trusted_Connection=true;`,
     };
 
     masterPool = await new sql.ConnectionPool(sqlMasterConnectionOptions).connect();
     console.log('connected to master...');
 
     // nuke database
-    await sqlService.nukeDb(masterPool, sqlDbConnectionOptions, {databaseName: options.databaseName, username: config.username, password: config.password});
+    await sqlService.nukeDb(masterPool, sqlDbConnectionOptions, {databaseName: databaseName, username: config.username, password: config.password});
 
     console.log(`migrating sql in local sql folder...`);
     sqlMigrationService.migrateSql();

pddev-rebuilddb.js

@@ -8,10 +8,12 @@ const config = require('./config.json');
 args.option('databaseName', 'The database you want to act on');
 
 (async () => {
+  const postgratorConfig = await require('./postgratorConfig');
   const sqlService = new SqlService();
   const options = args.parse(process.argv);
+  const databaseName = options.databaseName ? options.databaseName : postgratorConfig.database;
 
-  //const sqlScripts = await sqlService.transformSqlScripts({ databaseName: options.databaseName }); //await require('./sqlScripts/sqlScriptService')({ databaseName: options.databaseName });
+  //const sqlScripts = await sqlService.transformSqlScripts({ databaseName: databaseName }); //await require('./sqlScripts/sqlScriptService')({ databaseName: databaseName });
 
   let masterPool = {};
 
@@ -30,25 +32,25 @@ args.option('databaseName', 'The database you want to act on');
     //   }
     // };
     const sqlDbConnectionOptions = {
-      connectionString: `Driver=SQL Server;Server=(local);Database=${options.databaseName};Trusted_Connection=true;`,
+      connectionString: `Driver=SQL Server;Server=(local);Database=${databaseName};Trusted_Connection=true;`,
     };
 
     masterPool = await new sql.ConnectionPool(sqlMasterConnectionOptions).connect();
     masterPool.config.requestTimeout = 300000;
     console.log('connected to master...');
 
     // nuke database
-    await sqlService.nukeDb(masterPool, sqlDbConnectionOptions, {databaseName: options.databaseName, username: config.username, password: config.password});
+    await sqlService.nukeDb(masterPool, sqlDbConnectionOptions, {databaseName: databaseName, username: config.username, password: config.password});
 
     // **** restore database
-    console.log(`attempting to restore database ${options.databaseName}...`);
+    console.log(`attempting to restore database ${databaseName}...`);
     //const sqlFilePathResult = await masterPool.request().query(sqlScripts.getSqlFilePath);
     const sqlFilePathResult = await sqlService.runScript(masterPool, sqlService.scriptNames.getSqlFilePath);
     const sqlFilePath = sqlFilePathResult.recordsets[0] && sqlFilePathResult.recordsets[0][0] ? sqlFilePathResult.recordsets[0][0].sqlFilePath : null;
 
-    let result = await sqlService.restoreDatabase(masterPool,{databaseName: options.databaseName, restoreFilePath: './sql/restore.bak', sqlFilePath});
+    let result = await sqlService.restoreDatabase(masterPool,{databaseName: databaseName, restoreFilePath: './sql/restore.bak', sqlFilePath});
 
-    console.log(`${options.databaseName} restored - DONE`);
+    console.log(`${databaseName} restored - DONE`);
     masterPool.close();
   }
   catch (err) {

pddev-restoredb.js

@@ -7,13 +7,15 @@ const args = require('args');
 args
   .option('databaseName', 'The database you want to act on')
   .command('migratedb', 'Migrate database using scripts in local sql folder', ['m'])
+  .command('migratedbdown', 'Migrate database down to version (must supply version number)', ['d'])
   .command('nukedb', 'Nuke database (drop, then create empty)', ['n'])
   .command('rebuilddb', 'Rebuild your database (drop, create, migrate)', ['r'])
   .command('restoredb', 'Restore database from bak file', ['s'])
   .command('test', 'Test cool new console stuffs', ['t']);
 
 global.options = args.parse(process.argv);
 
+
 // (async () => {
 //   global.sqlScripts = await sqlScripts.loadSqlScripts({ databaseName: flags.databaseName});
 // })();

pddev.js

@@ -0,0 +1,13 @@
+const path = require('path');
+const fs = require("fs-extra");
+
+// this is how to do an export an asynchronous/awaitable require
+module.exports = (async () => {
+  const cwd = process.cwd();
+  const postgratorFilePath = path.resolve(cwd, 'postgrator.json');
+  postgratorConfig = await fs.readFile(postgratorFilePath, "utf8");
+
+  // this is what will be exported
+  return JSON.parse(postgratorConfig);
+})();
+

postgratorConfig.js

@@ -0,0 +1 @@
+delete from DbMigrationVersion where [version] > ${version}

sql/sqlScripts/migrateDown.sql

@@ -24,7 +24,8 @@ class SqlService {
       dropDatabase: 'dropDatabase',
       getSqlFilePath: 'getSqlFilePath',
       initSecurityForLocalUser: 'initSecurityForLocalUser',
-      restoreDatabase: 'restoreDatabase'
+      restoreDatabase: 'restoreDatabase',
+      migrateDown: 'migrateDown'
     };
   }