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); + } }); }