nodejs操作mysql实现增删改查数据操作

首先需要安装mysql模块：npm install mysql --save

然后创建user数据表：

接着使用nodejs对数据库进行增删改查：

[javascript] view plain copy

1. //引入mysql模块  
2. var mysql = require('mysql');  
3. //链接数据库  
4. var connection = mysql.createConnection({  
5.     host:'localhost',  
6.     user:'root',  
7.     password:'root',  
8.     database:'node',  
9. })  
10. connection.connect();  
11. //查询数据  
12. var sql = 'SELECT * FROM user';  
13. connection.query(sql,function (err,result) {  
14.     if(err){  
15.         console.log('error');  
16.         return;  
17.     }  
18.     console.log('-----------------查询----------------');  
19.     console.log(result);  
20.     console.log('-----------------查询结束----------------');  
21. })  
22.   
23. //增加数据  
24. var addsql = 'INSERT INTO user(name,age,sex) VALUES(?,?,?)';  
25. var addsqlparams = ['汪丹萍','24','女'];  
26. connection.query(addsql,addsqlparams,function (err,result) {  
27.     if(err){  
28.         console.log('error');  
29.         return;  
30.     }  
31.     console.log('-----------------新增成功----------------');  
32.     console.log(result);  
33.     console.log('-----------------结束----------------');  
34. })  
35.   
36. //修改数据  
37. var modsql = 'UPDATE user SET name = ?,age = ? WHERE id = ?';  
38. var modsqlparams = ['吕雪源love','26','1'];  
39. connection.query(modsql,modsqlparams,function (err,result) {  
40.     if(err){  
41.         console.log('err');  
42.         return;  
43.     }  
44.     console.log('--------------------------------');  
45.     console.log(result);  
46.     console.log('--------------------------------');  
47. })  
48.   
49. //删除数据  
50. var delsql = 'DELETE FROM user where id = 2';  
51. connection.query(delsql,function (err,result) {  
52.     if(err){  
53.         console.log('err');  
54.         return;  
55.     }  
56.     console.log('----------删除-------------');  
57.     console.log(result);  
58. })  
59.   
60.   
61. connection.end();  

最后运行js：

增删改查都已经执行成功了。