tcrud/lib/backend/mongo.js

var config       = require('./../tcrud-config');
var debug        = require('debug')('ff:tcrud:mongo');

module.exports = {
	registrate: function(key,server) {
		config.registratePlugin(new MongoPlugin(key,server));
	}
}

// ------- MongoPlugin Object

function MongoPlugin(key,server) {
	this.key = key;
	this.server = server;
}

MongoPlugin.prototype.configPlugin = function (ctx) {
	ctx.key='mongo#'+this.key;
	ctx.description='Adds mongo backend support.';
};

MongoPlugin.prototype.createBackend = function() {
	return new MongoBackend(this);
}

// -------- MongoBackend

function MongoBackend(plugin) {
	this.plugin = plugin;
}

MongoBackend.prototype.getKey = function() {
	return this.plugin.key;
}

MongoBackend.prototype.findAll = function(tview,crudType) {
	var self = this;
	return function(data, dataParam, cb) {
		var querySql = 'SELECT '+selectField(tview,crudType)+' FROM '+tview.tmeta.tmodel.tid+'';
		debug('findAll %s',querySql);
		var query = self.db.query(querySql,[],function (err, result) {
			if (err) {
				debug(err);
				cb(err);
			} else {
				cb(err,result.rows);
			}
		});
	};
}

MongoBackend.prototype.createNew = function(tview,crudType) {
	var self = this;
	return function(data, dataParam, cb) {
		
	};
}

MongoBackend.prototype.findOne = function(tview,crudType) {
	var self = this;
	return function(data, dataParam, cb) {
		var querySql = 'SELECT '+selectField(tview,crudType)+' FROM '+tview.tmeta.tmodel.tid+' WHERE '+whereKeys(tview)+'';
		debug('findOne param %s',JSON.stringify(dataParam));
		debug('findOne sql %s',querySql);
		var query = self.db.query(querySql, dataParam, function (err, result) {
			if (err) {
				debug(err);
				cb(err);
			} else {
				cb(err,result.rows[0]);
			}
		});
	};
}

MongoBackend.prototype.updateOne = function(tview,crudType) {
	var self = this;
	return function(data, dataParam, cb) {
		var querySql = 'UPDATE '+tview.tmeta.tmodel.tid+' '+updateValues(tview,data)+' WHERE '+whereKeys(tview);
		debug('updateOne param %s',JSON.stringify(dataParam));
		debug('updateOne data %s',JSON.stringify(data));
		debug('updateOne sql %s',querySql);
		var query = self.db.query(querySql, data, function (err, result) {
			if (err) {
				debug(err);
				cb(err);
			} else {
				cb(err,result.rows[0]);
			}
		});
	};
}

MongoBackend.prototype.deleteOne = function(tview,crudType) {
	var self = this;
	return function(data, dataParam, cb) {
		var querySql = 'DELETE FROM '+tview.tmeta.tmodel.tid+' WHERE '+whereKeys(tview);
		debug('deleteOne param %s',JSON.stringify(dataParam));
		debug('deleteOne sql %s',querySql);
		var query = self.db.query(querySql, dataParam, function (err, result) {
			if (err) {
				debug(err);
				cb(err);
			} else {
				cb(err,result.rows[0]);
			}
		});
	};
}

MongoBackend.prototype.findAllCount = function(tview,crudType) {
	var self = this;
	return function(data, dataParam, cb) {
		var querySql = 'SELECT count(*) FROM '+tview.tmeta.tmodel.tid+' WHERE '+whereKeys(tview);
		debug('findAllCount param %s',JSON.stringify(dataParam));
		debug('findAllCount sql %s',querySql);
		var query = self.db.query(querySql, dataParam, function (err, result) {
			if (err) {
				debug(err);
				cb(err);
			} else {
				cb(err,result.rows[0]);
			}
		});
	};
}