NodeJS对前端来说无疑具有里程碑意义,在其越来越流行的今天,掌握NodeJS已经不再是加分项,而是前端攻城师们必须要掌握的技能。本文将与同志们一起完成一个基于Express+MysqL的入门级服务端应用,即可以对数据库中的一张表进行简单的CRUD操作。但本人还是斗胆认为,通过这个应用,可以让没怎么接触后端开发的同志对使用Node进行后端开发有一个大致了解。
Express工程环境准备
1. 安装express,和express项目种子生成器(什么?你问第1步为什么不是安装NodeJS,我也只能呵呵..)
安装express
安装express
2. 创建工程。进入工程目录,运行命令
expresst项目种子生成器会帮我们生成express相应的工程结构,如下
/bin: 用于应用启动
/public: 静态资源目录
/routes:可以认为是controller(控制器)目录
/views: jade模板目录,可以认为是view(视图)目录
app.js 程序main文件
3. 进入工程,安装依赖,然后启动应用在工程根目录,使用npm install安装依赖,使用npm start启动应用。完成后,你在命令行工具里会看出如下界面,在浏览器中访问会得到我们应用的默认页面
MysqL环境准备
1. 当然,首先你要准备好MysqL环境。可以参看进行安装,同时也建议安装一个数据库管理工具,如navicat for MysqL,方便操作
2. 创建表MysqL安装好了后,进入到数据库,创建要用到的表(如user),结构如下
3. 安装Node的MysqL驱动(请允许装X一下…)在package.json的dependencies中新增,“MysqL” : “latest”, 并执行npm install安装依赖
编写相关代码,整合Express+MysqL
1. 首先,我们先建几个目录,简单分下层(看出我还是很用心木有?)
在工程根目录新增三个目录:
util – 工具方法
conf – 配置
dao – 与数据库交互
完成后的工程结构
2. 编写CRUD sql语句
module.exports = user;
以C(新增)的具体实现举例,在/routes/users.js 中增加一个路由
在userDao中实现add方法
// 使用连接池,提升性能
var pool = MysqL.createPool($util.extend({},$conf.MysqL));
// 向前台返回JSON方法的简单封装
var jsonWrite = function (res,ret) {
if(typeof ret === 'undefined') {
res.json({
code:'1',msg: '操作失败'
});
} else {
res.json(ret);
}
};
module.exports = {
add: function (req,next) {
pool.getConnection(function(err,connection) {
// 获取前台页面传过来的参数
var param = req.query || req.params;
// 建立连接,向表中插入值
// 'INSERT INTO user(id,connection.query($<a href="/tag/sql/" target="_blank" class="keywords">sql</a>.insert,[param.name,param.age],function(err,result) {
if(result) {
result = {
code: 200,msg:'增加成功'
};
}
// 以json形式,把操作结果返回给<a href="/tag/qiantai/" target="_blank" class="keywords">前台</a><a href="/tag/yemian/" target="_blank" class="keywords">页面</a>
jsonWrite(res,result);
// 释放连接
connection.release();
});
});
}
};
4. 测试整合是否成功
因为前面实现的是一个get请求的add方法, 所以可以在浏览器中直接使用地址访问,进入路由,http://localhost:3000/users/addUser?name=xyz&age=18.如果你得到如下JSON返回或看到数据表中有上面的数据插入,表示整合成功了
5. 同理,实现CRUD其它的方法,最终完整的的routes/user.js为:
/ GET users listing. /
router.get('/',next) {
res.send('respond with a resource');
});
// 增加用户
//TODO 同时支持get,post
router.get('/addUser',next);
});
router.get('/queryAll',next) {
userDao.queryAll(req,next);
});
router.get('/query',next) {
userDao.queryById(req,next);
});
router.get('/deleteUser',next) {
userDao.delete(req,next);
});
router.post('/updateUser',next) {
userDao.update(req,next);
});
module.exports = router;
完整的userDao.js为
var pool = mysql.createPool($util.extend({},result);
// 释放连接
connection.release();
});
});
},delete: function (req,next) {
// delete by Id
pool.getConnection(function(err,connection) {
var id = +req.query.id;
connection.query($sql.delete,id,result) {
if(result.affectedRows > 0) {
result = {
code: 200,msg:'删除成功'
};
} else {
result = void 0;
}
jsonWrite(res,result);
connection.release();
});
});
},update: function (req,next) {
// update by id
// 为了简单,要求同时传name和age两个参数
var param = req.body;
if(param.name == null || param.age == null || param.id == null) {
jsonWrite(res,undefined);
return;
}
pool.getConnection(function(err,connection) {
connection.query($<a href="/tag/sql/" target="_blank" class="keywords">sql</a>.update,param.age,+param.id],result) {
// 使用<a href="/tag/yemian/" target="_blank" class="keywords">页面</a>进行<a href="/tag/tiaozhuan/" target="_blank" class="keywords">跳转</a><a href="/tag/tishi/" target="_blank" class="keywords">提示</a>
if(result.affectedRows > 0) {
res.render('suc',{
result: result
}); // 第二个参数可以直接在jade中使用
} else {
res.render('fail',{
result: result
});
}
connection.release();
});
});
},queryById: function (req,next) {
var id = +req.query.id; // 为了拼凑正确的<a href="/tag/sql/" target="_blank" class="keywords">sql</a>语句,这里要转下整数
pool.getConnection(function(err,connection) {
connection.query($<a href="/tag/sql/" target="_blank" class="keywords">sql</a>.queryById,result) {
jsonWrite(res,result);
connection.release();
});
});
},queryAll: function (req,connection) {
connection.query($<a href="/tag/sql/" target="_blank" class="keywords">sql</a>.queryAll,result);
connection.release();
});
});
}
};
除了update测试外,其它get请求都可以直接在浏览器中使用地址+参数完成测试。为了模拟post请求,同时简单使用下jade模板(Express支持的一种模板引擎),我们在/views目录新建三个jade文件
updateUser.jade
suc.jade
fail.jade
以下是更新测试结果
最后,如果你使用的是idea或webStrom这样的IDE,你就不需要安装express和express项目种子生成器了。这两个IDE是可以直接创建NodeJS项目
小结:
一个Express的helloWorld就差不多完成了,可以通过这个链接下载此例子源代码http://pan.baidu.com/s/1jGvd4Bc。更多Express的功能(如日志,自动化测试等),等待大家去解锁,愿玩得愉快!