Adding mssql

Author: cliedeman

.travis.yml

@@ -13,12 +13,12 @@ addons:
       - postgresql-client-10
 
 node_js:
-  - '6'
-  - '7'
-  - '8'
-  - '9'
-  - '10'
-  - '11'
+  - "6"
+  - "7"
+  - "8"
+  - "9"
+  - "10"
+  - "11"
 
 env:
   - POSTGRESQL_VERSION=9.4 MYSQL_VERSION=5.5
@@ -33,6 +33,7 @@ before_install:
   - sudo service mysql stop || sudo service mysql-5.6 stop || sudo stop mysql-5.6 || sudo stop mysql || echo "failed to stop mysql"
   - sudo docker pull mysql:$MYSQL_VERSION
   - sudo docker run --name mysql -p 3306:3306 -e MYSQL_ROOT_PASSWORD=root -d mysql:$MYSQL_VERSION
+  - sudo docker run -e 'ACCEPT_EULA=Y' -e 'SA_PASSWORD=eioC9vvCZzQSy4S9g37i' -p 1433:1433 -d microsoft/mssql-server-linux:2017-CU8
   - sleep 20
 
 before_script:

docker-compose.yml

@@ -0,0 +1,26 @@
+version: "3"
+services:
+  mssql:
+    image: "microsoft/mssql-server-linux:2017-CU12"
+    environment:
+      - ACCEPT_EULA=Y
+      - SA_PASSWORD=eioC9vvCZzQSy4S9g37i
+    ports:
+      - "1433:1433"
+  mysql:
+    image: "mysql:8.0.15"
+    environment: 
+      - MYSQL_DATABASE=db_errors_test
+      - MYSQL_USER=db_errors
+      - MYSQL_PASSWORD=password
+      - MYSQL_ALLOW_EMPTY_PASSWORD=yes
+    ports:
+      - "3306:3306"
+  postgres:
+    image: "postgres:11.2"
+    environment: 
+      - POSTGRES_DB=db_errors_test
+      - POSTGRES_USER=db_errors
+      - POSTGRES_PASSWORD=password
+    ports:
+      - "3306:3306"

lib/errorCodes/index.js

@@ -2,8 +2,10 @@
 
 const postgres = require('./postgres');
 const mysql = require('./mysql');
+const mssql = require('./mssql');
 
 module.exports = {
   postgres,
-  mysql
+  mysql,
+  mssql,
 };

lib/errorCodes/mssql.js

@@ -0,0 +1,30 @@
+'use strict';
+
+// select * from sysmessages where [error] in (2601, 2627, 515, 547, 241, 242, 8152, 245) and msglangid = 1033;
+
+const codes = {
+  16: new Set([
+    241,
+    242,
+    245,
+    515,
+    547,
+    8152
+  ]),
+  14: new Set([2601, 2627])
+};
+
+function has(code) {
+  const set = codes[code.severity];
+
+  if (set) {
+    return set.has(code.errorCode);
+  }
+
+  return false;
+}
+
+// Top level key is the severity
+module.exports = {
+  has,
+}

lib/parsers/index.js

@@ -1,9 +1,11 @@
 const postgres = require('./postgres/DBError/parser');
 const sqlite = require('./sqlite/DBError/parser');
 const mysql = require('./mysql/DBError/parser');
+const mssql = require('./mssql/DBError/parser');
 
 module.exports = {
   postgres,
   sqlite,
-  mysql
+  mysql,
+  mssql,
 };

lib/parsers/mssql/DBError/CheckViolationError/parser.js

@@ -0,0 +1,27 @@
+const CheckViolationError = require('../../../../errors/CheckViolationError');
+const { isCode } = require('../util');
+
+const REGEX = /The (INSERT|UPDATE) statement conflicted with the CHECK constraint "(.+)". The conflict occurred in database "(.+)", table "(.+)", column '(.+)'./
+
+module.exports = {
+  error: CheckViolationError,
+
+  parse: (err) => {
+    if (isCode(err, 16, 547)) {
+      const match = REGEX.exec(err.originalError.message);
+
+      if (!match) {
+        return null;
+      }
+
+      return {
+        table: match[3],
+        constraint: match[1]
+      };
+    } else {
+      return null;
+    }
+  },
+
+  subclassParsers: []
+};

lib/parsers/mssql/DBError/DataError/parser.js

