MarkLogic World 2013 - MLDB talk

mldb-create-db.js

var dosomething = function() { /* whatever */ };

var db = new mldb(); // default options
db.exists(function(result) {
  if (!result.inError) {
    if (result.exists) {
      // already exists
      dosomething();
    } else {
      // create then destroy
      db.create(function(result) {
        dosomething();
      });
    }
  }
});

mldb-default-options.js

var defaultdboptions = {
  host: "localhost", port: 9090, adminport: 8002, ssl: false, 
  auth: "digest", username: "admin",password: "admin", 
  database: "mldbtest", 
  searchoptions: {}, fastthreads: 10, fastparts: 100
};

mldb-get-doc.js

var db = new mldb(); // default options
db.setLogger(logger);

var doc = db.get("/messages/1", function(result) {
  // now print it
  logger.debug("Doc content: " + JSON.stringify(result.doc));
  // done
});

mldb-save-get-delete.js

var db = new mldb(); // default options
  
db.save({from: "test", to: "all", body: "wibble"},"/messages/1", 
  {collection: "messages"},function(result) {
    
  // now fetch it
  db.get("/messages/1", function(result) {
    // now print it
    logger.debug("Doc content: " + JSON.stringify(result.doc));
    
    // now delete it
    db.delete("/messages/1", function(result) {
      // done
    });
  });
});

mldb-tx.js

tests.commit = function(callback) {
  var db = new mldb(); // default options
  db.setLogger(logger);
  
  db.beginTransaction(function(result) {
    var txid = result.txid;
    logger.debug("TEST: COMMIT: Transaction ID: " + txid);
    
    // now create doc
    var uri = "/trans/commit/1";
    var json = {title: "Transaction commit test doc"};
    db.save(json,uri,function(result) {
      
      // now commit
      db.commitTransaction(function(result) {
        if (result.inError) {
          logger.debug("TEST: COMMIT: ERROR IN COMMIT: " + JSON.stringify(result));
          callback(false);
        } else {
          db.get(uri, function(result) {
            // now print it
            logger.debug("TEST: COMMIT: Doc content: " + JSON.stringify(result.doc));
            if (JSON.stringify(json) == JSON.stringify(result.doc)) {
      
              // now delete it
              db.delete(uri, function(result) {
                logger.debug("TEST: COMMIT: Doc deleted");
              });
            } else {
              logger.debug("TEST: COMMIT: ERROR: Retrieved document is not same as that saved");
              callback(false);
            }
          });
        }
      });
    });
  });
};

node-create-server.js

var http = require('http');
http.createServer(function (req, res) {
  res.writeHead(200, {'Content-Type': 'text/plain'});
  res.end('Hello World\n');
}).listen(1337, '127.0.0.1');
console.log('Server running at http://127.0.0.1:1337/');