1. 程式人生 > >nodejs操作mysql實現增刪改查資料操作

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. var addsql = 'INSERT INTO user(name,age,sex) VALUES(?,?,?)';  
  24. var addsqlparams = ['汪丹萍','24','女'];  
  25. connection.query(addsql,addsqlparams,function (err,result) {  
  26.     if(err){  
  27.         console.log('error');  
  28.         return;  
  29.     }  
  30.     console.log('-----------------新增成功----------------'
    );  
  31.     console.log(result);  
  32.     console.log('-----------------結束----------------');  
  33. })  
  34. //修改資料
  35. var modsql = 'UPDATE user SET name = ?,age = ? WHERE id = ?';  
  36. var modsqlparams = ['呂雪源love','26','1'];  
  37. connection.query(modsql,modsqlparams,function (err,result) {  
  38.     if(err){  
  39.         console.log('err');  
  40.         return;  
  41.     }  
  42.     console.log('--------------------------------');  
  43.     console.log(result);  
  44.     console.log('--------------------------------');  
  45. })  
  46. //刪除資料
  47. var delsql = 'DELETE FROM user where id = 2';  
  48. connection.query(delsql,function (err,result) {  
  49.     if(err){  
  50.         console.log('err');  
  51.         return;  
  52.     }  
  53.     console.log('----------刪除-------------');  
  54.     console.log(result);  
  55. })  
  56. connection.end();  

最後執行js:


增刪改查都已經執行成功了。