|
@@ -1,279 +1,351 @@
|
|
|
|
+/**
|
|
|
|
+ * Module dependencies.
|
|
|
|
+ */
|
|
|
|
+
|
|
var cluster = require('cluster')
|
|
var cluster = require('cluster')
|
|
, numCPUs = require('os').cpus().length
|
|
, numCPUs = require('os').cpus().length
|
|
- , windows = require('os').platform() == 'win32';
|
|
|
|
-
|
|
|
|
-if(cluster.isMaster) {
|
|
|
|
- // Fork workers.
|
|
|
|
- for (var i = 0; i < numCPUs; i++) {
|
|
|
|
- cluster.fork();
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
- cluster.on('exit', function(worker, code, signal) {
|
|
|
|
- console.log('worker ' + worker.pid + ' died');
|
|
|
|
- });
|
|
|
|
-
|
|
|
|
- return;
|
|
|
|
-}
|
|
|
|
-
|
|
|
|
-var http = require('http')
|
|
|
|
|
|
+ , http = require('http')
|
|
, url = require('url')
|
|
, url = require('url')
|
|
|
|
+ , Sequelize = require('sequelize')
|
|
|
|
+ , mysql = require('mysql')
|
|
, async = require('async')
|
|
, async = require('async')
|
|
, mongoose = require('mongoose')
|
|
, mongoose = require('mongoose')
|
|
, conn = mongoose.connect('mongodb://localhost/hello_world')
|
|
, conn = mongoose.connect('mongodb://localhost/hello_world')
|
|
- , MongoClient = require('mongodb').MongoClient
|
|
|
|
- , connMap = { user: 'benchmarkdbuser', password: 'benchmarkdbpass', database: 'hello_world', host: 'localhost' };
|
|
|
|
-
|
|
|
|
-if (!windows) {
|
|
|
|
- var Mapper = require('mapper')
|
|
|
|
- , libmysql = require('mysql-libmysqlclient').createConnectionSync();
|
|
|
|
-
|
|
|
|
- Mapper.connect(connMap, {verbose: false, strict: false});
|
|
|
|
- var World = Mapper.map("World", "id", "randomNumber")
|
|
|
|
- libmysql.connectSync('localhost', 'benchmarkdbuser', 'benchmarkdbpass', 'hello_world');
|
|
|
|
-}
|
|
|
|
|
|
+ , MongoClient = require('mongodb').MongoClient;
|
|
|
|
|
|
|
|
+// MongoDB Raw Setup
|
|
var collection = null;
|
|
var collection = null;
|
|
-
|
|
|
|
MongoClient.connect('mongodb://localhost/hello_world?maxPoolSize=5', function(err, db) {
|
|
MongoClient.connect('mongodb://localhost/hello_world?maxPoolSize=5', function(err, db) {
|
|
collection = db.collection('world');
|
|
collection = db.collection('world');
|
|
});
|
|
});
|
|
|
|
|
|
-// define model
|
|
|
|
-var Schema = mongoose.Schema
|
|
|
|
- , ObjectId = Schema.ObjectId;
|
|
|
|
|
|
+// MySQL Raw Setup
|
|
|
|
+var connection = mysql.createConnection({
|
|
|
|
+ host : 'localhost',
|
|
|
|
+ user : 'benchmarkdbuser',
|
|
|
|
+ password : 'benchmarkdbpass',
|
|
|
|
+ database : 'hello_world'
|
|
|
|
+});
|
|
|
|
+connection.connect();
|
|
|
|
+
|
|
|
|
+// Mongoose Setup
|
|
|
|
+var WorldSchema = new mongoose.Schema({
|
|
|
|
+ id : Number,
|
|
|
|
+ randomNumber: Number
|
|
|
|
+ }, {
|
|
|
|
+ collection: 'world'
|
|
|
|
+ }),
|
|
|
|
+ MWorld = conn.model('World', WorldSchema);
|
|
|
|
+
|
|
|
|
+// Sequelize Setup
|
|
|
|
+var sequelize = new Sequelize('hello_world', 'benchmarkdbuser', 'benchmarkdbpass', {
|
|
|
|
+ host: 'localhost',
|
|
|
|
+ dialect: 'mysql',
|
|
|
|
+ logging: false
|
|
|
|
+});
|
|
|
|
|
|
-var WorldSchema = new Schema({
|
|
|
|
- id : Number
|
|
|
|
- , randomNumber : Number
|
|
|
|
-}, { collection : 'world' });
|
|
|
|
-var MWorld = conn.model('World', WorldSchema);
|
|
|
|
|
|
+var World = sequelize.define('World', {
|
|
|
|
+ id: {
|
|
|
|
+ type: 'Sequelize.INTEGER'
|
|
|
|
+ },
|
|
|
|
+ randomNumber: {
|
|
|
|
+ type: 'Sequelize.INTEGER'
|
|
|
|
+ }
|
|
|
|
+}, {
|
|
|
|
+ timestamps: false,
|
|
|
|
+ freezeTableName: true
|
|
|
|
+});
|
|
|
|
+var Fortune = sequelize.define('Fortune', {
|
|
|
|
+ id: {
|
|
|
|
+ type: 'Sequelize.INTEGER'
|
|
|
|
+ },
|
|
|
|
+ message: {
|
|
|
|
+ type: 'Sequelize.STRING'
|
|
|
|
+ }
|
|
|
|
+}, {
|
|
|
|
+ timestamps: false,
|
|
|
|
+ freezeTableName: true
|
|
|
|
+});
|
|
|
|
|
|
|
|
+// Helper functions
|
|
function getRandomNumber() {
|
|
function getRandomNumber() {
|
|
return Math.floor(Math.random() * 10000) + 1;
|
|
return Math.floor(Math.random() * 10000) + 1;
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+// Mongoose Query Functions
|
|
function mongooseQuery(callback) {
|
|
function mongooseQuery(callback) {
|
|
- MWorld.findOne({ id: getRandomNumber()}).exec(function (err, world) {
|
|
|
|
|
|
+ MWorld.findOne({
|
|
|
|
+ id: getRandomNumber()
|
|
|
|
+ }).exec(function (err, world) {
|
|
callback(err, world);
|
|
callback(err, world);
|
|
});
|
|
});
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+// MongoDB-Raw Query Functions
|
|
function mongodbDriverQuery(callback) {
|
|
function mongodbDriverQuery(callback) {
|
|
- collection.findOne({ id: getRandomNumber()}, function(err, world) {
|
|
|
|
|
|
+ collection.findOne({
|
|
|
|
+ id: getRandomNumber()
|
|
|
|
+ }, function(err, world) {
|
|
|
|
+ world._id = undefined; // remove _id from query response
|
|
callback(err, world);
|
|
callback(err, world);
|
|
});
|
|
});
|
|
}
|
|
}
|
|
|
|
|
|
function mongodbDriverUpdateQuery(callback) {
|
|
function mongodbDriverUpdateQuery(callback) {
|
|
- collection.findAndModify({ id: getRandomNumber()}, [['_id','asc']], {$set: {randomNumber: getRandomNumber()}}, {}, function(err, world) {
|
|
|
|
- callback(err, world);
|
|
|
|
|
|
+ collection.findAndModify({
|
|
|
|
+ id: getRandomNumber()
|
|
|
|
+ }, [['_id','asc']], {
|
|
|
|
+ $set: {randomNumber: getRandomNumber()}
|
|
|
|
+ }, {}, function(err, world) {
|
|
|
|
+ world.value._id = undefined; // remove _id from query response
|
|
|
|
+ callback(err, world.value);
|
|
});
|
|
});
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+// Sequelize Query Functions
|
|
function sequelizeQuery(callback) {
|
|
function sequelizeQuery(callback) {
|
|
- World.findById(getRandomNumber(), function (err, world) {
|
|
|
|
- callback(null, world);
|
|
|
|
- });
|
|
|
|
|
|
+ World.findOne({
|
|
|
|
+ where: {
|
|
|
|
+ id: Math.floor(Math.random() * 10000) + 1}
|
|
|
|
+ }
|
|
|
|
+ ).complete(callback);
|
|
}
|
|
}
|
|
|
|
|
|
-http.createServer(function (req, res) {
|
|
|
|
- // JSON response object
|
|
|
|
- var hello = {message: "Hello, World!"};
|
|
|
|
- var helloStr = "Hello, World!";
|
|
|
|
- var path = url.parse(req.url).pathname;
|
|
|
|
-
|
|
|
|
- // mysql on windows is not supported
|
|
|
|
- if (windows && (path.substr(0, 3) == '/my' || path == '/update')) {
|
|
|
|
- path = '/doesntexist';
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
- switch (path) {
|
|
|
|
- case '/json':
|
|
|
|
- // JSON Response Test
|
|
|
|
- res.writeHead(200, {'Content-Type': 'application/json; charset=UTF-8'});
|
|
|
|
- // Write JSON object to response
|
|
|
|
- res.end(JSON.stringify(hello));
|
|
|
|
- break;
|
|
|
|
-
|
|
|
|
- case '/plaintext':
|
|
|
|
- // JSON Response Test
|
|
|
|
- res.writeHead(200, {'Content-Type': 'text/plain; charset=UTF-8'});
|
|
|
|
- // Write JSON object to response
|
|
|
|
- res.end(helloStr);
|
|
|
|
- break;
|
|
|
|
-
|
|
|
|
- case '/mongodbdriver':
|
|
|
|
- // Database Test
|
|
|
|
- var values = url.parse(req.url, true);
|
|
|
|
- var queries = values.query.queries || 1;
|
|
|
|
- var queryFunctions = new Array(queries);
|
|
|
|
|
|
|
|
- for (var i = 0; i < queries; i += 1) {
|
|
|
|
- queryFunctions[i] = mongodbDriverQuery;
|
|
|
|
|
|
+// MySQL-Raw Query Functions
|
|
|
|
+function mysqlQuery(callback) {
|
|
|
|
+ connection.query("SELECT * FROM world WHERE id = " + getRandomNumber(), function (err, rows, fields) {
|
|
|
|
+ if (err) {
|
|
|
|
+ throw err;
|
|
}
|
|
}
|
|
|
|
+ callback(null, rows[0]);
|
|
|
|
+ });
|
|
|
|
+}
|
|
|
|
|
|
- res.writeHead(200, {'Content-Type': 'application/json; charset=UTF-8'});
|
|
|
|
-
|
|
|
|
- async.parallel(queryFunctions, function(err, results) {
|
|
|
|
- if (queries == 1) {
|
|
|
|
- results = results[0];
|
|
|
|
|
|
+function mysqlUpdateQuery(callback) {
|
|
|
|
+ connection.query("SELECT * FROM world WHERE id = " + getRandomNumber(), function (err, rows, fields) {
|
|
|
|
+ if (err) {
|
|
|
|
+ throw err;
|
|
|
|
+ }
|
|
|
|
+ rows[0].randomNumber = getRandomNumber();
|
|
|
|
+ var updateQuery = "UPDATE world SET randomNumber = " + rows[0].randomNumber + " WHERE id = " + rows[0]['id'];
|
|
|
|
+ connection.query(updateQuery, function (err, result) {
|
|
|
|
+ if (err) {
|
|
|
|
+ throw err;
|
|
}
|
|
}
|
|
- res.end(JSON.stringify(results));
|
|
|
|
|
|
+ callback(null, rows[0]);
|
|
});
|
|
});
|
|
- break;
|
|
|
|
-
|
|
|
|
- case '/mongoose':
|
|
|
|
- // Database Test
|
|
|
|
- var values = url.parse(req.url, true);
|
|
|
|
- var queries = values.query.queries || 1;
|
|
|
|
- var queryFunctions = new Array(queries);
|
|
|
|
|
|
+ });
|
|
|
|
+}
|
|
|
|
|
|
- for (var i = 0; i < queries; i += 1) {
|
|
|
|
- queryFunctions[i] = mongooseQuery;
|
|
|
|
- }
|
|
|
|
|
|
+if(cluster.isMaster) {
|
|
|
|
+ // Fork workers.
|
|
|
|
+ for (var i = 0; i < numCPUs; i++) {
|
|
|
|
+ cluster.fork();
|
|
|
|
+ }
|
|
|
|
|
|
- res.writeHead(200, {'Content-Type': 'application/json; charset=UTF-8'});
|
|
|
|
|
|
+ cluster.on('exit', function(worker, code, signal) {
|
|
|
|
+ console.log('worker ' + worker.pid + ' died');
|
|
|
|
+ });
|
|
|
|
|
|
- async.parallel(queryFunctions, function(err, results) {
|
|
|
|
- if (queries == 1) {
|
|
|
|
- results = results[0];
|
|
|
|
- }
|
|
|
|
- res.end(JSON.stringify(results));
|
|
|
|
- });
|
|
|
|
- break;
|
|
|
|
|
|
+ return;
|
|
|
|
+} else {
|
|
|
|
+ http.createServer(function (req, res) {
|
|
|
|
+ // JSON response object
|
|
|
|
+ var hello = {message: "Hello, World!"};
|
|
|
|
+ var helloStr = "Hello, World!";
|
|
|
|
+ var path = url.parse(req.url).pathname;
|
|
|
|
+
|
|
|
|
+ switch (req.url) {
|
|
|
|
+ case '/json':
|
|
|
|
+ res.writeHead(200, {
|
|
|
|
+ 'Content-Type': 'application/json',
|
|
|
|
+ 'Server': 'Node'
|
|
|
|
+ });
|
|
|
|
+ res.end(JSON.stringify(hello));
|
|
|
|
+ break;
|
|
|
|
|
|
- case '/mysql-orm':
|
|
|
|
|
|
+ case '/plaintext':
|
|
|
|
+ res.writeHead(200, {
|
|
|
|
+ 'Content-Type': 'text/plain; charset=UTF-8',
|
|
|
|
+ 'Server': 'Node'
|
|
|
|
+ });
|
|
|
|
+ res.end(helloStr);
|
|
|
|
+ break;
|
|
|
|
+ }
|
|
var values = url.parse(req.url, true);
|
|
var values = url.parse(req.url, true);
|
|
- var queries = values.query.queries || 1;
|
|
|
|
- var queryFunctions = new Array(queries);
|
|
|
|
|
|
+ var queries = isNaN(values.query.queries) ? 1 : parseInt(values.query.queries, 10);
|
|
|
|
+ queries = Math.min(Math.max(queries, 1), 500);
|
|
|
|
+ switch (values.pathname) {
|
|
|
|
+ // Raw MongoDB Routes
|
|
|
|
+ case '/mongodb':
|
|
|
|
+ var queryFunctions = [];
|
|
|
|
+ for (var i = 0; i < queries; i += 1) {
|
|
|
|
+ queryFunctions.push(mongodbDriverQuery);
|
|
|
|
+ }
|
|
|
|
|
|
- for (var i = 0; i < queries; i += 1) {
|
|
|
|
- queryFunctions[i] = sequelizeQuery;
|
|
|
|
- }
|
|
|
|
|
|
+ async.parallel(queryFunctions, function(err, results) {
|
|
|
|
+ if (!values.query.queries) {
|
|
|
|
+ results = results[0];
|
|
|
|
+ }
|
|
|
|
+ res.writeHead(200, {
|
|
|
|
+ 'Content-Type': 'application/json',
|
|
|
|
+ 'Server': 'Node'
|
|
|
|
+ });
|
|
|
|
+ res.end(JSON.stringify(results));
|
|
|
|
+ });
|
|
|
|
+ break;
|
|
|
|
|
|
- res.writeHead(200, {'Content-Type': 'application/json'});
|
|
|
|
|
|
+ case '/mongodb-update':
|
|
|
|
+ var queryFunctions = [];
|
|
|
|
+ for (var i = 0; i < queries; i += 1) {
|
|
|
|
+ queryFunctions.push(mongodbDriverUpdateQuery);
|
|
|
|
+ }
|
|
|
|
|
|
- async.parallel(queryFunctions, function(err, results) {
|
|
|
|
- if (queries == 1) {
|
|
|
|
- results = results[0];
|
|
|
|
- }
|
|
|
|
- res.end(JSON.stringify(results));
|
|
|
|
- });
|
|
|
|
- break;
|
|
|
|
-
|
|
|
|
- case '/mysql':
|
|
|
|
- res.writeHead(200, {'Content-Type': 'application/json'});
|
|
|
|
-
|
|
|
|
- function libmysqlQuery(callback) {
|
|
|
|
- libmysql.query("SELECT * FROM world WHERE id = " + getRandomNumber(), function (err, res) {
|
|
|
|
- if (err) {
|
|
|
|
- throw err;
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
- res.fetchAll(function(err, rows) {
|
|
|
|
- if (err) {
|
|
|
|
- throw err;
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
- res.freeSync();
|
|
|
|
- callback(null, rows[0]);
|
|
|
|
|
|
+ async.parallel(queryFunctions, function(err, results) {
|
|
|
|
+ res.writeHead(200, {
|
|
|
|
+ 'Content-Type': 'application/json',
|
|
|
|
+ 'Server': 'Node'
|
|
|
|
+ });
|
|
|
|
+ res.end(JSON.stringify(results));
|
|
});
|
|
});
|
|
- });
|
|
|
|
- }
|
|
|
|
|
|
+ break;
|
|
|
|
|
|
- var values = url.parse(req.url, true);
|
|
|
|
- var queries = values.query.queries || 1;
|
|
|
|
- var queryFunctions = new Array(queries);
|
|
|
|
-
|
|
|
|
- for (var i = 0; i < queries; i += 1) {
|
|
|
|
- queryFunctions[i] = libmysqlQuery;
|
|
|
|
- }
|
|
|
|
- async.parallel(queryFunctions, function(err, results) {
|
|
|
|
- if (err) {
|
|
|
|
- res.writeHead(500);
|
|
|
|
- return res.end('MYSQL CONNECTION ERROR.');
|
|
|
|
- }
|
|
|
|
- if (queries == 1) {
|
|
|
|
- results = results[0];
|
|
|
|
- }
|
|
|
|
- res.end(JSON.stringify(results));
|
|
|
|
- });
|
|
|
|
- break;
|
|
|
|
|
|
+ // Mongoose ORM Routes
|
|
|
|
+ case '/mongoose':
|
|
|
|
+ var queryFunctions = [];
|
|
|
|
+ for (var i = 0; i < queries; i += 1) {
|
|
|
|
+ queryFunctions.push(mongooseQuery);
|
|
|
|
+ }
|
|
|
|
|
|
- case '/update':
|
|
|
|
- res.writeHead(200, {'Content-Type': 'application/json'});
|
|
|
|
|
|
+ async.parallel(queryFunctions, function(err, results) {
|
|
|
|
+ if (!values.query.queries) {
|
|
|
|
+ results = results[0];
|
|
|
|
+ }
|
|
|
|
+ res.writeHead(200, {
|
|
|
|
+ 'Content-Type': 'application/json',
|
|
|
|
+ 'Server': 'Node'
|
|
|
|
+ });
|
|
|
|
+ res.end(JSON.stringify(results));
|
|
|
|
+ });
|
|
|
|
+ break;
|
|
|
|
|
|
- function libmysqlQuery(callback) {
|
|
|
|
- libmysql.query("SELECT * FROM world WHERE id = " + getRandomNumber(), function (err, res) {
|
|
|
|
- if (err) {
|
|
|
|
- throw err;
|
|
|
|
|
|
+ case '/mongoose-update':
|
|
|
|
+ var selectFunctions = [];
|
|
|
|
+ for (var i = 0; i < queries; i += 1) {
|
|
|
|
+ selectFunctions.push(mongooseQuery);
|
|
}
|
|
}
|
|
-
|
|
|
|
- res.fetchAll(function(err, rows) {
|
|
|
|
- if (err) {
|
|
|
|
- throw err;
|
|
|
|
|
|
+
|
|
|
|
+ async.parallel(selectFunctions, function(err, worlds) {
|
|
|
|
+ var updateFunctions = [];
|
|
|
|
+
|
|
|
|
+ for (var i = 0; i < queries; i++) {
|
|
|
|
+ (function(i){
|
|
|
|
+ updateFunctions.push(function(callback){
|
|
|
|
+ worlds[i].randomNumber = Math.ceil(Math.random() * 10000);
|
|
|
|
+ MWorld.update({
|
|
|
|
+ id: worlds[i]
|
|
|
|
+ }, {
|
|
|
|
+ randomNumber: worlds[i].randomNumber
|
|
|
|
+ }, callback);
|
|
|
|
+ });
|
|
|
|
+ })(i);
|
|
}
|
|
}
|
|
|
|
|
|
- res.freeSync();
|
|
|
|
|
|
+ async.parallel(updateFunctions, function(err, updates) {
|
|
|
|
+ res.writeHead(200, {
|
|
|
|
+ 'Content-Type': 'application/json',
|
|
|
|
+ 'Server': 'Node'
|
|
|
|
+ });
|
|
|
|
+ res.end(JSON.stringify(worlds));
|
|
|
|
+ });
|
|
|
|
+ });
|
|
|
|
+ break;
|
|
|
|
+
|
|
|
|
+ // Sequelize (MySQL ORM) Routes
|
|
|
|
+ case '/mysql-orm':
|
|
|
|
+ var queryFunctions = [];
|
|
|
|
+ for (var i = 0; i < queries; i += 1) {
|
|
|
|
+ queryFunctions.push(sequelizeQuery);
|
|
|
|
+ }
|
|
|
|
|
|
- rows[0].randomNumber = getRandomNumber();
|
|
|
|
- libmysql.query("UPDATE World SET randomNumber = " + rows[0].randomNumber + " WHERE id = " + rows[0]['id'], function (err, res) {
|
|
|
|
- if (err) {
|
|
|
|
- throw err;
|
|
|
|
- }
|
|
|
|
- callback(null, rows[0]);
|
|
|
|
|
|
+ async.parallel(queryFunctions, function(err, results) {
|
|
|
|
+ if (!values.query.queries) {
|
|
|
|
+ results = results[0];
|
|
|
|
+ }
|
|
|
|
+ res.writeHead(200, {
|
|
|
|
+ 'Content-Type': 'application/json',
|
|
|
|
+ 'Server': 'Node'
|
|
});
|
|
});
|
|
|
|
+ res.end(JSON.stringify(results));
|
|
});
|
|
});
|
|
- });
|
|
|
|
- }
|
|
|
|
|
|
+ break;
|
|
|
|
|
|
- var values = url.parse(req.url, true);
|
|
|
|
- var queries = values.query.queries || 1;
|
|
|
|
- if(queries < 1) {
|
|
|
|
- queries = 1;
|
|
|
|
- } else if(queries > 500) {
|
|
|
|
- queries = 500;
|
|
|
|
- }
|
|
|
|
- var queryFunctions = new Array(queries);
|
|
|
|
|
|
+ case '/mysql-orm-update':
|
|
|
|
+ var selectFunctions = [];
|
|
|
|
+ for (var i = 0; i < queries; i += 1) {
|
|
|
|
+ selectFunctions.push(sequelizeQuery);
|
|
|
|
+ }
|
|
|
|
|
|
- for (var i = 0; i < queries; i += 1) {
|
|
|
|
- queryFunctions[i] = libmysqlQuery;
|
|
|
|
- }
|
|
|
|
- async.parallel(queryFunctions, function(err, results) {
|
|
|
|
- if (err) {
|
|
|
|
- res.writeHead(500);
|
|
|
|
- return res.end('MYSQL CONNECTION ERROR.');
|
|
|
|
- }
|
|
|
|
- res.end(JSON.stringify(results));
|
|
|
|
- });
|
|
|
|
- break;
|
|
|
|
|
|
+ async.parallel(selectFunctions, function(err, worlds) {
|
|
|
|
+ var updateFunctions = [];
|
|
|
|
|
|
- case '/update-mongodb':
|
|
|
|
- // Database Test
|
|
|
|
- var values = url.parse(req.url, true);
|
|
|
|
- var queries = values.query.queries || 1;
|
|
|
|
- if (queries < 1) {
|
|
|
|
- queries = 1;
|
|
|
|
- } else if (queries > 500) {
|
|
|
|
- queries = 500;
|
|
|
|
- }
|
|
|
|
|
|
+ for (var i = 0; i < queries; i++) {
|
|
|
|
+ (function(i){
|
|
|
|
+ updateFunctions.push(function(callback){
|
|
|
|
+ worlds[i].randomNumber = Math.ceil(Math.random() * 10000);
|
|
|
|
+ worlds[i].save().complete(callback);
|
|
|
|
+ });
|
|
|
|
+ })(i);
|
|
|
|
+ }
|
|
|
|
|
|
- var queryFunctions = new Array(queries);
|
|
|
|
|
|
+ async.parallel(updateFunctions, function(err, updates) {
|
|
|
|
+ res.writeHead(200, {
|
|
|
|
+ 'Content-Type': 'application/json',
|
|
|
|
+ 'Server': 'Node'
|
|
|
|
+ });
|
|
|
|
+ res.end(JSON.stringify(worlds));
|
|
|
|
+ });
|
|
|
|
+ });
|
|
|
|
+ break;
|
|
|
|
|
|
- for (var i = 0; i < queries; i += 1) {
|
|
|
|
- queryFunctions[i] = mongodbDriverUpdateQuery;
|
|
|
|
- }
|
|
|
|
|
|
+ // Raw MongoDB Routes
|
|
|
|
+ case '/mysql':
|
|
|
|
+ var queryFunctions = [];
|
|
|
|
+ for (var i = 0; i < queries; i += 1) {
|
|
|
|
+ queryFunctions.push(mysqlQuery);
|
|
|
|
+ }
|
|
|
|
|
|
- res.writeHead(200, {'Content-Type': 'application/json; charset=UTF-8'});
|
|
|
|
|
|
+ async.parallel(queryFunctions, function(err, results) {
|
|
|
|
+ if (!values.query.queries) {
|
|
|
|
+ results = results[0];
|
|
|
|
+ }
|
|
|
|
+ res.writeHead(200, {
|
|
|
|
+ 'Content-Type': 'application/json',
|
|
|
|
+ 'Server': 'Node'
|
|
|
|
+ });
|
|
|
|
+ res.end(JSON.stringify(results));
|
|
|
|
+ });
|
|
|
|
+ break;
|
|
|
|
|
|
- async.parallel(queryFunctions, function(err, results) {
|
|
|
|
- res.end(JSON.stringify(results));
|
|
|
|
- });
|
|
|
|
- break;
|
|
|
|
|
|
+ case '/mysql-update':
|
|
|
|
+ var queryFunctions = [];
|
|
|
|
+ for (var i = 0; i < queries; i += 1) {
|
|
|
|
+ queryFunctions.push(mysqlUpdateQuery);
|
|
|
|
+ }
|
|
|
|
+ async.parallel(queryFunctions, function(err, results) {
|
|
|
|
+ res.writeHead(200, {
|
|
|
|
+ 'Content-Type': 'application/json',
|
|
|
|
+ 'Server': 'Node'
|
|
|
|
+ });
|
|
|
|
+ res.end(JSON.stringify(results));
|
|
|
|
+ });
|
|
|
|
+ break;
|
|
|
|
|
|
- default:
|
|
|
|
- // File not found handler
|
|
|
|
- res.writeHead(501, {'Content-Type': 'text/plain; charset=UTF-8'});
|
|
|
|
- res.end("NOT IMPLEMENTED");
|
|
|
|
- }
|
|
|
|
-}).listen(8080);
|
|
|
|
|
|
+ default:
|
|
|
|
+ // File not found handler
|
|
|
|
+ res.writeHead(501, {'Content-Type': 'text/plain; charset=UTF-8'});
|
|
|
|
+ res.end("NOT IMPLEMENTED");
|
|
|
|
+ }
|
|
|
|
+ }).listen(8080);
|
|
|
|
+}
|