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); 
})