var mysql = require('mysql');
//创建连接
var connection = mysql.createConnection({host : 'localhost', //主机名
user : 'root', //用户名
password : '123', 密码
database : 'test' //数据库名
});
//连接
connection.connect();
connection.query('select * from person', function (error) {
if (error) throw error;
console.log("连接成功");
});
//查询
var sql = 'select * from person';
// result 输出数据库表
connection.query(sql,function (err, result) {
if(err){
console.log(err.message);
return;
}
console.log('--------------------------SELECT----------------------------');
console.log(result);
console.log('------------------------------------------------------------\n\n');
});
connection.end();
// 增加
var sql1= 'insert into person(id,name,sex) values (?,?,?)';
var sqlvaule = [3,"王五","男"];
connection.query(sql1,sqlvaule,function (err,result) {
if(err){
console.log(err.message);
return;
}
console.log('--------------------------INSERT----------------------------');
console.log("增加成功");
console.log('------------------------------------------------------------\n\n');
});
connection.end();
//删除
var sql2 = "delete from person where id=2";
connection.query(sql2,function (err,result) {
if(err){
console.log(err.massage);
return;
}
console.log('--------------------------DELETE----------------------------');
console.log("删除成功");
console.log('-----------------------------------------------------------------\n\n');
});
connection.end();
//修改
var sql3 = "update person set id = 1,name = ?";
var sql3vaule = ["王五"];
connection.query(sql3,sql3vaule,function(err,result) {
if(err){
console.log(err.message);
return;
}
console.log('--------------------------UPDATE----------------------------');
console.log("修改成功");
console.log('-----------------------------------------------------------------\n\n');
});
connection.end(function () {
console.log("数据库已关闭")
});
数据库及其表