Docdb NPM | npm.io

DocDB

LOG-based JavaScript DataBase (based on streaming processing). The API will be significantly changed.

Install

	npm i docdb --save

Use

	const DATASTORE = require('docdb');
	let DataBase = new DATASTORE({dbname:'_test'});
	DataBase.then(function(db){
		
		//warning stream
		db.on('data', function(buffer){
			console.log(buffer);
		});
		
		//find documents from database (if you use the _id key, the search is performed by index)
		db.findMany({..filter documents fields type of Object}, [..document fields returned type of Array]).then(function(arr){
			//query result type of Array
			console.log(arr);
		});
		
		//insert (or update if exists) one document from database
		db.insertOne({..insert document type of Object}).then(function(_id){
			console.log(arr);
		});
		
		//remove one document from database
		db.removeOne({_id: first key document type of String}).then(function(_id){
			console.log(arr);
		});
		
		//backup database files
		db.service.toBackup().then(function(){
		
		});
		
		//restore database files from backup
		db.service.fromBackup().then(function(){
			
		});
		
		//recovery index file
		db.service.recovery().then(function(){
			
		});
		
		//index file compression
		db.service.compact().then(function(){
			
		});
		
		//data file compression
		db.service.compact("log").then(function(){
			
		});
	});

EXAMPLE

	const DATASTORE = require('docdb');
	let DataBase = new DATASTORE({dbname:'test'});
	DataBase.then(function(db){
		
		//warning stream
		db.on('data', function(buffer){
			console.log(buffer);
		});
		
		//insert (or update if exists) one document from database
		db.insertOne({_id: "sdasdasdas", text:"test", data: Date.now()}).then(function(_id){
			console.log(_id);
			return new Promise(function(res, rej){	//find documents from database (if you use the _id key, the search is performed by index)
				setTimeout(function(){
					db.findMany({_id: "sdasdasdas"}, ["_id", "text"]).then(res).catch(rej);
				}, 100);
			});	
		}).then(function(arr){
			//query result
			console.log(arr);
			return db.removeOne({_id: "sdasdasdas"});	//remove one document from database
		}).then(function(_id){
			console.log(_id);
			return new Promise(function(res, rej){	//find documents from database (if you use the _id key, the search is performed by index)
				setTimeout(function(){
					db.findMany({_id: "sdasdasdas"}, ["_id", "text"]).then(res).catch(rej);
				}, 100);
			});	
		}).then(function(arr){
			console.log(arr);
			return db.service.toBackup();//backup database files
		}).then(function(bool){
			console.log(bool);
			return db.service.fromBackup();//restore database files from backup
		}).then(function(bool){
			console.log(bool);
			return db.service.recovery();//recovery index file
		}).then(function(bool){
			console.log(bool);
			return db.service.compact();//index file compression
		}).then(function(){
			return db.service.compact("log");//data file compression
		}).then(function(){
			console.log('Test complete!');
		}).catch(function(err){
			console.log('Test interrupted, with error:', err);
		});
	});

EXAMPLE CONSOLE

	let READLINE = require('readline'),
		DATASTORE = require('docdb');
		
	let DataBase = new DATASTORE({dbname:'test'});

	DataBase.then(function(db){
		db.on('data', function(buffer){
			console.log(buffer);
		});
		const rl = READLINE.createInterface({
			input: process.stdin,
			output: process.stdout,
			prompt: 'DocDB> '
		});
		rl.prompt();
		rl.on('line', (line) => {
			try{
				let _tmp = eval(line);
				if(typeof(_tmp) !== 'undefined'){
					console.log(_tmp);
				}
			} catch(err) {
				console.error("Ошибка команды: "+err);
			}
			rl.prompt();
		}).on('close', () => {
			console.log('DocDB disconnected!');
			process.exit(0);
		});
	});