eqemu-server/wi/http/data/sql.js

var moment = require('moment');

function CreateReplace(table, body, fields) {
	try {
		var query = 'REPLACE INTO ' + table + ' VALUES(';
		var first = true;
		var args = [];
		
		for(var idx in fields) {
			if(first) {
				first = false;
			} else {
				query += ',';
			}
			
			query += '?';
		
			var entry = fields[idx];
			if(entry.type === 12) {
				try {
					var d = new moment(body[entry.name]);
					
					if(d.isValid()) {
						args.push(d.format('YYYY-MM-DD HH:mm:ss'));
					} else {
						args.push(null);
					}
				} catch(ex) {
					args.push(null);
				}
			} else {
				args.push(body[entry.name]);
			}
		}
		
		query += ')';
		
		return { 'query': query, 'args': args };
	} catch(ex) {
		return { 'query': '', 'args': [] };
	}
}

function CreateUpdate(req, res, table, pkey) {
	req.mysql.getConnection(function(err, connection) {
		try {
			if(err) {
				console.log(err);
				connection.release();
				res.sendStatus(500);
				return;
			}
			
			if(req.body[pkey] !== parseInt(req.params[pkey], 10)) {
				connection.release();
				res.sendStatus(400);
				return;
			}
			
			connection.query('SELECT * FROM ' + table + ' WHERE ' + pkey + '=? LIMIT 1', [req.params[pkey]], function (error, results, fields) {
				try {
					if(error) {
						console.log(error);
						connection.release();
						res.sendStatus(400);
						return;
					}
					
					var replace = CreateReplace(table, req.body, fields);
					if(replace.query === '') {
						connection.release();
						res.sendStatus(400);
						return;
					}
					
					connection.query(replace.query, replace.args, function(error, results, fields) {
						try {
							if(error) {
								console.log(error);
								connection.release();
								res.sendStatus(400);
								return;
							}
							
							connection.release();
							res.sendStatus(200);
						} catch(ex) {
							console.log(ex);
							connection.release();
							res.sendStatus(500);
						}
					});
				} catch(ex) {
					console.log(ex);
					connection.release();
					res.sendStatus(500);
				}
			});
		} catch(ex) {
			console.log(ex);
			connection.release();
			res.sendStatus(500);
		}
	});
}

function RetrieveAll(req, res, table, pkey) {
	req.mysql.getConnection(function(err, connection) {
		try {
			if(err) {
				console.log(err);
				connection.release();
				res.sendStatus(500);
				return;
			}
			
			connection.query('SELECT * FROM ' + table + ' ORDER BY ' + pkey + ' ASC LIMIT 1000', [], function (error, results, fields) {
				try {
					var ret = [];
					
					for(var idx in results) {
						var result = results[idx];
						var obj = { };
						
						for(var i in result) {
							var value = result[i];
							obj[i] = value;
						}
						
						ret.push(obj);
					}
					
					connection.release();
					res.json(ret);
				} catch(ex) {
					console.log(ex);
					connection.release();
					res.sendStatus(500);
				}
			});
		} catch(ex) {
			console.log(ex);
			connection.release();
			res.sendStatus(500);
		}
	});
}

function Retrieve(req, res, table, pkey) {
	req.mysql.getConnection(function(err, connection) {
		try {
			if(err) {
				console.log(err);
				connection.release();
				res.sendStatus(500);
				return;
			}
			
			connection.query('SELECT * FROM ' + table + ' WHERE ' + pkey + '=? LIMIT 1', [req.params[pkey]], function (error, results, fields) {
				try {
					if(results.length == 0) {
						connection.release();
						res.sendStatus(404);
						return;
					}
					
					var result = results[0];
					var ret = { };
					
					for(var idx in result) {
						var value = result[idx];
						ret[idx] = value;
					}
					
					connection.release();
					res.json(ret);
				} catch(ex) {
					console.log(ex);
					connection.release();
					res.sendStatus(500);
				}
			});
		} catch(ex) {
			console.log(ex);
			connection.release();
			res.sendStatus(500);
		}
	});
}

function Delete(req, res, table, pkey) {
	req.mysql.getConnection(function(err, connection) {
		try {
			if(err) {
				console.log(err);
				connection.release();
				res.sendStatus(500);
				return;
			}
						
			connection.query('DELETE FROM ' + table + ' WHERE ' + pkey + '=? LIMIT 1', [req.params[pkey]], function (error, results, fields) {
				try {
					if(error) {
						console.log(error);
						connection.release();
						res.sendStatus(400);
						return;
					}
					
					connection.release();
					res.sendStatus(200);
				} catch(ex) {
					console.log(ex);
					connection.release();
					res.sendStatus(500);
				}
			});
		} catch(ex) {
			console.log(ex);
			connection.release();
			res.sendStatus(500);
		}
	});
}

function Search(req, res, table, pkey, skeys) {
	//Verify incoming model
	if(!req.body.hasOwnProperty('start')) {
		res.sendStatus(400);
		return;
	}
	
	if(!req.body.hasOwnProperty('length')) {
		res.sendStatus(400);
		return;
	}
	
	if(!req.body.hasOwnProperty('search')) {
		res.sendStatus(400);
		return;
	}
	
	req.mysql.getConnection(function(err, connection) {
		try {
			if(err) {
				console.log(err);
				connection.release();
				res.sendStatus(500);
				return;
			}
			
			var query = 'SELECT * FROM ' + table;
			var first = true;
			var idx;
			var args = [];
			var searchTerm = '%' + req.body['search'] + '%';
			for(idx in skeys) {
				var skey = skeys[idx];
				if(first) {
					first = false;
					query +=  ' WHERE ';
				} else {
					query += ' OR ';
				}
				
				query += skey;
				query += ' LIKE ?';
				args.push(searchTerm);
			}
			
			query += ' ORDER BY ' + pkey + ' ASC';
			query += ' LIMIT ?, ?';
			args.push(req.body['start']);
			args.push(req.body['length']);
			
			connection.query(query, args, function (error, results, fields) {
				try {
					var ret = [];
					
					for(idx in results) {
						var result = results[idx];
						var obj = { };
						
						for(var i in result) {
							var value = result[i];
							obj[i] = value;
						}
						
						ret.push(obj);
					}
					
					connection.release();
					res.json(ret);
				} catch(ex) {
					console.log(ex);
					connection.release();
					res.sendStatus(500);
				}
			});
		} catch(ex) {
			console.log(ex);
			connection.release();
			res.sendStatus(500);
		}
	});
}

module.exports = {
	'CreateUpdate': CreateUpdate,
	'Retrieve': Retrieve,
	'RetrieveAll': RetrieveAll,
	'Delete': Delete,
	'Search': Search,
}