Fix the on-demand connection

examples/datasource-app.js

@@ -1,20 +1,6 @@
 var DataSource = require('../../jugglingdb').DataSource;
 var ds = new DataSource('memory');
 
-var Article = ds.define('Article', {title: String});
-var Tag = ds.define('Tag', {name: String});
-Article.hasAndBelongsToMany('tags');
-
-Article.create(function(e, article) {
-    article.tags.create({name: 'popular'}, function (err, data) {
-        Article.findOne(function(e, article) {
-            article.tags(function(e, tags) {
-               console.log(tags);
-            });
-        });
-    });
-});
-
 // define models
 var Post = ds.define('Post', {
     title: { type: String, length: 255 },
@@ -91,8 +77,19 @@ User.create({name: 'Ray'}, function (err, data) {
     console.log(data);
 });
 
-var count = 5;
-setInterval(function() {console.log(count--); if(!count) process.exit(0);}, 100);
+var Article = ds.define('Article', {title: String});
+var Tag = ds.define('Tag', {name: String});
+Article.hasAndBelongsToMany('tags');
+
+Article.create(function(e, article) {
+    article.tags.create({name: 'popular'}, function (err, data) {
+        Article.findOne(function(e, article) {
+            article.tags(function(e, tags) {
+                console.log(tags);
+            });
+        });
+    });
+});
 
 
 

lib/dao.js

@@ -150,13 +150,16 @@ DataAccessObject.create = function (data, callback) {
 };
 
 function stillConnecting(schema, obj, args) {
-    if (schema.connected) return false;
-    if (schema.connecting) return true;
+    if (schema.connected) return false; // Connected
+
     var method = args.callee;
+    // Set up a callback after the connection is established to continue the method call
     schema.once('connected', function () {
         method.apply(obj, [].slice.call(args));
     });
-    schema.connect();
+    if (!schema.connecting) {
+        schema.connect();
+    }
     return true;
 };
 

lib/datasource.js

@@ -128,6 +128,12 @@ DataSource.prototype.setup = function(name, settings) {
 
     schema.connect = function(cb) {
         var schema = this;
+        if(schema.connected) {
+            if (cb) {
+                process.nextTick(cb);
+            }
+            return;
+        }
         schema.connecting = true;
         if (schema.adapter.connect) {
             schema.adapter.connect(function(err) {