@@ -0,0 +1,20 @@
+const DataError = require('../../../../errors/DataError');
+const { isCode } = require('../util');
+
+module.exports = {
+  error: DataError,
+
+  parse: (err) => {
+    // 241 - Conversion failed when converting date and/or time from character string.
+    // 242 - The conversion of a nvarchar data type to a datetime data type resulted in an out-of-range value.
+    // 245 - Conversion failed when converting the nvarchar value 'lol' to data type int.
+    // 8152 - String or binary data would be truncated.
+    if (isCode(err, 16, 241) || isCode(err, 16, 242) || isCode(err, 16, 245) || isCode(err, 16, 8152)) {
+      return {};
+    } else {
+      return null;
+    }
+  },
+
+  subclassParsers: []
+};

lib/parsers/mssql/DBError/ForeignKeyViolationError/parser.js

@@ -0,0 +1,35 @@
+const ForeignKeyViolationError = require('../../../../errors/ForeignKeyViolationError');
+const { isCode } = require('../util');
+
+const INSERT_UPDATE_REGEX = /The (?:INSERT|UPDATE) statement conflicted with the FOREIGN KEY constraint "(.+)". The conflict occurred in database "(.+)", table "(.+)", column '(.+)'./;
+const DELETE_REGEX = /The DELETE statement conflicted with the REFERENCE constraint "(.+)". The conflict occurred in database "(.+)", table "(.+)", column '(.+)'./;
+
+module.exports = {
+  error: ForeignKeyViolationError,
+
+  parse: (err) => {
+    if (isCode(err, 16, 547)) {
+      const insertUpdateMatch = INSERT_UPDATE_REGEX.exec(err.originalError.message);
+
+      if (insertUpdateMatch) {
+        return {
+          table: insertUpdateMatch[3],
+          constraint: insertUpdateMatch[1],
+        };
+      }
+
+      const deleteMatch = DELETE_REGEX.exec(err.originalError.message);
+
+      if (deleteMatch) {
+        return {
+          table: deleteMatch[3],
+          constraint: deleteMatch[1],
+        };
+      }
+    }
+
+    return null;
+  },
+
+  subclassParsers: []
+};

lib/parsers/mssql/DBError/NotNullViolationError/parser.js

@@ -0,0 +1,27 @@
+const NotNullViolationError = require('../../../../errors/NotNullViolationError');
+const { isCode } = require('../util');
+
+const REGEX = /Cannot insert the value NULL into column '(.+)', table '(.+)'; column does not allow nulls. (?:INSERT|UPDATE) fails./;
+
+module.exports = {
+  error: NotNullViolationError,
+
+  parse: (err) => {
+    if (isCode(err, 16, 515)) {
+      const match = REGEX.exec(err.originalError.message);
+
+      if (!match) {
+        return null;
+      }
+
+      return {
+        table: match[2],
+        column: match[1],
+      };
+    } else {
+      return null;
+    }
+  },
+
+  subclassParsers: []
+};

lib/parsers/mssql/DBError/UniqueViolationError/parser.js

@@ -0,0 +1,45 @@
+const UniqueViolationError = require('../../../../errors/UniqueViolationError');
+const { isCode } = require('../util');
+
+const UNIQUE_INDEX_REGEX = /Cannot insert duplicate key row in object '(.+)' with unique index '(.+)'. The duplicate key value is (.+)./;
+const UNIQUE_CONSTRAINT_REGEX = /Violation of UNIQUE KEY constraint '(.+)'. Cannot insert duplicate key in object '(.+)'. The duplicate key value is \((.+)\)/;
+
+// 2601 - Violation in unique index
+// 2627 - Violation in unique constraint (although it is implemented using unique index)
+
+module.exports = {
+  error: UniqueViolationError,
+
+  parse: (err) => {
+    if (isCode(err, 14, 2627)) {
+      const constraintMatch = UNIQUE_CONSTRAINT_REGEX.exec(err.originalError.message);
+
+      if (!constraintMatch) {
+        return null;
+      }
+
+      return {
+        table: constraintMatch[2],
+        constraint: constraintMatch[1]
+      };
+    }
+
+    // TODO: this case is missing a test
+    if (isCode(err, 14, 2601)) {
+      const indexMatch = UNIQUE_INDEX_REGEX.exec(err.originalError.message);
+
+      if (!indexMatch) {
+        return null;
+      }
+
+      return {
+        table: indexMatch[1],
+        constraint: indexMatch[2]
+      };
+    }
+
+    return null;
+  },
+
+  subclassParsers: []
+};