server/migrations/2.5.17.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 };