nodejs之mysql查詢

示例代碼中的mysql版本 2.14.1

參考代碼

/**
 * 測試mysql連接
 */

var mysql = require('mysql');
var connection = mysql.createConnection({
  host     : 'localhost',  //服務器
  user     : 'root', //用戶名
  password : 'root', //密碼
  database : 'mysql' //數據庫
});
connection.connect(function(err) {
    if(err) {
        console.error('error connecting: ' + err.stack);
        return;
    }
    console.log('connected as id ' + connection.threadId);
});

var http = require('http');

var server = http.createServer(function(request, response){
    response.writeHeader(200, {'Content-type': 'text/html'});
    // 查詢User為root的用戶
    connection.query('SELECT * FROM user WHERE User = ?', ['root'], function(err, results, fields){
        if(err) {
            throw err;
        }
        var data = '';
        for (var i = 0; i < results.length; i++) {
            var firstResult = results[i];
            data += 'User: '+ firstResult['User'] + '&nbsp;&nbsp;Password: ' + firstResult['Password'] + '<br>';
        }

        response.write(data);
        response.end();

    });
});

server.listen(8080);

var sys = require('util');
sys.puts('Server running at http://localhost:8080/');