nonrenew-rethinkdb-wrapper

NOnReNEW based wrapper for rethinkdb

Example

var rthkwrp = require("nonrenew-rethinkdb-wrapper");
var Collection = rthkwrp.Collection;
var RethinkdbWrapper = rthkwrp.RethinkdbWrapper;

var User = new Collection({
    name: "users",
    primary: "id",
    fields: {
        "id":{required:true},
        "username":{required:true},
        "password":{required:true},
        "first_name":{required:false},
        "last_name":{required:false}
    }
});


var dbw = RethinkdbWrapper({database:"nonrenew"}, [Users]);

var crypto = require('crypto');
var shasum = crypto.createHash('sha1');
shasum.update("mypasswd");
var pwd = shasum.digest("hex");

function insert() {
    console.log(dbw)
    console.log("Inserting data");
    dbw.upsert(User, {
        // "id":"14337ac8-08b8-4d01-afaa-b99ce3008abf",
        "username":"jdoe",
        "password":pwd
    }, function (row) {
        console.log("Row:", row);
    });
}

var __id = "";

function query() {
    console.log("Making a query...");
    dbw.select(User,
        {
            "username":"jdoe",
            "password":pwd
        },
        function (data) {
            for(ri=0;ri<data.length;ri++) {
                console.log(data[ri]);
                __id = data[ri].id;
            }
        }
    );
}

function remove() {
    console.log("Deleting data");
    dbw.delete(User, {"id":__id}, function (row) {
        console.log("Deleted:", row);
    });
}

console.log("Starting...");
setTimeout(insert, 3000);
setTimeout(query, 3500);
setTimeout(remove, 4000);