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

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

然后创建user数据表:

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

接着使用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:

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

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