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
var firstResult = results[i];
console.log('id: ' + firstResult['id']+' name: ' + firstResult['name']);
}
}
);
client.end();
console.log('關閉MySQL連接配接...');
};
clientConnectionReady(client);