Node.js 连接 MySQL 并进行数据库操作

var mysql      = require('mysql');
var connection = mysql.createConnection({
host     : '10.58.187.217',//远程MySQL数据库的ip地址
user     : 'root',
password : '123456',
});

//试试有米有连接上mysql
connection.connect(function(error, results) {
if(error) {
console.log('Connection Error: ' + error.message);
return;
}
console.log('Connected to MySQL');
ClientConnectionReady(connection);
});

//试试有米有连接上test数据库
ClientConnectionReady = function(connection)
{
connection.query('USE test', function(error, results) {
if(error) {
console.log('ClientConnectionReady Error: ' + error.message);
connection.end();
return;
}
console.log("connect test");
//ClientReady(connection);
GetData(connection);
});
};

//向test数据库中的goods表中插入数据
ClientReady = function(connection)
{
var values = [6000, 'mac'];
connection.query('INSERT INTO goods SET price = ?, goodName = ?', values,
function(error, results) {
if(error) {
console.log("ClientReady Error: " + error.message);
connection.end();
return;
}
console.log('Inserted: ' + results.affectedRows + ' row.');
console.log('Id inserted: ' + results.insertId);
}
);
GetData(connection);
}

//展示test数据库中的goods表的所有数据
GetData = function(connection) {
connection.query(
'SELECT * FROM goods',
function selectCb(error, results, fields) {
if (error) {
console.log('GetData Error: ' + error.message);
connection.end();
return;
}
console.log("connect goods");
console.log(results);
if (results.length > 0) {
var firstResult = results[results.length-1];
//console.log('price: ' + firstResult['price']);
//console.log('goodName: ' + firstResult['goodName']);
}
})
}