server/migrations/2.3.4.js

   1 'use strict';
   2
   3 var BPromise = require('bluebird');
   4 var util = require('util');
   5
   6 var logger = require('../config/logger')('migration');
   7
   8 var Sequence = function() {};
   9
  10 Sequence.prototype.enqueue = function(fn) {
  11     this.tail = this.tail ? this.tail.finally(fn) : fn();
  12 };
  13
  14 var Migration = function(queryInterface) {
  15     this.queryInterface = queryInterface;
  16     this.sequence = new Sequence();
  17 };
  18
  19 Migration.prototype.changeColumn = function(table, column, type) {
  20     var _this = this;
  21     this.sequence.enqueue(function() {
  22         return _this.queryInterface
  23             .changeColumn(table, column, type)
  24             .then(function() {
  25                 logger.info('Changed column %s in table %s', column, table);
  26             })
  27             .catch(function(err) {
  28                 logger.info(JSON.stringify(err));
  29             });
  30     });
  31 };
  32
  33 Migration.prototype.addColumn = function(table, column, type) {
  34     var _this = this;
  35     this.sequence.enqueue(function() {
  36         return _this.queryInterface
  37             .addColumn(table, column, type)
  38             .then(function() {
  39                 logger.info('Added column %s to %s', column, table);
  40             })
  41             .catch(function(err) {
  42                 logger.info(JSON.stringify(err));
  43             });
  44     });
  45 };
  46
  47 Migration.prototype.dropTable = function(table) {
  48     var _this = this;
  49     this.sequence.enqueue(function() {
  50         return _this.queryInterface
  51             .dropTable(table, {
  52                 force: true
  53             })
  54             .then(function() {
  55                 logger.info('table dropped %s', table);
  56             })
  57             .catch(function(err) {
  58                 logger.info(JSON.stringify(err));
  59             });
  60     });
  61 };
  62
  63 Migration.prototype.addIndex = function(table, column, indexName) {
  64     var _this = this;
  65     this.sequence.enqueue(function() {
  66         return _this.queryInterface
  67             .addIndex(table, column, {
  68                 indexName: indexName
  69             })
  70             .then(function() {
  71                 logger.info('addIndex %s %s %s', table, column.join(','), indexName);
  72             })
  73             .catch(function(err) {
  74                 logger.info(JSON.stringify(err));
  75             });
  76     });
  77 };
  78
  79 Migration.prototype.removeIndex = function(table, indexName) {
  80     var _this = this;
  81     this.sequence.enqueue(function() {
  82         return _this.queryInterface
  83             .removeIndex(table, indexName)
  84             .then(function() {
  85                 logger.info('removeIndex %s %s', table, indexName);
  86             })
  87             .catch(function(err) {
  88                 logger.info(JSON.stringify(err));
  89             });
  90     });
  91 };
  92
  93 Migration.prototype.query = function(sql) {
  94     var _this = this;
  95     this.sequence.enqueue(function() {
  96         return _this.queryInterface.sequelize
  97             .query(sql)
  98             .then(function() {
  99                 logger.info('query %s', sql);
 100             })
 101             .catch(function(err) {
 102                 logger.info(JSON.stringify(err));
 103             });
 104     });
 105 };
 106
 107 Migration.prototype.removeColumn = function(table, column) {
 108     var _this = this;
 109     this.sequence.enqueue(function() {
 110         return _this.queryInterface
 111             .removeColumn(table, column)
 112             .then(function() {
 113                 logger.info('Removed column %s from %s', column, table);
 114             })
 115             .catch(function(err) {
 116                 logger.info(
 117                     util.inspect(err, {
 118                         showHidden: false,
 119                         depth: null
 120                     })
 121                 );
 122             });
 123     });
 124 };
 125
 126 Migration.prototype.renameColumn = function(table, oldColumn, newColumn) {
 127     var _this = this;
 128     this.sequence.enqueue(function() {
 129         return _this.queryInterface
 130             .renameColumn(table, oldColumn, newColumn)
 131             .then(function() {
 132                 logger.info('Renamed column from %s to %s on %s', oldColumn, newColumn, table);
 133             })
 134             .catch(function(err) {
 135                 logger.info(
 136                     util.inspect(err, {
 137                         showHidden: false,
 138                         depth: null
 139                     })
 140                 );
 141             });
 142     });
 143 };
 144
 145 Migration.prototype.final = function(resolve) {
 146     this.sequence.enqueue(function() {
 147         return resolve();
 148     });
 149 };
 150
 151 module.exports = {
 152     up: function(queryInterface, Sequelize) {
 153         return new BPromise(function(resolve) {
 154             var migration = new Migration(queryInterface);
 155
 156             // START FINAL
 157             migration.final(resolve);
 158             // END FINAL
 159         });
 160     },
 161
 162     down: function(queryInterface, Sequelize) {
 163         // var migration = new Migration(queryInterface);
 164     }
 165 };