Improved handling of postgres schemas when dealing with enum values.

changelog.md

 # Next
 - [FIXED] Apply scopes to `aggregate` [#4764](https://github.com/sequelize/sequelize/issues/4764)
+- [FIXED] Improved postgres enum schema handling [#4796](https://github.com/sequelize/sequelize/issues/4796)
 - [ADDED/FIXED] Lower case `onDelete` option to allow the use of `onDelete: 'CASCADE', hooks: true`.
 
 # 3.13.0

lib/dialects/abstract/query-generator.js

@@ -19,6 +19,16 @@ var throwMethodUndefined = function(methodName) {
 var QueryGenerator = {
   options: {},
 
+  extractTableDetails: function(tableName, options) {
+    options = options || {};
+    tableName = tableName || {};
+    return {
+      schema: tableName.schema || options.schema || 'public',
+      tableName: _.isPlainObject(tableName) ? tableName.table : tableName,
+      delimiter: tableName.delimiter || options.delimiter || '.'
+    };
+  },
+
   addSchema: function(param) {
     var self = this;
 

lib/dialects/postgres/query-generator.js

@@ -719,34 +719,36 @@ var QueryGenerator = {
 
   pgEnumName: function (tableName, attr, options) {
     options = options || {};
+    var tableDetails = this.extractTableDetails(tableName, options)
+      , enumName = '"enum_' + tableDetails.tableName + '_' + attr + '"';
 
-    var enumName = '"enum_' + (_.isPlainObject(tableName) ? tableName.table : tableName) + '_' + attr + '"';
-
-    if (options.schema !== false && tableName && tableName.schema) {
-      enumName = '"' + tableName.schema + '"' + tableName.delimiter + enumName;
+    // pgListEnums requires the enum name only, without the schema
+    if (options.schema !== false && tableDetails.schema) {
+      enumName = this.quoteIdentifier(tableDetails.schema) + tableDetails.delimiter + enumName;
     }
 
     return enumName;
+
   },
 
-  pgListEnums: function(tableName, attrName) {
+  pgListEnums: function(tableName, attrName, options) {
     var enumName = ''
-      , schema = tableName && tableName.schema ? tableName.schema : 'public';
+      , tableDetails = this.extractTableDetails(tableName, options);
 
-    if (!!tableName && !!attrName) {
-      enumName = ' AND t.typname=' + this.pgEnumName(tableName, attrName, { schema: false }).replace(/"/g, "'");
+    if (tableDetails.tableName && attrName) {
+      enumName = ' AND t.typname=' + this.pgEnumName(tableDetails.tableName, attrName, { schema: false }).replace(/"/g, "'");
     }
 
     var query = 'SELECT t.typname enum_name, array_agg(e.enumlabel) enum_value FROM pg_type t ' +
       'JOIN pg_enum e ON t.oid = e.enumtypid ' +
       'JOIN pg_catalog.pg_namespace n ON n.oid = t.typnamespace ' +
-      "WHERE n.nspname = '" + schema + "'" + enumName + ' GROUP BY 1';
+      "WHERE n.nspname = '" + tableDetails.schema + "'" + enumName + ' GROUP BY 1';
 
     return query;
   },
 
   pgEnum: function(tableName, attr, dataType, options) {
-    var enumName = this.pgEnumName(tableName, attr)
+    var enumName = this.pgEnumName(tableName, attr, options)
       , values;
 
     if (dataType.values) {

lib/instance-validator.js

@@ -64,10 +64,12 @@ InstanceValidator.prototype.validate = function() {
   this.inProgress = true;
 
   var self = this;
-  return Promise.settle([
+  return Promise.all([
     self._builtinValidators(),
     self._customValidators()
-  ]).then(function() {
+  ].map(function(promise) {
+    return promise.reflect();
+  })).then(function() {
     if (self.errors.length) {
       return new sequelizeError.ValidationError(null, self.errors);
     }
@@ -98,7 +100,7 @@ InstanceValidator.prototype.hookValidate = function() {
 /**
  * Will run all the built-in validators.
  *
- * @return {Promise(Array.<Promise.PromiseInspection>)} A promise from .settle().
+ * @return {Promise(Array.<Promise.PromiseInspection>)} A promise from .reflect().
  * @private
  */
 InstanceValidator.prototype._builtinValidators = function() {
@@ -119,17 +121,17 @@ InstanceValidator.prototype._builtinValidators = function() {
     }
 
     if (self.modelInstance.validators.hasOwnProperty(field)) {
-      validators.push(self._builtinAttrValidate.call(self, value, field));
+      validators.push(self._builtinAttrValidate.call(self, value, field).reflect());
     }
   });
 
-  return Promise.settle(validators);
+  return Promise.all(validators);
 };
 
 /**
  * Will run all the custom validators.
  *
- * @return {Promise(Array.<Promise.PromiseInspection>)} A promise from .settle().
+ * @return {Promise(Array.<Promise.PromiseInspection>)} A promise from .reflect().
  * @private
  */
 InstanceValidator.prototype._customValidators = function() {
@@ -139,15 +141,16 @@ InstanceValidator.prototype._customValidators = function() {
     if (self.options.skip.indexOf(validatorType) >= 0) {
       return;
     }
-    
+
     var valprom = self._invokeCustomValidator(validator, validatorType)
       // errors are handled in settling, stub this
-      .catch(function() {});
+      .catch(function() {})
+      .reflect();
 
     validators.push(valprom);
   });
 
-  return Promise.settle(validators);
+  return Promise.all(validators);
 };
 
 /**
@@ -184,16 +187,16 @@ InstanceValidator.prototype._builtinAttrValidate = function(value, field) {
 
     // Check for custom validator.
     if (typeof test === 'function') {
-      return validators.push(self._invokeCustomValidator(test, validatorType, true, value, field));
+      return validators.push(self._invokeCustomValidator(test, validatorType, true, value, field).reflect());
     }
 
     var validatorPromise = self._invokeBuiltinValidator(value, test, validatorType, field);
     // errors are handled in settling, stub this
     validatorPromise.catch(function() {});
-    validators.push(validatorPromise);
+    validators.push(validatorPromise.reflect());
   });
 
-  return Promise.settle(validators).then(this._handleSettledResult.bind(this, field));
+  return Promise.all(validators).then(this._handleReflectedResult.bind(this, field));
 };
 
 /**
@@ -299,7 +302,7 @@ InstanceValidator.prototype._validateSchema = function(rawAttribute, field, valu
 
 
 /**
- * Handles the returned result of a Promise.settle.
+ * Handles the returned result of a Promise.reflect.
  *
  * If errors are found it populates this.error.
  *
@@ -307,7 +310,7 @@ InstanceValidator.prototype._validateSchema = function(rawAttribute, field, valu
  * @param {Array.<Promise.PromiseInspection>} Promise inspection objects.
  * @private
  */
-InstanceValidator.prototype._handleSettledResult = function(field, promiseInspections) {
+InstanceValidator.prototype._handleReflectedResult = function(field, promiseInspections) {
   var self = this;
   promiseInspections.forEach(function(promiseInspection) {
     if (promiseInspection.isRejected()) {

lib/model.js

@@ -2436,6 +2436,7 @@ Model.prototype.update = function(values, options) {
         }
       });
     }
+    return null;
   }).then(function() {
     // Run before hook
     if (options.hooks) {

lib/query-interface.js

@@ -93,7 +93,7 @@ QueryInterface.prototype.createTable = function(tableName, attributes, options,
 
     for (i = 0; i < keyLen; i++) {
       if (attributes[keys[i]].type instanceof DataTypes.ENUM) {
-        sql = self.QueryGenerator.pgListEnums(tableName, attributes[keys[i]].field || keys[i]);
+        sql = self.QueryGenerator.pgListEnums(tableName, attributes[keys[i]].field || keys[i], options);
         promises.push(self.sequelize.query(
           sql, { plain: true, raw: true, type: QueryTypes.SELECT, logging: options.logging, transaction: options.transaction }
         ));

package.json

@@ -32,7 +32,7 @@
     "url": "https://github.com/sequelize/sequelize/issues"
   },
   "dependencies": {
-    "bluebird": "^3.0.0",
+    "bluebird": "^3.0.5",
     "depd": "^1.0.0",
     "dottie": "^1.0.0",
     "generic-pool": "2.2.1",

test/unit/sql/enum.test.js

@@ -5,7 +5,8 @@ var Support   = require(__dirname + '/../support')
   , DataTypes = require(__dirname + '/../../../lib/data-types')
   , expectsql = Support.expectsql
   , current   = Support.sequelize
-  , sql       = current.dialect.QueryGenerator;
+  , sql       = current.dialect.QueryGenerator
+  , expect    = require('chai').expect;
 
 
 describe(Support.getTestDialectTeaser('SQL'), function() {
@@ -24,6 +25,22 @@ describe(Support.getTestDialectTeaser('SQL'), function() {
         }
       });
 
+      describe('pgEnumName', function() {
+        it('does not add schema when options: { schema: false }', function() {
+          expect(sql.pgEnumName(PublicUser.getTableName(), 'mood', { schema: false }))
+            .to.equal('"enum_users_mood"');
+          expect(sql.pgEnumName(FooUser.getTableName(), 'theirMood', { schema: false }))
+            .to.equal('"enum_users_theirMood"');
+        });
+
+        it('properly quotes both the schema and the enum name', function() {
+          expect(sql.pgEnumName(PublicUser.getTableName(), 'mood', PublicUser.rawAttributes.mood.type))
+            .to.equal('"public"."enum_users_mood"');
+          expect(sql.pgEnumName(FooUser.getTableName(), 'theirMood', FooUser.rawAttributes.mood.type))
+            .to.equal('"foo"."enum_users_theirMood"');
+        });
+      });
+
       describe('pgEnum', function () {
         it('uses schema #3171', function () {
           expectsql(sql.pgEnum(FooUser.getTableName(), 'mood', FooUser.rawAttributes.mood.type), {
@@ -31,9 +48,9 @@ describe(Support.getTestDialectTeaser('SQL'), function() {
           });
         });
 
-        it('does not add schema when public', function () {
+        it('does add schema when public', function () {
           expectsql(sql.pgEnum(PublicUser.getTableName(), 'theirMood', PublicUser.rawAttributes.mood.type), {
-            postgres: 'CREATE TYPE "enum_users_theirMood" AS ENUM(\'happy\', \'sad\');'
+            postgres: 'CREATE TYPE "public"."enum_users_theirMood" AS ENUM(\'happy\', \'sad\');'
           });
         });
       });
@@ -45,8 +62,8 @@ describe(Support.getTestDialectTeaser('SQL'), function() {
           });
         });
 
-        it('uses the default schema if options given', function () {
-            expectsql(sql.pgListEnums(), {
+        it('uses the default schema if no options given', function () {
+          expectsql(sql.pgListEnums(), {
             postgres: 'SELECT t.typname enum_name, array_agg(e.enumlabel) enum_value FROM pg_type t JOIN pg_enum e ON t.oid = e.enumtypid JOIN pg_catalog.pg_namespace n ON n.oid = t.typnamespace WHERE n.nspname = \'public\' GROUP BY 1'
           });
         });