Node.js操作mysql数据库增删改查

关于node.js操作mysql数据库的相关介绍请阅读全文吧。下文介绍的非常详细，具体内容如下所示：
安装mysql模块

npm install mysql

数据库准备
mysql server所在的机器IP地址是192.168.0.108，登录账户就用root@123456

在mysql中创建test数据库

在test数据库中创建一张users表

操作
连接数据库

var mysql=require（"mysql"）;var connection = mysql.createConnection（{host : "192.168.0.108",user : "root",password : "123456",database : "test1",port:"3306"}）;connection.connect（）;

插入一个user

var usr={name:"zhangsan",password:"pwdzhangsan",mail:"zhangsan@gmail.com"};connection.query（"insert into users set ?", usr, function（err, result） {if （err） throw err;console.log（"inserted zhangsan"）;console.log（result）;console.log（"
"）;}）;

更新user，带条件

connection.query（"update users set password="ddd" where name="zhangsan"", {password:"ppp"}, function（err, result） {if （err） throw err;console.log（"updated zhangsan"s password to ddd"）;console.log（result）;console.log（"
"）;}）;

删除一个user，带条件

connection.query（"delete from users where name="zhangsan"", {password:"ppp"}, function（err, result） {if （err） throw err;console.log（"deleted zhangsan"）;console.log（result）;console.log（"
"）;}）;

查询user，所有

connection.query（"select * from users", function（err, rows, fields） {if （err） throw err;console.log（"selected after deleted"）;for（var i= 0,usr;usr=rows[i++];）{console.log（"user nae="+usr.name + ", password="+usr.password）;}console.log（"
"）;}）;

关闭数据库连接
connection.end（）;

基本的CRUD完成
mysql模块的完整功能说明参见官方：

https://www.npmjs.com/package/mysql

https://github.com/felixge/node-mysql

全部demo代码

var mysql=require（"mysql"）;var connection = mysql.createConnection（{host : "192.168.0.108",user : "root",password : "123456",database : "test1",port:"3306"}）;connection.connect（）;var usr={name:"zhangsan",password:"pwdzhangsan",mail:"zhangsan@gmail.com"};connection.query（"insert into users set ?", usr, function（err, result） {if （err） throw err;console.log（"inserted zhangsan"）;console.log（result）;console.log（"
"）;}）;connection.query（"select * from users", function（err, rows, fields） {if （err） throw err;console.log（"selected after inserted"）;for（var i= 0,usr;usr=rows[i++];）{console.log（"user nae="+usr.name + ", password="+usr.password）;}console.log（"
"）;}）;connection.query（"update users set password="ddd" where name="zhangsan"", {password:"ppp"}, function（err, result） {if （err） throw err;console.log（"updated zhangsan"s password to ddd"）;console.log（result）;console.log（"
"）;}）;connection.query（"select * from users", function（err, rows, fields） {if （err） throw err;console.log（"selected after updated"）;for（var i= 0,usr;usr=rows[i++];）{console.log（"user nae="+usr.name + ", password="+usr.password）;}console.log（"
"）;}）;connection.query（"delete from users where name="zhangsan"", {password:"ppp"}, function（err, result） {if （err） throw err;console.log（"deleted zhangsan"）;console.log（result）;console.log（"
"）;}）;connection.query（"select * from users", function（err, rows, fields） {if （err） throw err;console.log（"selected after deleted"）;for（var i= 0,usr;usr=rows[i++];）{console.log（"user nae="+usr.name + ", password="+usr.password）;}console.log（"
"）;}）;connection.end（）;