From 29bc4d4574e2eead51a52fa52a575a03b252a28f Mon Sep 17 00:00:00 2001 From: Timothy J Warren Date: Fri, 11 Mar 2016 13:41:33 -0500 Subject: [PATCH] Try to gum up the works on connection errors --- lib/adapters/Firebird.js | 4 ++++ lib/adapters/Mysql.js | 6 +++++- lib/adapters/Pg.js | 4 ++++ 3 files changed, 13 insertions(+), 1 deletion(-) diff --git a/lib/adapters/Firebird.js b/lib/adapters/Firebird.js index f2a1ef3..480893f 100644 --- a/lib/adapters/Firebird.js +++ b/lib/adapters/Firebird.js @@ -10,6 +10,10 @@ class Firebird extends Adapter { super({}); fb.attach(config, (err, instance) => { this.instance = instance; + + if (err) { + throw new Error(err); + } }); } diff --git a/lib/adapters/Mysql.js b/lib/adapters/Mysql.js index a81a690..dc0e2ae 100644 --- a/lib/adapters/Mysql.js +++ b/lib/adapters/Mysql.js @@ -9,7 +9,11 @@ class Mysql extends Adapter { constructor(config) { let instance = mysql2.createConnection(config); - instance.connect(); + instance.connect(err => { + if (err) { + throw new Error(err); + } + }); super(instance); } diff --git a/lib/adapters/Pg.js b/lib/adapters/Pg.js index 5dfb962..aece7ac 100644 --- a/lib/adapters/Pg.js +++ b/lib/adapters/Pg.js @@ -36,6 +36,10 @@ class Pg extends Adapter { instance.connect(err => { connected = true; + + if (err) { + throw new Error(err); + } }); }