26 error report file name

query.js

@@ -36,7 +36,10 @@ function execute_query(conn, path, final_file_paths, type, cb, run) {
     var current_file_path = path + "/" + file_name;
 
     var queries = require(current_file_path);
-    console.info(colors.green("Run: " + run + " Type: " + type.toUpperCase() + ": " +queries[type]));
+    console.info(colors.green(
+      `Run: ${run} Type: ${type.toUpperCase()}: ${file_name}`
+    ));
+    console.info(colors.gray(queries[type]));
 
     var timestamp_val = file_name.split("_", 1)[0];
     if (typeof(queries[type]) == 'string') {

test/query.js

@@ -4,13 +4,49 @@ var queryFunctions = require('../query');
 var testCommons = require('./test_commons');
 var mysql = require('./mysql');
 var assert = require('assert');
+var fs = require('fs');
 
 var should = chai.should();
 
 describe('query.js', function() {
   before(function (done) {
     testCommons(done);
   });
+  after(function (done) {
+    testCommons(done);
+  });
+
+  context('execute_query', function () {
+    it('should write file name', function (done) {
+      const name = '1_should_write_file_name.js';
+      fs.writeFileSync(
+        __dirname + '/migrations/' + name,
+        `module.exports={up: "select 1", down: "select 2"};`,
+        { encoding: 'utf-8' }
+      );
+
+      mysql.getConnection(function (err, connection) {
+        if (err) throw err;
+
+        var files = [{
+          timestamp: 1, file_path: name
+        }];
+        var oldInfo = console.info;
+        var loggedFile = false;
+        console.info = (arg1) => {
+          if (`${arg1}`.includes(name)) {
+            loggedFile = true;
+          }
+        };
+
+        queryFunctions.execute_query(mysql, __dirname + '/migrations', files, 'up', function () {
+          console.info = oldInfo.bind(console);
+          assert.ok(loggedFile, 'File name was logged.');
+          done();
+        });
+      });
+    })
+  });
 
   context('updateRecords', function () {
     var timestamp = Date.now();

test/test_commons.js

@@ -1,5 +1,6 @@
 var mysql = require('./mysql');
 var fs = require('fs');
+var config = require('../config');
 
 function deleteFolderRecursive(path) {
   if (fs.existsSync(path)) {
@@ -30,8 +31,11 @@ module.exports = function(cb) {
             if (error) throw error;
             connection.query("DROP TABLE IF EXISTS user5", function (error) {
               if (error) throw error;
-              deleteFolderRecursive(__dirname + '/migrations');
-              cb();
+              connection.query(`delete from ${config.table}`, function (error) {
+                if (error) throw error;
+                deleteFolderRecursive(__dirname + '/migrations');
+                cb();
+              })
             });
           });
         });