node db wat

mongo-like interface to rethinkdb

goals

• small efficient codebase
• high throughput atomic writes to disc/network (only write new data to disc)
• no write corruption on master data even during unexpected errors/faults.
• optional automatic passthrough to replicate or loadbalance

install

install https://rethinkdb.com/

npm install nodedbwat

check test.js

todo

many many things.

usage:

 
// LOAD/CREATE DATABASE(S)
var nodedbwat = require("nodedbwat");
var db = nodedbwat.connect("", ["mydb", "anotherdb"]);
 
// SUBSCRIBE TO DB INSERT EVENTS FOR A REALTIME FEED
db.mydb.on("insert", function (entry) {
    
    // LOGS OUT EVENT
    console.log("insert event:");
    console.log(entry);
    
    // SAVE TO SSD
    db.mydb.save(); 
 
    // FIND DATA
    db.mydb.find({ car: "BAKKIE" }, function (err, results) {
        console.log(results);
    });
 
});
 
// INSERTS DATA
db.mydb.insert({ name: "KOOS", age: Math.round(Math.random() * 120), car: "BAKKIE" });

build:

tsc *.ts --lib 'ES2015' -w

reference

// CONNECT
var nodeDBwat = require('nodedbwat');
var db = nodeDBwat.connect("", ["brands", "models", "stats"], {dbPath:__dirname})
 
/*
connect(peerIps[], collections[], options?)
 
options = {
  dbPath: "./db" ,          // set the folder relative of abolute
                            // use __dirname to get the current path
}
*/
 

---

// INSERT DATA
var somedata = { foo : "bar", beep : "boop", a : [1,2,3] }
 
db.mydb.insert(somedata)

---

// FIND DATA BY FILTERING
db.mydb.find({peep:"boop"}, (err, result) => { 
  console.log(result); 
})

---

// FIND AND UPDATE 
db.mydb.update({beep:"boop"}, {bar:"foo"} , (err, result) => { 
  console.log(result); 
})

---

// SAVE TO db_mydb.json FILE
db.mydb.save((err) => { 
  console.error(err); 
})