joepie91
/
node-database-error
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

ESLint autofixes

Browse Source
master
Sven Slootweg 4 years ago
parent abba82ad07
commit ccae979451
33 changed files with 543 additions and 543 deletions
Show Stats Download Patch File Download Diff File

2
gulpfile.js
Unescape Escape View File

@ -1,7 +1,7 @@
var gulp = require("gulp"); var gulp = require("gulp");
var presetES2015 = require("@joepie91/gulp-preset-es2015"); var presetES2015 = require("@joepie91/gulp-preset-es2015");
var source = ["src/**/*.js"] var source = ["src/**/*.js"];
gulp.task('babel', function() { gulp.task('babel', function() {
return gulp.src(source) return gulp.src(source)

88
src/errors/check-constraint-violation.js
Unescape Escape View File

@ -12,48 +12,48 @@ let CheckConstraintViolationError = create("CheckConstraintViolationError", { in
let messageRegex = /^(.+) - new row for relation "([^"]+)" violates check constraint "([^"]+)"$/; let messageRegex = /^(.+) - new row for relation "([^"]+)" violates check constraint "([^"]+)"$/;
module.exports = { module.exports = {
error: CheckConstraintViolationError, error: CheckConstraintViolationError,
errorName: "CheckConstraintViolationError", errorName: "CheckConstraintViolationError",
check: function checkType(error) { check: function checkType(error) {
return ( return (
// PostgreSQL (via `pg`): // PostgreSQL (via `pg`):
(error.length != null && error.file != null && error.line != null && error.routine != null && error.code === "23514") (error.length != null && error.file != null && error.line != null && error.routine != null && error.code === "23514")
) );
}, },
convert: function convertError(error) { convert: function convertError(error) {
let messageMatch = messageRegex.exec(error.message); let messageMatch = messageRegex.exec(error.message);
if (messageMatch == null) { if (messageMatch == null) {
throw new Error("Encountered unknown error format"); throw new Error("Encountered unknown error format");
} }
let [_, query, table, constraint] = messageMatch; let [_, query, table, constraint] = messageMatch;
let columns = getColumns(query); let columns = getColumns(query);
let offendingColumn, message; let offendingColumn, message;
if (columns != null) { if (columns != null) {
/* This is the naming convention that Knex uses for .enum() in PostgreSQL */ /* This is the naming convention that Knex uses for .enum() in PostgreSQL */
offendingColumn = columns.find(column => { offendingColumn = columns.find(column => {
return error.constraint === `${error.table}_${column}_check` return error.constraint === `${error.table}_${column}_check`;
}); });
message = `Value violates the '${error.constraint}' constraint for the '${offendingColumn}' column in the '${error.table}' table`; message = `Value violates the '${error.constraint}' constraint for the '${offendingColumn}' column in the '${error.table}' table`;
} else { } else {
message = `Value violates the '${error.constraint}' constraint for the '${error.table}' table`; message = `Value violates the '${error.constraint}' constraint for the '${error.table}' table`;
} }
return new CheckConstraintViolationError(message, { return new CheckConstraintViolationError(message, {
originalError: error, originalError: error,
pgCode: error.code, pgCode: error.code,
code: pgErrorCodes[error.code], code: pgErrorCodes[error.code],
query: query, query: query,
schema: error.schema, schema: error.schema,
table: error.table, table: error.table,
column: offendingColumn, column: offendingColumn,
constraint: error.constraint, constraint: error.constraint,
values: getValues(error.detail) values: getValues(error.detail)
}); });
} }
}; };

72
src/errors/enum.js
Unescape Escape View File

@ -11,40 +11,40 @@ let EnumError = create("EnumError", { inheritsFrom: DatabaseError });
let messageRegex = /^(.+) - invalid input value for enum ([^:]+): "([^"]+)"$/; let messageRegex = /^(.+) - invalid input value for enum ([^:]+): "([^"]+)"$/;
module.exports = { module.exports = {
error: EnumError, error: EnumError,
errorName: "EnumError", errorName: "EnumError",
check: function checkType(error) { check: function checkType(error) {
return ( return (
// PostgreSQL (via `pg`): // PostgreSQL (via `pg`):
(error.length != null && error.file != null && error.line != null && error.routine != null && error.code === "22P02" && error.message.includes("invalid input value for enum")) (error.length != null && error.file != null && error.line != null && error.routine != null && error.code === "22P02" && error.message.includes("invalid input value for enum"))
) );
}, },
convert: function convertError(error) { convert: function convertError(error) {
let messageMatch = messageRegex.exec(error.message); let messageMatch = messageRegex.exec(error.message);
if (messageMatch == null) { if (messageMatch == null) {
throw new Error("Encountered unknown error format"); throw new Error("Encountered unknown error format");
} }
let [_, query, enumType, value] = messageMatch; let [_, query, enumType, value] = messageMatch;
let table = getTable(query); let table = getTable(query);
let message; let message;
if (table != null) { if (table != null) {
message = `Value '${value}' is not an allowed value for the ENUM type '${enumType}' (in table '${table}')`; message = `Value '${value}' is not an allowed value for the ENUM type '${enumType}' (in table '${table}')`;
} else { } else {
message = `Value '${value}' is not an allowed value for the ENUM type '${enumType}'`; message = `Value '${value}' is not an allowed value for the ENUM type '${enumType}'`;
} }
return new EnumError(message, { return new EnumError(message, {
originalError: error, originalError: error,
pgCode: error.code, pgCode: error.code,
code: pgErrorCodes[error.code], code: pgErrorCodes[error.code],
query: query, query: query,
table: table, table: table,
enumType: enumType, enumType: enumType,
value: value value: value
}); });
} }
}; };

44
src/errors/foreign-key-constraint-violation.js
Unescape Escape View File

@ -9,27 +9,27 @@ let ForeignKeyConstraintViolationError = create("ForeignKeyConstraintViolationEr
let detailsRegex = /^Key \(([^\)]+)\)=\(([^\)]+)\) is not present in table "([^"]+)"\.$/; let detailsRegex = /^Key \(([^\)]+)\)=\(([^\)]+)\) is not present in table "([^"]+)"\.$/;
module.exports = { module.exports = {
error: ForeignKeyConstraintViolationError, error: ForeignKeyConstraintViolationError,
errorName: "ForeignKeyConstraintViolationError", errorName: "ForeignKeyConstraintViolationError",
check: function checkType(error) { check: function checkType(error) {
return ( return (
// PostgreSQL (via `pg`): // PostgreSQL (via `pg`):
(error.length != null && error.file != null && error.line != null && error.routine != null && error.code === "23503") (error.length != null && error.file != null && error.line != null && error.routine != null && error.code === "23503")
) );
}, },
convert: function convertError(error) { convert: function convertError(error) {
let [_, column, value, foreignTable] = detailsRegex.exec(error.detail); let [_, column, value, foreignTable] = detailsRegex.exec(error.detail);
return new ForeignKeyConstraintViolationError(`Value for column '${column}' in table '${error.table}' refers to a non-existent key '${value}' in table '${foreignTable}'`, { return new ForeignKeyConstraintViolationError(`Value for column '${column}' in table '${error.table}' refers to a non-existent key '${value}' in table '${foreignTable}'`, {
originalError: error, originalError: error,
pgCode: error.code, pgCode: error.code,
code: pgErrorCodes[error.code], code: pgErrorCodes[error.code],
schema: error.schema, schema: error.schema,
table: error.table, table: error.table,
foreignTable: foreignTable, foreignTable: foreignTable,
column: column, column: column,
value: value, value: value,
constraint: error.constraint constraint: error.constraint
}); });
} }
}; };

76
src/errors/invalid-type.js
Unescape Escape View File

@ -12,42 +12,42 @@ let InvalidTypeError = create("InvalidTypeError", { inheritsFrom: DatabaseError
let messageRegex = /^(?:(.+) - )?invalid input syntax for(?: type)? ([^:]+)(?:: "(.+)")?$/; let messageRegex = /^(?:(.+) - )?invalid input syntax for(?: type)? ([^:]+)(?:: "(.+)")?$/;
module.exports = { module.exports = {
error: InvalidTypeError, error: InvalidTypeError,
errorName: "InvalidTypeError", errorName: "InvalidTypeError",
check: function checkType(error) { check: function checkType(error) {
return ( return (
// PostgreSQL (via `pg`): // PostgreSQL (via `pg`):
(error.length != null && error.file != null && error.line != null && error.routine != null && error.code === "22P02" && error.message.includes("invalid input syntax for")) (error.length != null && error.file != null && error.line != null && error.routine != null && error.code === "22P02" && error.message.includes("invalid input syntax for"))
) );
}, },
convert: function convertError(error) { convert: function convertError(error) {
let messageMatch = messageRegex.exec(error.message); let messageMatch = messageRegex.exec(error.message);
if (messageMatch == null) { if (messageMatch == null) {
/* TODO: Update other error parsing modules to display the original error message here as well. */ /* TODO: Update other error parsing modules to display the original error message here as well. */
throw new Error(`Encountered unknown error format for error message: ${error.message}`); throw new Error(`Encountered unknown error format for error message: ${error.message}`);
} }
let [_, query, expectedType, value] = messageMatch; let [_, query, expectedType, value] = messageMatch;
let table = getTable(query); let table = getTable(query);
let message; let message;
/* TODO: `value` can be undefined! */ /* TODO: `value` can be undefined! */
if (table != null) { if (table != null) {
message = `Value <${value}> is of the wrong type for a '${expectedType}'-type column (in table '${table}')`; message = `Value <${value}> is of the wrong type for a '${expectedType}'-type column (in table '${table}')`;
} else { } else {
message = `Value <${value}> is of the wrong type for a '${expectedType}'-type column`; message = `Value <${value}> is of the wrong type for a '${expectedType}'-type column`;
} }
return new InvalidTypeError(message, { return new InvalidTypeError(message, {
originalError: error, originalError: error,
pgCode: error.code, pgCode: error.code,
code: pgErrorCodes[error.code], code: pgErrorCodes[error.code],
query: query, query: query,
table: table, table: table,
expectedType: expectedType, expectedType: expectedType,
value: value, value: value,
}); });
} }
}; };

42
src/errors/not-null-constraint-violation.js
Unescape Escape View File

@ -11,26 +11,26 @@ let NotNullConstraintViolationError = create(DatabaseError, "NotNullConstraintVi
let messageRegex = /^(.+) - null value in column "([^"]+)" violates not-null constraint$/; let messageRegex = /^(.+) - null value in column "([^"]+)" violates not-null constraint$/;
module.exports = { module.exports = {
error: NotNullConstraintViolationError, error: NotNullConstraintViolationError,
errorName: "NotNullConstraintViolationError", errorName: "NotNullConstraintViolationError",
check: function checkType(error) { check: function checkType(error) {
return ( return (
// PostgreSQL (via `pg`): // PostgreSQL (via `pg`):
(error.length != null && error.file != null && error.line != null && error.routine != null && error.code === "23502") (error.length != null && error.file != null && error.line != null && error.routine != null && error.code === "23502")
) );
}, },
convert: function convertError(error) { convert: function convertError(error) {
let [_, query, column] = messageRegex.exec(error.message); let [_, query, column] = messageRegex.exec(error.message);
return new NotNullConstraintViolationError(`Missing required value for column '${error.column}' in table '${error.table}'`, { return new NotNullConstraintViolationError(`Missing required value for column '${error.column}' in table '${error.table}'`, {
originalError: error, originalError: error,
pgCode: error.code, pgCode: error.code,
code: pgErrorCodes[error.code], code: pgErrorCodes[error.code],
schema: error.schema, schema: error.schema,
table: error.table, table: error.table,
column: error.column, column: error.column,
values: getValues(error.detail), values: getValues(error.detail),
query: query query: query
}); });
} }
}; };

70
src/errors/undefined-column.js
Unescape Escape View File

@ -11,39 +11,39 @@ let UndefinedColumnError = create("UndefinedColumnError", { inheritsFrom: Databa
let messageRegex = /^(.+) - column "([^"]+)" (?:of relation "([^"]+)" )?does not exist$/; let messageRegex = /^(.+) - column "([^"]+)" (?:of relation "([^"]+)" )?does not exist$/;
module.exports = { module.exports = {
error: UndefinedColumnError, error: UndefinedColumnError,
errorName: "UndefinedColumnError", errorName: "UndefinedColumnError",
check: function checkType(error) { check: function checkType(error) {
return ( return (
// PostgreSQL (via `pg`): // PostgreSQL (via `pg`):
(error.length != null && error.file != null && error.line != null && error.routine != null && error.code === "42703") (error.length != null && error.file != null && error.line != null && error.routine != null && error.code === "42703")
) );
}, },
convert: function convertError(error) { convert: function convertError(error) {
let messageMatch = messageRegex.exec(error.message); let messageMatch = messageRegex.exec(error.message);
if (messageMatch == null) { if (messageMatch == null) {
throw new Error("Encountered unknown error format"); throw new Error("Encountered unknown error format");
} }
let [_, query, column, table] = messageMatch; let [_, query, column, table] = messageMatch;
let errorMessage; let errorMessage;
if (table != null) { if (table != null) {
errorMessage = `The '${column}' column does not exist in the '${table}' table`; errorMessage = `The '${column}' column does not exist in the '${table}' table`;
} else { } else {
/* TODO: Maybe try to extract this from the query... somehow? */ /* TODO: Maybe try to extract this from the query... somehow? */
errorMessage = `The '${column}' column does not exist in (unknown table)`; errorMessage = `The '${column}' column does not exist in (unknown table)`;
} }
return new UndefinedColumnError(errorMessage, { return new UndefinedColumnError(errorMessage, {
originalError: error, originalError: error,
pgCode: error.code, pgCode: error.code,
code: pgErrorCodes[error.code], code: pgErrorCodes[error.code],
query: query, query: query,
table: table, table: table,
column: column, column: column,
}); });
} }
}; };

90
src/errors/unique-constraint-violation.js
Unescape Escape View File

@ -10,49 +10,49 @@ let UniqueConstraintViolationError = create("UniqueConstraintViolationError", {
let detailsRegex = /Key \(([^\)]+)\)=\(([^\)]+)\) already exists\./; let detailsRegex = /Key \(([^\)]+)\)=\(([^\)]+)\) already exists\./;
module.exports = { module.exports = {
error: UniqueConstraintViolationError, error: UniqueConstraintViolationError,
errorName: "UniqueConstraintViolationError", errorName: "UniqueConstraintViolationError",
check: function checkType(error) { check: function checkType(error) {
return ( return (
// PostgreSQL (via `pg`): // PostgreSQL (via `pg`):
(error.length != null && error.file != null && error.line != null && error.routine != null && error.code === "23505") (error.length != null && error.file != null && error.line != null && error.routine != null && error.code === "23505")
) );
}, },
convert: function convertError(error) { convert: function convertError(error) {
let [_, columnValue, valueValue] = detailsRegex.exec(error.detail); let [_, columnValue, valueValue] = detailsRegex.exec(error.detail);
let column, columns, value, values, messageColumn, messageValue, isComposite; let column, columns, value, values, messageColumn, messageValue, isComposite;
if (columnValue.includes(",")) { if (columnValue.includes(",")) {
columns = splitValues(columnValue); columns = splitValues(columnValue);
messageColumn = `columns [${columns.map(column => `'${column}'`).join(", ")}]`; messageColumn = `columns [${columns.map(column => `'${column}'`).join(", ")}]`;
isComposite = true; isComposite = true;
} else { } else {
column = columnValue; column = columnValue;
messageColumn = `column '${column}'`; messageColumn = `column '${column}'`;
isComposite = false; isComposite = false;
} }
if (valueValue.includes(",")) { if (valueValue.includes(",")) {
values = splitValues(valueValue); values = splitValues(valueValue);
messageValue = `Values [${values.map(value => `'${value}'`).join(", ")}] already exist`; messageValue = `Values [${values.map(value => `'${value}'`).join(", ")}] already exist`;
} else { } else {
value = valueValue; value = valueValue;
messageValue = `Value '${value}' already exists`; messageValue = `Value '${value}' already exists`;
} }
return new UniqueConstraintViolationError(`${messageValue} for ${messageColumn} in table '${error.table}'`, { return new UniqueConstraintViolationError(`${messageValue} for ${messageColumn} in table '${error.table}'`, {
originalError: error, originalError: error,
pgCode: error.code, pgCode: error.code,
code: pgErrorCodes[error.code], code: pgErrorCodes[error.code],
schema: error.schema, schema: error.schema,
table: error.table, table: error.table,
column: column, column: column,
columns: columns, columns: columns,
value: value, value: value,
values: values, values: values,
isComposite: isComposite, isComposite: isComposite,
constraint: error.constraint constraint: error.constraint
}); });
} }
}; };

20
src/get-columns.js
Unescape Escape View File

@ -5,15 +5,15 @@ let updateRegex = /^update "[^"]+" set (.+) where/;
let updateColumnRegex = /^"([^"]+)"/; let updateColumnRegex = /^"([^"]+)"/;
module.exports = function getColumns(query) { module.exports = function getColumns(query) {
let match, columns; let match, columns;
if (match = insertRegex.exec(query)) { if (match = insertRegex.exec(query)) {
return match[1].split(",").map((columnName) => { return match[1].split(",").map((columnName) => {
return columnName.trim().slice(1, -1) return columnName.trim().slice(1, -1);
}); });
} else if (match = updateRegex.exec(query)) { } else if (match = updateRegex.exec(query)) {
return match[1].split(",").map((statement) => { return match[1].split(",").map((statement) => {
return updateColumnRegex.exec(statement.trim())[1]; return updateColumnRegex.exec(statement.trim())[1];
}); });
} }
}; };

12
src/get-table.js
Unescape Escape View File

@ -4,11 +4,11 @@ let insertRegex = /^insert into "([^"]+)"/;
let updateRegex = /^update "([^"]+)"/; let updateRegex = /^update "([^"]+)"/;
module.exports = function getTable(query) { module.exports = function getTable(query) {
let match; let match;
if (match = insertRegex.exec(query)) { if (match = insertRegex.exec(query)) {
return match[1]; return match[1];
} else if (match = updateRegex.exec(query)) { } else if (match = updateRegex.exec(query)) {
return match[1]; return match[1];
} }
}; };

12
src/get-values.js
Unescape Escape View File

@ -3,13 +3,13 @@
let detailsRegex = /^Failing row contains \((.+)\).$/; let detailsRegex = /^Failing row contains \((.+)\).$/;
module.exports = function getValues(detail) { module.exports = function getValues(detail) {
let detailsMatch = detailsRegex.exec(detail); let detailsMatch = detailsRegex.exec(detail);
if (detailsMatch == null) { if (detailsMatch == null) {
throw new Error("Could not determine values for query"); throw new Error("Could not determine values for query");
} }
let [_, valueList] = detailsMatch; let [_, valueList] = detailsMatch;
return valueList.split(", "); return valueList.split(", ");
}; };

6
src/index.js
Unescape Escape View File

@ -15,13 +15,13 @@ let handlers = [
require("./errors/invalid-type"), require("./errors/invalid-type"),
require("./errors/undefined-column"), require("./errors/undefined-column"),
require("./errors/not-null-constraint-violation"), require("./errors/not-null-constraint-violation"),
] ];
function convertError(error) { function convertError(error) {
let handler = handlers.find(handler => handler.check(error)); let handler = handlers.find(handler => handler.check(error));
if (handler != null) { if (handler != null) {
debug(`Converting error with message: ${error.message}`) debug(`Converting error with message: ${error.message}`);
return handler.convert(error); return handler.convert(error);
} else { } else {
throw new UnknownError("The specified error is not of a recognized type"); throw new UnknownError("The specified error is not of a recognized type");
@ -51,4 +51,4 @@ module.exports = Object.assign({
rethrow: rethrowBetterError, rethrow: rethrowBetterError,
UnknownError: UnknownError, UnknownError: UnknownError,
DatabaseError: DatabaseError DatabaseError: DatabaseError
}, errorTypes) }, errorTypes);

20
test/create-tables/check-constraint-violation.js
Unescape Escape View File

@ -3,14 +3,14 @@
const Promise = require("bluebird"); const Promise = require("bluebird");
module.exports = { module.exports = {
up: function createCheckConstraintViolationTable(knex, errorHandler) { up: function createCheckConstraintViolationTable(knex, errorHandler) {
return knex.schema.createTable("check_constraint_violation", (table) => { return knex.schema.createTable("check_constraint_violation", (table) => {
table.increments("id"); table.increments("id");
table.enum("number_value", ["one", "two", "three"]); table.enum("number_value", ["one", "two", "three"]);
table.text("name"); table.text("name");
}).catch(errorHandler); }).catch(errorHandler);
}, },
down: function dropCheckConstraintViolationTable(knex, errorHandler) { down: function dropCheckConstraintViolationTable(knex, errorHandler) {
return knex.schema.dropTable("check_constraint_violation").catch(errorHandler); return knex.schema.dropTable("check_constraint_violation").catch(errorHandler);
} }
}; };

24
test/create-tables/composite-unique-constraint-violation.js
Unescape Escape View File

@ -1,16 +1,16 @@
'use strict'; 'use strict';
module.exports = { module.exports = {
up: function createUniqueConstraintViolationTable(knex, errorHandler) { up: function createUniqueConstraintViolationTable(knex, errorHandler) {
return knex.schema.createTable("composite_unique_constraint_violation", (table) => { return knex.schema.createTable("composite_unique_constraint_violation", (table) => {
table.increments("id"); table.increments("id");
table.text("email"); table.text("email");
table.text("username"); table.text("username");
table.text("name"); table.text("name");
table.unique(["email", "username"]); table.unique(["email", "username"]);
}).catch(errorHandler); }).catch(errorHandler);
}, },
down: function dropUniqueConstraintViolationTable(knex, errorHandler) { down: function dropUniqueConstraintViolationTable(knex, errorHandler) {
return knex.schema.dropTable("composite_unique_constraint_violation").catch(errorHandler); return knex.schema.dropTable("composite_unique_constraint_violation").catch(errorHandler);
} }
}; };

36
test/create-tables/enum.js
Unescape Escape View File

@ -3,22 +3,22 @@
const Promise = require("bluebird"); const Promise = require("bluebird");
module.exports = { module.exports = {
up: function createEnumViolationTable(knex, errorHandler) { up: function createEnumViolationTable(knex, errorHandler) {
return Promise.try(() => { return Promise.try(() => {
return knex.raw("CREATE TYPE number AS ENUM ('one', 'two', 'three')").catch(errorHandler); return knex.raw("CREATE TYPE number AS ENUM ('one', 'two', 'three')").catch(errorHandler);
}).then(() => { }).then(() => {
return knex.schema.createTable("enum_violation", (table) => { return knex.schema.createTable("enum_violation", (table) => {
table.increments("id"); table.increments("id");
table.specificType("number_value", "number"); table.specificType("number_value", "number");
table.text("name"); table.text("name");
}).catch(errorHandler); }).catch(errorHandler);
}); });
}, },
down: function dropEnumViolationTable(knex, errorHandler) { down: function dropEnumViolationTable(knex, errorHandler) {
return Promise.try(() => { return Promise.try(() => {
return knex.schema.dropTable("enum_violation").catch(errorHandler); return knex.schema.dropTable("enum_violation").catch(errorHandler);
}).then(() => { }).then(() => {
return knex.raw("DROP TYPE number").catch(errorHandler); return knex.raw("DROP TYPE number").catch(errorHandler);
}); });
} }
}; };

44
test/create-tables/foreign-key-constraint-violation.js
Unescape Escape View File

@ -3,26 +3,26 @@
const Promise = require("bluebird"); const Promise = require("bluebird");
module.exports = { module.exports = {
up: function createForeignKeyConstraintViolationTable(knex, errorHandler) { up: function createForeignKeyConstraintViolationTable(knex, errorHandler) {
return Promise.try(() => { return Promise.try(() => {
return knex.schema.createTable("foreign_key_constraint_users", (table) => { return knex.schema.createTable("foreign_key_constraint_users", (table) => {
table.increments("id"); table.increments("id");
table.text("username"); table.text("username");
table.text("name"); table.text("name");
}).catch(errorHandler); }).catch(errorHandler);
}).then(() => { }).then(() => {
return knex.schema.createTable("foreign_key_constraint_posts", (table) => { return knex.schema.createTable("foreign_key_constraint_posts", (table) => {
table.increments("id"); table.increments("id");
table.integer("user_id").references("id").inTable("foreign_key_constraint_users"); table.integer("user_id").references("id").inTable("foreign_key_constraint_users");
table.text("body"); table.text("body");
}).catch(errorHandler); }).catch(errorHandler);
}); });
}, },
down: function dropForeignKeyConstraintViolationTable(knex, errorHandler) { down: function dropForeignKeyConstraintViolationTable(knex, errorHandler) {
return Promise.try(() => { return Promise.try(() => {
return knex.schema.dropTable("foreign_key_constraint_posts").catch(errorHandler); return knex.schema.dropTable("foreign_key_constraint_posts").catch(errorHandler);
}).then(() => { }).then(() => {
return knex.schema.dropTable("foreign_key_constraint_users").catch(errorHandler); return knex.schema.dropTable("foreign_key_constraint_users").catch(errorHandler);
}); });
} }
}; };

56
test/create-tables/index.js
Unescape Escape View File

@ -3,40 +3,40 @@
const Promise = require("bluebird"); const Promise = require("bluebird");
let tables = [ let tables = [
require("./unique-constraint-violation"), require("./unique-constraint-violation"),
require("./composite-unique-constraint-violation"), require("./composite-unique-constraint-violation"),
require("./check-constraint-violation"), require("./check-constraint-violation"),
require("./foreign-key-constraint-violation"), require("./foreign-key-constraint-violation"),
require("./enum"), require("./enum"),
require("./invalid-type"), require("./invalid-type"),
require("./not-null-constraint-violation") require("./not-null-constraint-violation")
]; ];
let noop = function noop(err) { let noop = function noop(err) {
// Do nothing. // Do nothing.
} };
let rethrow = function rethrowError(err) { let rethrow = function rethrowError(err) {
throw err; throw err;
} };
module.exports = { module.exports = {
up: function createTables(knex) { up: function createTables(knex) {
return Promise.map(tables, (table) => { return Promise.map(tables, (table) => {
return table.up(knex, rethrow); return table.up(knex, rethrow);
}); });
}, },
down: function dropTables(knex, ignoreErrors) { down: function dropTables(knex, ignoreErrors) {
let errorHandler; let errorHandler;
if (ignoreErrors) { if (ignoreErrors) {
errorHandler = noop; errorHandler = noop;
} else { } else {
errorHandler = rethrow; errorHandler = rethrow;
} }
return Promise.map(tables, (table) => { return Promise.map(tables, (table) => {
return table.down(knex, errorHandler); return table.down(knex, errorHandler);
}); });
} }
} };

22
test/create-tables/invalid-type.js
Unescape Escape View File

@ -1,15 +1,15 @@
'use strict'; 'use strict';
module.exports = { module.exports = {
up: function createInvalidTypeTable(knex, errorHandler) { up: function createInvalidTypeTable(knex, errorHandler) {
return knex.schema.createTable("invalid_type", (table) => { return knex.schema.createTable("invalid_type", (table) => {
table.increments("id"); table.increments("id");
table.integer("age"); table.integer("age");
table.text("name"); table.text("name");
table.boolean("active"); table.boolean("active");
}).catch(errorHandler); }).catch(errorHandler);
}, },
down: function dropInvalidTypeTable(knex, errorHandler) { down: function dropInvalidTypeTable(knex, errorHandler) {
return knex.schema.dropTable("invalid_type").catch(errorHandler); return knex.schema.dropTable("invalid_type").catch(errorHandler);
} }
}; };

20
test/create-tables/not-null-constraint-violation.js
Unescape Escape View File

@ -1,14 +1,14 @@
'use strict'; 'use strict';
module.exports = { module.exports = {
up: function createNotNullConstraintViolationTable(knex, errorHandler) { up: function createNotNullConstraintViolationTable(knex, errorHandler) {
return knex.schema.createTable("not_null_violation", (table) => { return knex.schema.createTable("not_null_violation", (table) => {
table.increments("id"); table.increments("id");
table.text("email").notNull(); table.text("email").notNull();
table.text("name"); table.text("name");
}).catch(errorHandler); }).catch(errorHandler);
}, },
down: function dropNotNullConstraintViolationTable(knex, errorHandler) { down: function dropNotNullConstraintViolationTable(knex, errorHandler) {
return knex.schema.dropTable("not_null_violation").catch(errorHandler); return knex.schema.dropTable("not_null_violation").catch(errorHandler);
} }
}; };

20
test/create-tables/unique-constraint-violation.js
Unescape Escape View File

@ -1,14 +1,14 @@
'use strict'; 'use strict';
module.exports = { module.exports = {
up: function createUniqueConstraintViolationTable(knex, errorHandler) { up: function createUniqueConstraintViolationTable(knex, errorHandler) {
return knex.schema.createTable("unique_constraint_violation", (table) => { return knex.schema.createTable("unique_constraint_violation", (table) => {
table.increments("id"); table.increments("id");
table.text("email").unique(); table.text("email").unique();
table.text("name"); table.text("name");
}).catch(errorHandler); }).catch(errorHandler);
}, },
down: function dropUniqueConstraintViolationTable(knex, errorHandler) { down: function dropUniqueConstraintViolationTable(knex, errorHandler) {
return knex.schema.dropTable("unique_constraint_violation").catch(errorHandler); return knex.schema.dropTable("unique_constraint_violation").catch(errorHandler);
} }
}; };

34
test/test.js
Unescape Escape View File

@ -10,29 +10,29 @@ const path = require("path");
const createTables = require("./create-tables"); const createTables = require("./create-tables");
let db = knex({ let db = knex({
client: "pg", client: "pg",
connection: { connection: {
host: "localhost", host: "localhost",
user: "sven", user: "sven",
password: "password", password: "password",
database: "database_error" database: "database_error"
}, },
debug: true debug: true
}); });
return Promise.try(() => { return Promise.try(() => {
return createTables.down(db, true); return createTables.down(db, true);
}).then(() => { }).then(() => {
return createTables.up(db); return createTables.up(db);
}).then(() => { }).then(() => {
let testcase = require(path.join(process.cwd(), process.argv[2])); let testcase = require(path.join(process.cwd(), process.argv[2]));
return testcase(db); return testcase(db);
}).catch(databaseError.rethrow).catch((err) => { }).catch(databaseError.rethrow).catch((err) => {
console.log("__________________\n"); console.log("__________________\n");
console.error(util.inspect(err, {colors: true, depth: 1})); console.error(util.inspect(err, {colors: true, depth: 1}));
console.log("__________________\n"); console.log("__________________\n");
}).finally(() => { }).finally(() => {
return createTables.down(db); return createTables.down(db);
}).finally(() => { }).finally(() => {
return db.destroy(); return db.destroy();
}); });

14
test/testcase/check-constraint-violation-insert.js
Unescape Escape View File

@ -1,11 +1,11 @@
'use strict'; 'use strict';
module.exports = function attemptCheckConstraintViolation(knex) { module.exports = function attemptCheckConstraintViolation(knex) {
return knex("check_constraint_violation").insert([{ return knex("check_constraint_violation").insert([{
number_value: "one", number_value: "one",
name: "Joe" name: "Joe"
}, { }, {
number_value: "four", number_value: "four",
name: "Jane" name: "Jane"
}]).returning("*"); }]).returning("*");
}; };

24
test/testcase/check-constraint-violation-update.js
Unescape Escape View File

@ -3,16 +3,16 @@
const Promise = require("bluebird"); const Promise = require("bluebird");
module.exports = function attemptCheckConstraintViolation(knex) { module.exports = function attemptCheckConstraintViolation(knex) {
return Promise.try(() => { return Promise.try(() => {
return knex("check_constraint_violation").insert({ return knex("check_constraint_violation").insert({
number_value: "one", number_value: "one",
name: "Joe" name: "Joe"
}).returning("id"); }).returning("id");
}).then((id) => { }).then((id) => {
return knex("check_constraint_violation").update({ return knex("check_constraint_violation").update({
number_value: "four" number_value: "four"
}).where({ }).where({
id: id[0] id: id[0]
}); });
}); });
}; };

34
test/testcase/composite-unique-constraint-violation.js
Unescape Escape View File

@ -1,21 +1,21 @@
'use strict'; 'use strict';
module.exports = function attemptCompositeUniqueConstraintViolation(knex) { module.exports = function attemptCompositeUniqueConstraintViolation(knex) {
return knex("composite_unique_constraint_violation").insert([{ return knex("composite_unique_constraint_violation").insert([{
email: "foo@bar.com", email: "foo@bar.com",
username: "foo", username: "foo",
name: "Joe" name: "Joe"
}, { }, {
email: "baz@qux.com", email: "baz@qux.com",
username: "bar", username: "bar",
name: "Jane" name: "Jane"
}, { }, {
email: "foo@bar.com", email: "foo@bar.com",
username: "baz", username: "baz",
name: "Pete" name: "Pete"
}, { }, {
email: "foo@bar.com", email: "foo@bar.com",
username: "foo", username: "foo",
name: "Jill" name: "Jill"
}]).returning("*"); }]).returning("*");
}; };

14
test/testcase/enum-insert.js
Unescape Escape View File

@ -1,11 +1,11 @@
'use strict'; 'use strict';
module.exports = function attemptEnumViolation(knex) { module.exports = function attemptEnumViolation(knex) {
return knex("enum_violation").insert([{ return knex("enum_violation").insert([{
number_value: "one", number_value: "one",
name: "Joe" name: "Joe"
}, { }, {
number_value: "four", number_value: "four",
name: "Jane" name: "Jane"
}]).returning("*"); }]).returning("*");
}; };

24
test/testcase/enum-update.js
Unescape Escape View File

@ -3,16 +3,16 @@
const Promise = require("bluebird"); const Promise = require("bluebird");
module.exports = function attemptEnumViolation(knex) { module.exports = function attemptEnumViolation(knex) {
return Promise.try(() => { return Promise.try(() => {
return knex("enum_violation").insert({ return knex("enum_violation").insert({
number_value: "one", number_value: "one",
name: "Joe" name: "Joe"
}).returning("id"); }).returning("id");
}).then((id) => { }).then((id) => {
return knex("enum_violation").update({ return knex("enum_violation").update({
number_value: "four" number_value: "four"
}).where({ }).where({
id: id[0] id: id[0]
}); });
}); });
}; };

40
test/testcase/foreign-key-constraint-violation.js
Unescape Escape View File

@ -3,24 +3,24 @@
const Promise = require("bluebird"); const Promise = require("bluebird");
module.exports = function attemptForeignKeyConstraintViolation(knex) { module.exports = function attemptForeignKeyConstraintViolation(knex) {
return Promise.try(() => { return Promise.try(() => {
return knex("foreign_key_constraint_users").insert([{ return knex("foreign_key_constraint_users").insert([{
name: "Joe", name: "Joe",
username: "joe" username: "joe"
}, { }, {
name: "Jane", name: "Jane",
username: "jane" username: "jane"
}]).returning("id"); }]).returning("id");
}).then((ids) => { }).then((ids) => {
return knex("foreign_key_constraint_posts").insert([{ return knex("foreign_key_constraint_posts").insert([{
user_id: ids[0], user_id: ids[0],
body: "Foo" body: "Foo"
}, { }, {
user_id: ids[1], user_id: ids[1],
body: "Bar" body: "Bar"
}, { }, {
user_id: 567213, user_id: 567213,
body: "Baz" body: "Baz"
}]) }]);
}); });
}; };

26
test/testcase/invalid-type-boolean-inverse.js
Unescape Escape View File

@ -1,17 +1,17 @@
'use strict'; 'use strict';
module.exports = function attemptInvalidTypeBooleanInverse(knex) { module.exports = function attemptInvalidTypeBooleanInverse(knex) {
return knex("invalid_type").insert([{ return knex("invalid_type").insert([{
name: "Joe", name: "Joe",
age: 29, age: 29,
active: true active: true
}, { }, {
name: "Jane", name: "Jane",
age: 42, age: 42,
active: true active: true
}, { }, {
name: true, name: true,
age: 24, age: 24,
active: false active: false
}]).returning("*"); }]).returning("*");
}; };

26
test/testcase/invalid-type-boolean.js
Unescape Escape View File

@ -1,17 +1,17 @@
'use strict'; 'use strict';
module.exports = function attemptInvalidTypeBoolean(knex) { module.exports = function attemptInvalidTypeBoolean(knex) {
return knex("invalid_type").insert([{ return knex("invalid_type").insert([{
name: "Joe", name: "Joe",
age: 29, age: 29,
active: true active: true
}, { }, {
name: "Jane", name: "Jane",
age: 42, age: 42,
active: true active: true
}, { }, {
name: "Pete", name: "Pete",
age: 24, age: 24,
active: "foo bar" active: "foo bar"
}]).returning("*"); }]).returning("*");
}; };

26
test/testcase/invalid-type-integer.js
Unescape Escape View File

@ -1,17 +1,17 @@
'use strict'; 'use strict';
module.exports = function attemptInvalidTypeInteger(knex) { module.exports = function attemptInvalidTypeInteger(knex) {
return knex("invalid_type").insert([{ return knex("invalid_type").insert([{
name: "Joe", name: "Joe",
age: 29, age: 29,
active: true active: true
}, { }, {
name: "Jane", name: "Jane",
age: 42, age: 42,
active: true active: true
}, { }, {
name: "Pete", name: "Pete",
age: "twenty-four", age: "twenty-four",
active: false active: false
}]).returning("*"); }]).returning("*");
}; };

16
test/testcase/not-null-constraint-violation.js
Unescape Escape View File

@ -1,12 +1,12 @@
'use strict'; 'use strict';
module.exports = function attemptNotNullConstraintViolation(knex) { module.exports = function attemptNotNullConstraintViolation(knex) {
return knex("not_null_violation").insert([{ return knex("not_null_violation").insert([{
email: "foo@bar.com", email: "foo@bar.com",
name: "Joe" name: "Joe"
}, { }, {
email: "baz@qux.com" email: "baz@qux.com"
}, { }, {
name: "Pete" name: "Pete"
}]).returning("*"); }]).returning("*");
}; };

12
test/testcase/undefined-column.js
Unescape Escape View File

@ -1,10 +1,10 @@
'use strict'; 'use strict';
module.exports = function attemptUndefinedColumn(knex) { module.exports = function attemptUndefinedColumn(knex) {
return knex("invalid_type").insert([{ return knex("invalid_type").insert([{
name: "Joe", name: "Joe",
age: 29, age: 29,
active: true, active: true,
nonexistentColumn: "Hello!" nonexistentColumn: "Hello!"
}]).returning("*"); }]).returning("*");
}; };

20
test/testcase/unique-constraint-violation.js
Unescape Escape View File

@ -1,14 +1,14 @@
'use strict'; 'use strict';
module.exports = function attemptUniqueConstraintViolation(knex) { module.exports = function attemptUniqueConstraintViolation(knex) {
return knex("unique_constraint_violation").insert([{ return knex("unique_constraint_violation").insert([{
email: "foo@bar.com", email: "foo@bar.com",
name: "Joe" name: "Joe"
}, { }, {
email: "baz@qux.com", email: "baz@qux.com",
name: "Jane" name: "Jane"
}, { }, {
email: "foo@bar.com", email: "foo@bar.com",
name: "Pete" name: "Pete"
}]).returning("*"); }]).returning("*");
}; };

Write Preview
Loading…
Cancel
Save