Merge pull request #48 from but1head/master

Adding support postgresql ARRAY support

Author: flexxnn

lib/migrate.js

@@ -96,6 +96,15 @@ const reverseSequelizeColType = function(col, prefix = 'Sequelize.')
             return prefix + 'GEOGRAPHY';
 
         case DataTypes.ARRAY.key:
+          const _type = attrObj.toString();
+          let arrayType;
+          if(_type === 'INTEGER[]' || _type === 'STRING[]') {
+            arrayType = prefix + _type.replace('[]', '');
+          } else {
+            arrayType = (col.seqType === 'Sequelize.ARRAY(Sequelize.INTEGER)') ? prefix + 'INTEGER' : prefix + 'STRING';
+          }
+          return prefix + `ARRAY(${arrayType})`;
+            
         case DataTypes.RANGE.key:
             console.warn(attrName + ' type not supported, you should make it by')
             return prefix + attrObj.toSql()
@@ -201,12 +210,24 @@ const reverseModels = function(sequelize, models)
                     delete attributes[column][property];
             }
 
-            if(typeof attributes[column]['type'] === 'undefined')
+            if(typeof attributes[column]['type'] === 'undefined') 
             {
+              if(!attributes[column]['seqType']) 
+              {
                 log(`[Not supported] Skip column with undefined type ${model}:${column}`);
                 delete attributes[column];
                 continue;
+              } else {
+                if(!['Sequelize.ARRAY(Sequelize.INTEGER)', 'Sequelize.ARRAY(Sequelize.STRING)'].includes(attributes[column]['seqType'])) {
+                  delete attributes[column];
+                  continue;
+                }
+                attributes[column]['type'] = {
+                  key: Sequelize.ARRAY.key
+                }
+              }
             }
+            
             let seqType = reverseSequelizeColType(attributes[column]);
 
             // NO virtual types in migration
@@ -820,4 +841,3 @@ const executeMigration = function(queryInterface, filename, pos, cb)
 };
 
 module.exports = { writeMigration, getMigration, sortActions, parseDifference, reverseModels, executeMigration };
-