New ExclusionConstraintError and handling it in Postgres

lib/dialects/postgres/query.js

@@ -121,7 +121,7 @@ module.exports = (function() {
               attribute: field,
               collate: attribute.match(/COLLATE "(.*?)"/) ? /COLLATE "(.*?)"/.exec(attribute)[1] : undefined,
               order: attribute.indexOf('DESC') !== -1 ? 'DESC' : attribute.indexOf('ASC') !== -1 ? 'ASC': undefined,
-              length: undefined,
+              length: undefined
             };
           });
           delete result.columns;
@@ -254,7 +254,10 @@ module.exports = (function() {
   Query.prototype.formatError = function (err) {
     var match
       , table
-      , index;
+      , index
+      , fields
+      , errors
+      , message;
 
     var code = err.code || err.sqlState
       , errMessage = err.message || err.messagePrimary
@@ -277,9 +280,9 @@ module.exports = (function() {
         match = errDetail.match(/Key \((.*?)\)=\((.*?)\)/);
 
         if (match) {
-          var fields = Utils._.zipObject(match[1].split(', '), match[2].split(', '))
-            , errors = []
-            , message = 'Validation error';
+          fields = Utils._.zipObject(match[1].split(', '), match[2].split(', '));
+          errors = [];
+          message = 'Validation error';
 
           Utils._.forOwn(fields, function(value, field) {
             errors.push(new sequelizeErrors.ValidationErrorItem(
@@ -309,6 +312,44 @@ module.exports = (function() {
         }
 
         break;
+      case '23P01':
+        // there are multiple different formats of error messages for this error code
+        // this regex should check at least two
+        match = errDetail.match(/Key \((.*?)\)=\((.*?)\)/);
+
+        if (match) {
+          fields = Utils._.zipObject(match[1].split(', '), match[2].split(', '));
+          errors = [];
+          message = 'Validation error';
+
+          Utils._.forOwn(fields, function(value, field) {
+            errors.push(new sequelizeErrors.ValidationErrorItem(
+              field + ' must be unique', 'unique violation', field, value));
+          });
+
+          if (this.callee && this.callee.__options && this.callee.__options.uniqueKeys) {
+            Utils._.forOwn(this.callee.__options.uniqueKeys, function(constraint) {
+              if (Utils._.isEqual(constraint.fields, Object.keys(fields)) && !!constraint.msg) {
+                message = constraint.msg;
+                return false;
+              }
+            });
+          }
+
+          return new sequelizeErrors.ExclusionConstraintError({
+            message: message,
+            errors: errors,
+            parent: err,
+            fields: fields
+          });
+        } else {
+          return new sequelizeErrors.ExclusionConstraintError({
+            message: errMessage,
+            parent: err
+          });
+        }
+
+        break;
       default:
         return new sequelizeErrors.DatabaseError(err);
     }

lib/errors.js

@@ -145,6 +145,26 @@ error.ForeignKeyConstraintError = function (options) {
 util.inherits(error.ForeignKeyConstraintError, error.DatabaseError);
 
 /**
+ * Thrown when an exclusion constraint is violated in the database
+ * @extends DatabaseError
+ * @constructor
+ */
+error.ExclusionConstraintError = function (options) {
+  options = options || {};
+  options.parent = options.parent || { sql: '' };
+
+  error.DatabaseError.call(this, options.parent);
+  this.name = 'SequelizeExclusionConstraintError';
+
+  this.message = options.message;
+  this.fields = options.fields;
+  this.table = options.table;
+  this.value = options.value;
+  this.index = options.index;
+};
+util.inherits(error.ExclusionConstraintError, error.DatabaseError);
+
+/**
  * The message from the DB.
  * @property message
  * @name message