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);