server/migrations/2.5.26.js

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