0.目標(biāo)
實(shí)現(xiàn)通過Node.js對(duì)MySQL進(jìn)行數(shù)據(jù)CURD操作逢慌，這里將使用Node.js的Express框架。
1.前置條件
1.1 已經(jīng)安裝了MySQL數(shù)據(jù)庫(kù)般又。
建議再安裝一個(gè)可視化操作工具M(jìn)ySQL Front
1.2 安裝Express和MySQL
npm install express --save
npm install mysql --save
2.重點(diǎn)
2.0 文件夾結(jié)構(gòu)預(yù)覽
整個(gè)應(yīng)用的流程如下：
啟動(dòng)app.js后布隔，用戶在瀏覽器發(fā)出請(qǐng)求霎匈，調(diào)用routes對(duì)應(yīng)的方法趟济，從models中找到處理方法乱投，從config獲取配置后對(duì)數(shù)據(jù)庫(kù)進(jìn)行操作。
2.1 定義數(shù)據(jù)庫(kù)配置參數(shù)
這里先在config文件夾里創(chuàng)建一個(gè)db.js文件顷编，導(dǎo)出一個(gè)名為onelib的數(shù)據(jù)庫(kù)鏈接配置戚炫。
module.exports = {
onelib: {
host: '127.0.0.1', // MySQL所在服務(wù)器IP
user: 'root', // 用戶名
password: '', // 密碼
database:'onelib', // 數(shù)據(jù)庫(kù)名稱
port: 3306, // 端口號(hào)
dateStrings: true, // 時(shí)間以字符串形式顯示，否則會(huì)有類似這樣的顯示：Thu Apr 14 2016 00:00:00 GMT+0800 (中國(guó)標(biāo)準(zhǔn)時(shí)間) 17:20:12
}
};
注意媳纬，如果有多個(gè)數(shù)據(jù)庫(kù)双肤，可以增加一個(gè)配置參數(shù)，和onelib并列层宫。如：
module.exports = {
onelib: {
……
},
newdb: { // 新的數(shù)據(jù)庫(kù)配置
……
}
};
2.2 設(shè)置數(shù)據(jù)庫(kù)連接
仍然在config文件夾中創(chuàng)建一個(gè)文件杨伙，名為mysql.js其监。該文件用于建立與MySQL的連接萌腿。
var mysql = require('mysql'); // 引用mysql模塊。注意要先安裝mysql： npm install mysql
var config = require('./db');
var onelib_pool = mysql.createPool(config.onelib);
exports.onelib_pool = onelib_pool;
注意抖苦，如果有多個(gè)數(shù)據(jù)庫(kù)毁菱，只需要使用對(duì)應(yīng)的配置(在db.js中定義的)信息即可設(shè)置多個(gè)數(shù)據(jù)庫(kù)連接，如：
var mysql = require('mysql'); // 引用mysql模塊锌历。注意要先安裝mysql： npm install mysql
var config = require('./db');
// 數(shù)據(jù)庫(kù)連接
var onelib_pool = mysql.createPool(config.onelib);
exports.onelib_pool = onelib_pool;
// 新的數(shù)據(jù)庫(kù)連接
var newdb_pool = mysql.createPool(config. newdb);
exports. newdb_pool = newdb_pool;
2.3 操作數(shù)據(jù)庫(kù)的模型
在數(shù)據(jù)庫(kù)配置完畢并建立連接后贮庞，即可對(duì)數(shù)據(jù)庫(kù)進(jìn)行CURD操作。
我們?cè)趍odels文件夾中究西，創(chuàng)建一個(gè)名為tasks.js的文件窗慎，用來存儲(chǔ)對(duì)task模塊的操作：
var mysql = require('../config/mysql');// 獲取數(shù)據(jù)庫(kù)連接配置
var Task = function() {}; // 預(yù)定義一個(gè)空的類，接下來只需要往里增加方法即可
Task.prototype.find = function(id, callback) { // 增加一個(gè)方法卤材，名為find遮斥，傳入?yún)?shù)為id和回調(diào)函數(shù)callback
// sql查詢語(yǔ)句，注意這里的“?”號(hào)扇丛，它會(huì)在query的時(shí)候被處理
var sql = "SELECT * FROM tasks WHERE id =?";
// 獲取mysql的onelib_pool連接池术吗，以回調(diào)的方式處理（即獲取成功后，執(zhí)行下一步）
mysql.onelib_pool.getConnection(function(err, connection) {
if (err) {
callback(true);
return;
}
// 獲取成功后帆精，執(zhí)行query
// 注意到這里有三個(gè)參數(shù)较屿，第一個(gè)是sql語(yǔ)句隧魄，第二個(gè)是一個(gè)數(shù)組，第三個(gè)是回調(diào)函數(shù)
// 需要著重說明的是第二個(gè)參數(shù)隘蝎，它將依次替換sql里的“?”號(hào)
// sql語(yǔ)句被替換后购啄，會(huì)是這樣的："SELECT * FROM tasks WHERE id = " + id
connection.query(sql, [id], function(err, results) {
if (err) {
callback(true);
return;
}
callback(false, results);
});
});
};
Hint1：如果我們要對(duì)newdb進(jìn)行操作，則可以這樣寫：
Task.prototype.find = function(id, callback){
……
mysql.newdb_pool.getConnection(function(err, connection) {
……
});
};
Hint2：關(guān)于sql語(yǔ)句的填寫：
如果有多個(gè)參數(shù)要傳入末贾，可以這么寫：
var sql = "SELECT * FROM tasks WHERE releaser=? OR relative=?";
var sql_value_arr = [name, name]; // 對(duì)應(yīng)sql語(yǔ)句里的問號(hào)
……
connection.query(sql, sql_value_arr, function(err, results) {
……
}
如果沒有參數(shù)要傳入闸溃，可以這么寫：
var sql = "SELECT * FROM tasks";
var sql_value_arr = [];
……
connection.query(sql, sql_value_arr, function(err, results) {
……
}
2.4 處理路由請(qǐng)求
在routes文件夾中創(chuàng)建一個(gè)文件：tasks.js。這個(gè)文件用來處理用戶的路由請(qǐng)求
// 引用tasks模型
var Task = require('../models/tasks');
// 根據(jù)taskid獲取任務(wù)數(shù)據(jù)
exports.getTask = function(req, res) {
var taskid = req.params.taskid;
var task = new Task();
task.find(taskid,function(err,result){
if(err){
res.send('沒有找到taskid為'+taskid+'的任務(wù)');
}
else if(undefined!=result){ // 增加這個(gè)判斷拱撵，否則在沒有查詢到的情況下（sql查詢出錯(cuò)的情況下）辉川，Node.js會(huì)掛掉。當(dāng)然拴测，你也可以安裝supervisor乓旗，這樣即使掛掉了也會(huì)自動(dòng)重啟。安裝指令為“npm install -g supervisor”集索，安裝完畢后屿愚，使用“supervisor app”來代替“node app”來啟動(dòng)應(yīng)用
res.send(result.length === 1 ? result[0]:result);
}
else{
res.end("Error");
}
});
}
Hint1：關(guān)于查詢結(jié)果的結(jié)構(gòu)
查詢結(jié)果如果只有一個(gè)，會(huì)以對(duì)象的形式返回务荆。查詢結(jié)果如果有多個(gè)妆距，會(huì)以數(shù)組的形式把對(duì)象組合起來
Hint2：關(guān)于undefined的檢查
如果查詢結(jié)果result為undefined，而我們又對(duì)result取result[0]函匕，將導(dǎo)致出錯(cuò)娱据，Node.js會(huì)直接掛掉！
Hint3：對(duì)結(jié)果集進(jìn)行解析
當(dāng)前的代碼會(huì)將查詢結(jié)果直接以對(duì)象的形式輸出到頁(yè)面中盅惜，如果不是ajax的請(qǐng)求中剩，這樣的輸出會(huì)unreadable；所以抒寂，我們有必要在輸出之前先對(duì)其進(jìn)行“裝飾”结啼。雖然這個(gè)是前端工程師的工作，但我們的目標(biāo)是全棧工程師嘛屈芜。
2.5 映射路由到應(yīng)用中
注意到郊愧，我們之前寫的方法全部是export的，即可以被外部調(diào)用的井佑。我們把路由請(qǐng)求的處理也export了属铁，目的是讓app.js文件更簡(jiǎn)潔，路由的實(shí)現(xiàn)全部在routes文件夾里毅糟，而不會(huì)摻雜在app.js文件中红选。
下面給出app.js代碼
var express = require('express')
, path = require('path')
, task = require('./routes/tasks');
var app = express();
/* 主頁(yè) */
app.get('/', function(req, res){
res.sendfile('views/index.html');
});
/* 處理路由請(qǐng)求 */
// Onelib
app.get('/gettask/:taskid',task.getTask);
// newdb
app.get('/gettask/:taskid',task.getTask);
/* 設(shè)置靜態(tài)文件路徑 */
app.use(express.static(path.join(__dirname, 'public')));
/* 啟動(dòng)服務(wù)器 */
var server = app.listen(3000, function(){
var host = server.address().address;
var port = server.address().port;
console.log("*** OneLib智庫(kù)已啟動(dòng)，訪問地址為 http://%s:%s", host, port)
});
打開瀏覽器姆另，輸入
http://127.0.0.1:3000/gettask/1
taskid為1的數(shù)據(jù)將顯示在網(wǎng)頁(yè)中（當(dāng)然喇肋，你的數(shù)據(jù)庫(kù)里首先要有這個(gè)數(shù)據(jù) ^ _ ^）
原創(chuàng)文章坟乾，未經(jīng)許可，請(qǐng)勿轉(zhuǎn)載
作者：Mike的讀書季
日期：2016.08.08
QQ：1139904786
Blog：http://blog.csdn.net/kkdestiny
