不管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(); });