Node 一个简单的HttpServer+Mysql的后台

createServer();

function createServer(){
	//使用express创建HTTP服务器
	var express = require('express');
	var bodyParser = require('body-parser');
	var app = express();
	var server = require('http').createServer(app);
	var PORT = process.env.PORT || 8002;
	server.listen(PORT);
	console.log('Server running.');

	//连接mysql
	var mysql = require('mysql');
	var conn = mysql.createConnection({
	    host: 'localhost',
	    user: 'root',
	    password: 'root',
	    database:'NodeDB',
	    port: 8889
	});
	conn.connect();
	console.log("Connect Mysql Success");

	// conn.end();
	setupRoute();
	//设定路由
	function setupRoute(){
		//使用body-parser解析body参数
		app.use(bodyParser.urlencoded({   
  			extended: true
		}));

		app.get('/getdemo', function (req, res) { 
			res.contentType('json');//返回的数据类型
			console.log("Get method");
			// console.log(req.query); 
			var selectSQL = 'SELECT * from UserTB where account = "'+req.query.account+'"';
			//select
			conn.query(selectSQL, function (err, rows) {
			 	if (err) console.log(err);
				console.log("SELECT ==> ");
			    for (var i in rows) {
			    	console.log(rows[i]);
			    	res.send(JSON.stringify(rows[i]));//给客户端返回一个json格式的数据
			    }
			});
		}); 

		app.post('/postdemo', function (req, res) { 
			res.contentType('json');//返回的数据类型
			console.log("Post method");
			console.log(req.body); 
			var selectSQL = 'SELECT * from UserTB where account = "'+req.body.account+'"';
			//select
			conn.query(selectSQL, function (err, rows) {
			 	if (err) console.log(err);
				console.log("SELECT ==> ");
			    for (var i in rows) {
			    	console.log(rows[i]);
			    	res.send(JSON.stringify(rows[i]));//给客户端返回一个json格式的数据
			    }
			}); 
		}); 
	}
}