Fixed ignored connection errors for mysql alpha 2.0 driver

joeferner · Jul 18, 2013 · 24cb276 · 24cb276
1 parent ce018cb
commit 24cb276
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/lib/drivers/mysql.js b/lib/drivers/mysql.js
@@ -96,16 +96,19 @@ var MySqlDriver = Driver.extend({
       var db;
       if (typeof(mysql.createConnection) === 'undefined') {
         db = new mysql.createClient(opts);
+        conn = new MySqlConnection(this, db, true, opts);
+        callback(null, conn);
       } else {
         db = new mysql.createConnection(opts);
         db.connect(function(err) {
           if (err) {
-            console.log(err);
+            callback(err);
+          } else {
+            conn = new MySqlConnection(this, db, true, opts);
+            callback(null, conn);
           }
         });
       }
-      conn = new MySqlConnection(this, db, true, opts);
-      callback(null, conn);
     }
   },