diff --git a/browserid/lib/db_mysql.js b/browserid/lib/db_mysql.js
index 1fb2fd8ce2e2f72a778d08b669ecc99bd09b73bd..4bcb8d52e23cdf27b86a1791208600b80cec203f 100644
--- a/browserid/lib/db_mysql.js
+++ b/browserid/lib/db_mysql.js
@@ -111,44 +111,37 @@ exports.open = function(cfg, cb) {
     drop_on_close = database;
   }
 
-  client.connect(function(error) {
-    if (error) {
-      logUnexpectedError(error);
-      cb(error);
-    } else {
-      // now create the databse
-      client.query("CREATE DATABASE IF NOT EXISTS " + database, function(err) {
-        if (err) {
-          logUnexpectedError(err);
-          cb(err);
-          return;
-        }
-        client.useDatabase(database, function(err) {
-          if (err) {
-            logUnexpectedError(err);
-            cb(err);
-            return;
-          }
+  // now create the databse
+  client.query("CREATE DATABASE IF NOT EXISTS " + database, function(err) {
+    if (err) {
+      logUnexpectedError(err);
+      cb(err);
+      return;
+    }
+    client.useDatabase(database, function(err) {
+      if (err) {
+        logUnexpectedError(err);
+        cb(err);
+        return;
+      }
 
-          // now create tables
-          function createNextTable(i) {
-            if (i < schemas.length) {
-              client.query(schemas[i], function(err) {
-                if (err) {
-                  logUnexpectedError(err);
-                  cb(err);
-                } else {
-                  createNextTable(i+1);
-                }
-              });
+      // now create tables
+      function createNextTable(i) {
+        if (i < schemas.length) {
+          client.query(schemas[i], function(err) {
+            if (err) {
+              logUnexpectedError(err);
+              cb(err);
             } else {
-              cb();
+              createNextTable(i+1);
             }
-          }
-          createNextTable(0);
-        });
-      });
-    }
+          });
+        } else {
+          cb();
+        }
+      }
+      createNextTable(0);
+    });
   });
 };