Untitled

var http = require( 'http' );
var url = require( 'url' );

var mysql = require( 'mysql2' );

var m = mysql.createConnection( {
		host: 'localhost',
		user: 'root',
		password: '1234',
		database: 'test',
} );
// create table test( word1 char( 5 ), word2 char( 5 ), value int, count int, unique key w ( word1, word2 ) );

var repeat = makeinserts();

function makeinserts () {
	insertsql( null, function( error, sql ) {
		doquery( null, sql, function( error, qres ) {} );
	} );
	setTimeout( makeinserts, 250 + r( 1, 1750 ) );
};

http.createServer( function( request, response ) {

	doquery( null, "SELECT * FROM test", function( error, qres ) {

		var header = "";
		header += "<html><head>\n";
		header += "<meta http-equiv=\"refresh\" content=\"1\">\n";
		header += "</head>\n<body><pre>\n";

		var tablehead = "<b>\#</b>\t";
		var dotablehead = 0;

		var numerated = 0;
		var table = "";

		for ( var i = 0; i < qres.length; i++ ) {

			Object.keys( qres[ i ] ).forEach( function ( k ) {
				if ( !dotablehead ) { tablehead += "<b>" + k + "</b>\t"; }
				if ( !numerated ) { table += "<b>" + ( i + 1 ) + "</b>\t"; numerated++; }
				table += qres[ i ][ k ] + "\t";
			} );

			dotablehead++;

			numerated--;
			table += "\n";
		}

		tablehead += "\n";

		var data = header + tablehead + table;

		response.writeHead( 200, { 'Content-Type': 'text/html' } );
		response.write( data );

		response.end();

	} );
} ).listen(8888);

function doquery( error, q, callback ) {
	m.query( q, function( err, res, fields ) {
		if ( err ) { callback( err, null ); }
		callback( null, res )
	} );
}

function r ( a, b ) { return Math.floor( Math.random() * ( b - a + 1 ) + a ); }

function insertsql ( error, callback ) {

	var sql = "INSERT INTO test \( word1, word2, value, count \) VALUES \(";

	var first = [ "hello", "salut", "aloha", "greet", "bonjr", ];
	var last = [ "world", "peopl", "unive", "human", "ever1", ];

	var word1 = first[ r( 0, 4 ) ];
	var word2 = last[ r( 0, 4 ) ];
	var value = r( 1, 20 );
	var count = 1;

	sql += " \"" + word1 + "\", \"" + word2 + "\", " + value + ", " + count + " \) ";
	sql += "ON DUPLICATE KEY UPDATE value = " + value + ", count = count + 1";

	callback( null, sql );
}