初識(shí)NodeJS服務(wù)端開發(fā)入門（Express+MySQL）
NodeJS對(duì)前端來(lái)說(shuō)無(wú)疑具有里程碑意義，在其越來(lái)越流行的今天，掌握NodeJS已經(jīng)不再是加分項(xiàng)，而是前端攻城師們必須要掌握的技能。本文將與同志們一起完成一個(gè)基于Express+MySQL的入門級(jí)服務(wù)端應(yīng)用，即可以對(duì)數(shù)據(jù)庫(kù)中的一張表進(jìn)行簡(jiǎn)單的CRUD操作。但本人還是斗膽認(rèn)為，通過(guò)這個(gè)應(yīng)用，可以讓沒(méi)怎么接觸后端開發(fā)的同志對(duì)使用Node進(jìn)行后端開發(fā)有一個(gè)大致了解。
Express工程環(huán)境準(zhǔn)備
1. 安裝express，和express項(xiàng)目種子生成器（什么？你問(wèn)第1步為什么不是安裝NodeJS，我也只能呵呵..）
安裝express
npm install express -g
安裝express
npm install express-generator -g
2. 創(chuàng)建工程。進(jìn)入工程目錄，運(yùn)行命令
express projectName
expresst項(xiàng)目種子生成器會(huì)幫我們生成express相應(yīng)的工程結(jié)構(gòu)，如下
/bin: 用于應(yīng)用啟動(dòng)
/public: 靜態(tài)資源目錄
/routes：可以認(rèn)為是controller（控制器）目錄
/views: jade模板目錄，可以認(rèn)為是view(視圖)目錄
app.js 程序main文件
3. 進(jìn)入工程，安裝依賴，然后啟動(dòng)應(yīng)用在工程根目錄，使用npm install安裝依賴，使用npm start啟動(dòng)應(yīng)用。完成后，你在命令行工具里會(huì)看出如下界面，在瀏覽器中訪問(wèn)會(huì)得到我們應(yīng)用的默認(rèn)頁(yè)面
MySQL環(huán)境準(zhǔn)備
1. 當(dāng)然，首先你要準(zhǔn)備好MySQL環(huán)境。可以參看http://chabaoo.cn/article/39188.htm進(jìn)行安裝，同時(shí)也建議安裝一個(gè)數(shù)據(jù)庫(kù)管理工具，如navicat for mysql,方便操作
2. 創(chuàng)建表MySQL安裝好了后，進(jìn)入到數(shù)據(jù)庫(kù)，創(chuàng)建要用到的表(如user), 結(jié)構(gòu)如下
3. 安裝Node的MySQL驅(qū)動(dòng)（請(qǐng)?jiān)试S裝X一下…）在package.json的dependencies中新增, “mysql” : “l(fā)atest”， 并執(zhí)行npm install安裝依賴
編寫相關(guān)代碼，整合Express+MySQL
1. 首先，我們先建幾個(gè)目錄，簡(jiǎn)單分下層（看出我還是很用心木有？）
在工程根目錄新增三個(gè)目錄：
util – 工具方法
conf – 配置
dao – 與數(shù)據(jù)庫(kù)交互
完成后的工程結(jié)構(gòu)
2.在conf目錄中，編寫mySQL數(shù)據(jù)庫(kù)連接配置
// conf/db.js
// MySQL數(shù)據(jù)庫(kù)聯(lián)接配置
module.exports = {
mysql: {
host: '127.0.0.1',
user: 'root',
password: '',
database:'test', // 前面建的user表位于這個(gè)數(shù)據(jù)庫(kù)中
port: 3306
}
};
2. 編寫CRUD SQL語(yǔ)句
// dao/userSqlMapping.js
// CRUD SQL語(yǔ)句
var user = {
insert:'INSERT INTO user(id, name, age) VALUES(0,?,?)',
update:'update user set name=?, age=? where id=?',
delete: 'delete from user where id=?',
queryById: 'select * from user where id=?',
queryAll: 'select * from user'
};
module.exports = user;
3. 增加路由及實(shí)現(xiàn)數(shù)據(jù)庫(kù)的CRUD
以C（新增）的具體實(shí)現(xiàn)舉例，在/routes/users.js 中增加一個(gè)路由
// 增加用戶
router.get('/addUser', function(req, res, next) {
userDao.add(req, res, next);
});
在userDao中實(shí)現(xiàn)add方法
// dao/userDao.js
// 實(shí)現(xiàn)與MySQL交互
var mysql = require('mysql');
var $conf = require('../conf/conf');
var $util = require('../util/util');
var $sql = require('./userSqlMapping');
// 使用連接池，提升性能
var pool = mysql.createPool($util.extend({}, $conf.mysql));
// 向前臺(tái)返回JSON方法的簡(jiǎn)單封裝
var jsonWrite = function (res, ret) {
if(typeof ret === 'undefined') {
res.json({
code:'1',
msg: '操作失敗'
});
} else {
res.json(ret);
}
};
module.exports = {
add: function (req, res, next) {
pool.getConnection(function(err, connection) {
// 獲取前臺(tái)頁(yè)面?zhèn)鬟^(guò)來(lái)的參數(shù)
var param = req.query || req.params;
// 建立連接，向表中插入值
// 'INSERT INTO user(id, name, age) VALUES(0,?,?)',
connection.query($sql.insert, [param.name, param.age], function(err, result) {
if(result) {
result = {
code: 200,
msg:'增加成功'
};
}
// 以json形式，把操作結(jié)果返回給前臺(tái)頁(yè)面
jsonWrite(res, result);
// 釋放連接
connection.release();
});
});
}
};
4. 測(cè)試整合是否成功
因?yàn)榍懊鎸?shí)現(xiàn)的是一個(gè)get請(qǐng)求的add方法， 所以可以在瀏覽器中直接使用地址訪問(wèn)，進(jìn)入路由, http://localhost:3000/users/addUser?name=xyz&age=18.如果你得到如下JSON返回或看到數(shù)據(jù)表中有上面的數(shù)據(jù)插入，表示整合成功了
5. 同理，實(shí)現(xiàn)CRUD其它的方法，最終完整的的routes/user.js為：
var express = require('express');
var router = express.Router();
var userDao = require('../dao/userDao');
/* GET users listing. */
router.get('/', function(req, res, next) {
res.send('respond with a resource');
});
// 增加用戶
//TODO 同時(shí)支持get,post
router.get('/addUser', function(req, res, next) {
userDao.add(req, res, next);
});
router.get('/queryAll', function(req, res, next) {
userDao.queryAll(req, res, next);
});
router.get('/query', function(req, res, next) {
userDao.queryById(req, res, next);
});
router.get('/deleteUser', function(req, res, next) {
userDao.delete(req, res, next);
});
router.post('/updateUser', function(req, res, next) {
userDao.update(req, res, next);
});
module.exports = router;
完整的userDao.js為
// dao/userDao.js
// 實(shí)現(xiàn)與MySQL交互
var mysql = require('mysql');
var $conf = require('../conf/db');
var $util = require('../util/util');
var $sql = require('./userSqlMapping');
// 使用連接池，提升性能
var pool = mysql.createPool($util.extend({}, $conf.mysql));
// 向前臺(tái)返回JSON方法的簡(jiǎn)單封裝
var jsonWrite = function (res, ret) {
if(typeof ret === 'undefined') {
res.json({
code:'1',
msg: '操作失敗'
});
} else {
res.json(ret);
}
};
module.exports = {
add: function (req, res, next) {
pool.getConnection(function(err, connection) {
// 獲取前臺(tái)頁(yè)面?zhèn)鬟^(guò)來(lái)的參數(shù)
var param = req.query || req.params;
// 建立連接，向表中插入值
// 'INSERT INTO user(id, name, age) VALUES(0,?,?)',
connection.query($sql.insert, [param.name, param.age], function(err, result) {
if(result) {
result = {
code: 200,
msg:'增加成功'
};
}
// 以json形式，把操作結(jié)果返回給前臺(tái)頁(yè)面
jsonWrite(res, result);
// 釋放連接
connection.release();
});
});
},
delete: function (req, res, next) {
// delete by Id
pool.getConnection(function(err, connection) {
var id = +req.query.id;
connection.query($sql.delete, id, function(err, result) {
if(result.affectedRows > 0) {
result = {
code: 200,
msg:'刪除成功'
};
} else {
result = void 0;
}
jsonWrite(res, result);
connection.release();
});
});
},
update: function (req, res, next) {
// update by id
// 為了簡(jiǎn)單，要求同時(shí)傳name和age兩個(gè)參數(shù)
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($sql.update, [param.name, param.age, +param.id], function(err, result) {
// 使用頁(yè)面進(jìn)行跳轉(zhuǎn)提示
if(result.affectedRows > 0) {
res.render('suc', {
result: result
}); // 第二個(gè)參數(shù)可以直接在jade中使用
} else {
res.render('fail', {
result: result
});
}
connection.release();
});
});
},
queryById: function (req, res, next) {
var id = +req.query.id; // 為了拼湊正確的sql語(yǔ)句，這里要轉(zhuǎn)下整數(shù)
pool.getConnection(function(err, connection) {
connection.query($sql.queryById, id, function(err, result) {
jsonWrite(res, result);
connection.release();
});
});
},
queryAll: function (req, res, next) {
pool.getConnection(function(err, connection) {
connection.query($sql.queryAll, function(err, result) {
jsonWrite(res, result);
connection.release();
});
});
}
};
除了update測(cè)試外，其它get請(qǐng)求都可以直接在瀏覽器中使用地址+參數(shù)完成測(cè)試。為了模擬post請(qǐng)求，同時(shí)簡(jiǎn)單使用下jade模板（Express支持的一種模板引擎），我們?cè)?views目錄新建三個(gè)jade文件
updateUser.jade
extends layout block content h1 更新用戶資料 form(method='post', action='/p/users/updateUser') div.form-row label span ID: input(type='text',name='id') div.form-row label span name: input(type='text',name='name') div.form-row label span age: input(type='text',name='age') div.form-row input(type='submit')
suc.jade
block content
h1 操作成功！
pre #{JSON.stringify(result)}
fail.jade
block content
h1 操作失??！
pre #{JSON.stringify(result)}
以下是更新測(cè)試結(jié)果
最后，如果你使用的是idea或webStrom這樣的IDE，你就不需要安裝express和express項(xiàng)目種子生成器了。這兩個(gè)IDE是可以直接創(chuàng)建NodeJS項(xiàng)目
小結(jié)：
一個(gè)Express的helloWorld就差不多完成了, 可以通過(guò)這個(gè)鏈接下載此例子源代碼http://pan.baidu.com/s/1jGvd4Bc。更多Express的功能（如日志，自動(dòng)化測(cè)試等），等待大家去解鎖，愿玩得愉快！
- nodejs中操作mysql數(shù)據(jù)庫(kù)示例
- nodejs mysql 實(shí)現(xiàn)分頁(yè)的方法
- NodeJs使用Mysql模塊實(shí)現(xiàn)事務(wù)處理實(shí)例
- Docker + Nodejs + Kafka + Redis + MySQL搭建簡(jiǎn)單秒殺環(huán)境
- nodejs連接mysql數(shù)據(jù)庫(kù)簡(jiǎn)單封裝示例-mysql模塊
- Nodejs連接mysql并實(shí)現(xiàn)增、刪、改、查操作的方法詳解
- nodejs連接mysql數(shù)據(jù)庫(kù)及基本知識(shí)點(diǎn)詳解
- Nodejs使用mysql模塊之獲得更新和刪除影響的行數(shù)的方法
- NodeJS與Mysql的交互示例代碼
- nodejs+mysql實(shí)現(xiàn)用戶相關(guān)的增刪改查的詳細(xì)操作
相關(guān)文章
關(guān)于node+mysql數(shù)據(jù)庫(kù)連接池連接
這篇文章主要介紹了關(guān)于node+mysql數(shù)據(jù)庫(kù)連接池連接,mysql有兩種連接方式：一種是直接連接 另一種是池化連接，我們這篇講的是池化連接,需要的朋友可以參考下2023-04-04
Node.js中,在cmd界面,進(jìn)入退出Node.js運(yùn)行環(huán)境的方法
今天小編就為大家分享一篇Node.js中,在cmd界面,進(jìn)入退出Node.js運(yùn)行環(huán)境的方法，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2018-05-05
經(jīng)過(guò)幾個(gè)星期的nodejs學(xué)習(xí)，從開始的小白到現(xiàn)在漸漸得熟悉，走過(guò)來(lái)也才算明白，現(xiàn)在已經(jīng)入門也掌握了相關(guān)的學(xué)習(xí)方法，今天開始記錄下自己學(xué)習(xí)的過(guò)程，以便日后查看。2014-11-11
Node.js應(yīng)用設(shè)置安全的沙箱環(huán)境
這篇文章主要介紹了Node.js應(yīng)用設(shè)置安全的沙箱環(huán)境的方法以及注意事項(xiàng)，對(duì)此有需要的朋友可以參考學(xué)習(xí)下。2018-04-04
Node.js 使用 gRPC從定義到實(shí)現(xiàn)過(guò)程詳解
gRPC是一個(gè)高性能、開源的遠(yuǎn)程過(guò)程調(diào)用（RPC）框架,由 Google 開發(fā),它支持多種編程語(yǔ)言,旨在簡(jiǎn)化和優(yōu)化分布式系統(tǒng)中的服務(wù)通信,本文給大家介紹Node.js 使用 gRPC從定義到實(shí)現(xiàn)過(guò)程,感興趣的朋友跟隨小編一起看看吧2024-07-07
淺析Node.js實(shí)現(xiàn)HTTP文件下載
本文介紹如何用Node.js來(lái)實(shí)現(xiàn)HTTP文件下載，文章以實(shí)例演示所以很詳細(xì)，有需要的小伙伴們可以參考學(xué)習(xí)。2016-08-08
這篇文章主要介紹了node.js中的fs.close方法使用說(shuō)明,本文介紹了fs.close方法說(shuō)明、語(yǔ)法、接收參數(shù)、使用實(shí)例和實(shí)現(xiàn)源碼,需要的朋友可以參考下2014-12-12
nodejs清空/刪除指定文件夾下面所有文件或文件夾的方法示例
這篇文章主要介紹了nodejs清空/刪除指定文件夾下面所有文件或文件夾的方法,通過(guò)兩個(gè)具體案例形式分析了node.js同步刪除文件/文件夾,以及異步刪除文件/文件夾的相關(guān)實(shí)現(xiàn)技巧,涉及遞歸遍歷與文件判斷、回調(diào)等相關(guān)操作,需要的朋友可以參考下2023-04-04
基于NodeJS的前后端分離的思考與實(shí)踐（一）全棧式開發(fā)
這個(gè)話題最近被討論得比較多，阿里有些BU也在進(jìn)行一些嘗試。討論了很久之后，我們團(tuán)隊(duì)決定探索一套基于NodeJS的前后端分離方案，過(guò)程中有一些不斷變化的認(rèn)識(shí)以及思考，記錄在這里，也希望看到的同學(xué)參與討論，幫我們完善。2014-09-09
nodejs利用readline提示輸入內(nèi)容實(shí)例代碼
這篇文章主要給大家介紹了關(guān)于nodejs利用readline提示輸入內(nèi)容的相關(guān)資料,Readline是Node.js里實(shí)現(xiàn)標(biāo)準(zhǔn)輸入輸出的封裝好的模塊,通過(guò)這個(gè)模塊我們可以以逐行的方式讀取數(shù)據(jù)流,需要的朋友可以參考下2021-07-07