不管node仍是java增刪改查都是同樣的原理,變得是配合框架使用時候有簡便方法而已。javascript
這裏我接着上一篇開始講,使用同一個數據庫(數據庫建立方法單獨說)這裏必須建立了數據庫前端
優化:爲了維護方便這裏咱們把sql語句提出來放在一個對象裏面,只有要改變的參數放在請求接口的router裏面java
首先在routes文件夾裏面建立userSql.js,在裏面建立一個對象,再導出node
var SQL = { inset:{// 增 actorIn:'INSERT INTO actor(first_name,last_name) VALUES(?,?)' // actor是數據庫的表名 first_name,last_name是其中的兩個字段名,id通常設爲自增 }, delete:{// 刪 actorDel:'DELETE FROM actor where actor_id = ?' // 通常惟一標識是id而且自增,我改成了actor_id(最好不要變) }, change:{// 改 actorCh:'UPDATE actor SET first_name=?,last_name=? WHERE actor_id=?' //修改惟一標識actor_id爲幾的first_name和last_name值 }, check:{// 查 actorCk:'SELECT * FROM actor', //查詢全部使用*,actor是表名 actorId:'SELECT * FROM actor WHERE actor_id=?', //查詢惟一標識actor_id=x的全部字段 actorAll:'SELECT first_name FROM actor', //查詢actor表裏面的全部first_name字段 actorId:'SELECT first_name FROM actor WHERE actor_id=?' //查詢惟一標識actor_id=x的全部first_name字段 } } module.exports = SQL;
而後咱們在user.js裏面導入mysql
var userSql = require('./userSql.js')
1、增sql
在user.js裏面咱們建立一個添加的router。數據庫
router.post('/add', function(req, res, next) { var addValue = ['kk','MM']//參數是對應first_name,last_name的值,前端調用接口post方法是使用req.body.xx獲取的參數
// query()第一個是語句,第二個是參數 mysql.query(userSql.inset.actorIn,addValue, function (error, results) { // 增 if (error) throw error; res.json({ code:0, data:'成功' }) }); mysql.end();//關閉mysql鏈接 上篇文章中把mysql鏈接提取出來了,這裏就沒寫 });
2、刪json
在user.js裏面咱們建立一個刪除的router框架
router.post('/del', function(req, res, next) { var delValue = 4 // 這裏是刪除的行惟一標識,通常是id,這裏改成了actor_id mysql.query(userSql.delete.actorDel,delValue, function (error, results) { // 刪 if (error) throw error; res.json({ code:0, data:'成功' }) }); mysql.end(); });
3、改post
在user.js裏面咱們建立一個修改的router
router.post('/change', function(req, res, next) { var addValue = ['aa','22',3] // 前兩個對應first_name,last_name,actor_id=3 mysql.query(userSql.change.actorCh,addValue, function (error, results) { // 改 if (error) throw error; res.json({ code:0, data:'成功' }) }); mysql.end(); });
4、查
在user.js裏面咱們建立一個查詢的router
router.get('/check', function(req, res, next) { //查詢通常使用get方法,獲取前端傳來參數使用req.query.xx mysql.query(userSql.check.actorCk,1, function (error, results, fields) { // 查 if (error) throw error; res.json({ code:0, data:results }) }); mysql.end(); });