【Nodejs】Nodejs连接Mysql初级操作CURD

//数据库名称
var TEST_TABLE = "person";
//表名
var TEST_DATABASE = "shixun";

var mysql = require('mysql');
//创建连接
var client = mysql.createConnection({
user: 'root',
password: 'root',
});
//建立连接
client.connect();
//使用某数据库
client.query("use " + TEST_DATABASE);
//插入方式一
client.query(
'INSERT INTO '+ TEST_TABLE + ' ' + 'SET FirstName = ?, LastName = ?',
['张', '三'],
function (err, result){
if(err){
console.log('[INSERT ERROR] - ', err.message);
return;
}
console.log('-------INSERT----------');
console.log('INSERT :',result);
}
);
//插入方式二
client.query(
'INSERT INTO '+ TEST_TABLE + '(FirstName, LastName) values(?,?)',
['李', '四'],
function (err, result){
if(err){
console.log('[INSERT ERROR] - ', err.message);
return;
}
console.log('-------INSERT----------');
console.log('INSERT :',result);
}
);
//查询
client.query(
'SELECT * FROM '+ TEST_TABLE,
function selectCb(err, results, fields) {
if (err) {
throw err;
}
console.log("添加后查询结果如下");
if(results)
{
for(var i = 0; i < results.length; i++)
{
console.log("PersonId: %d ,\tFirstName: %s ,\tLastName: %s", results[i].PersonId ,results[i].FirstName, results[i].LastName);
}
}
}
);
//修改
client.query(
'UPDATE '+ TEST_TABLE + ' set FirstName = ?, LastName = ? where FirstName=?',
['李', '九', '李']
);
//查询
client.query(
'SELECT * FROM '+ TEST_TABLE,
function selectCb(err, results, fields) {
if (err) {
throw err;
}
console.log("修改后查询结果如下");
if(results)
{
for(var i = 0; i < results.length; i++)
{
console.log("PersonId: %d ,\tFirstName: %s ,\tLastName: %s", results[i].PersonId ,results[i].FirstName, results[i].LastName);
}
}
}
);
//删除
client.query(
'DELETE FROM '+ TEST_TABLE + ' where FirstName=?',
['李', '九', '李']
);

//查询
client.query(
'SELECT * FROM '+ TEST_TABLE,
function selectCb(err, results, fields) {
if (err) {
throw err;
}
console.log("修改后查询结果如下");
if(results)
{
for(var i = 0; i < results.length; i++)
{
console.log("PersonId: %d ,\tFirstName: %s ,\tLastName: %s", results[i].PersonId ,results[i].FirstName, results[i].LastName);
}
}
client.end();
}
);

console.log("程序执行结束!");
console.log("-------------");