nodeJS连接MySQL数据库

nodeJS连接MySQL数据库，首先创建一个数据库及表。如下： 

create databases node;

create table test( id int AUTO_INCREMENT PRIMARY KEY , name char(50) )ENGINE=InnoDB DEFAULT CHARSET=utf8;

安装MySQL驱动： 

$ npm install mysql

下面是nodeJS代码： 

var sys = require(‘util‘); 
console.log(‘正在连接MySQL...‘); 
var client = require(‘mysql‘).createClient({‘host‘:‘localhost‘,‘port‘:3306,‘user‘:‘root‘,‘password‘:‘xxx‘});

clientConnectionReady = function(client) 
{
    client.query(‘use node‘, function(error, results) { 
        if(error) { 
            console.log(‘ClientConnectionReady Error: ‘ + error.message); 
            client.end(); 
            return; 
        }else{
 	    console.log(‘已经连接上MySQL....‘);
	} 
        clientReady(client); 
    }); 
};

clientReady = function(client) { 
    var values = [‘不错啊‘]; 
    client.query(‘insert into test set name = ?‘, values, 
        function(error, results) { 
            if(error) { 
                console.log("ClientReady Error: " + error.message); 
                client.end(); 
                return; 
            } 
            console.log(‘Inserted: ‘ + results.affectedRows + ‘ row.‘); 
            console.log(‘Id inserted: ‘ + results.insertId); 
        } 
    ); 
    getData(client); 
}

getData = function(client) { 
    client.query( 
        ‘select * from test‘, 
        function selectCb(error, results, fields) { 
           if (error) { 
                console.log(‘GetData Error: ‘ + error.message); 
                client.end(); 
                return; 
           } 

	   for(var i=0; i<results.length; i++){
		var firstResult = results[i]; 
        	console.log(‘id: ‘ + firstResult[‘id‘]+‘    name: ‘ + firstResult[‘name‘]);
	   }

    	}
    ); 
    client.end(); 
    console.log(‘关闭MySQL连接...‘); 
};



clientConnectionReady(client);