初识NodeJS服务端开发入门（Express+MySQL）

NodeJS对前端来说无疑具有里程碑意义，在其越来越流行的今天，掌握NodeJS已经不再是加分项，而是前端攻城师们必须要掌握的技能。本文将与同志们一起完成一个基于Express+MysqL的入门级服务端应用，即可以对数据库中的一张表进行简单的CRUD操作。但本人还是斗胆认为，通过这个应用，可以让没怎么接触后端开发的同志对使用Node进行后端开发有一个大致了解。

Express工程环境准备

1. 安装express，和express项目种子生成器（什么？你问第1步为什么不是安装NodeJS，我也只能呵呵..）

安装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.在conf目录中，编写MysqL 数据库连接配置

MysqL数据库联接配置 module.exports = { MysqL: { host: '127.0.0.1',user: 'root',password: '',database:'test',// 前面建的user表位于这个数据库中 port: 3306 } };

2. 编写CRUD sql语句

sqlMapping.js // CRUD sql语句 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. 增加路由及实现数据库的CRUD

以C（新增）的具体实现举例，在/routes/users.js 中增加一个路由

增加用户 router.get('/addUser',function(req,res,next) { userDao.add(req,next); });

在userDao中实现add方法

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));

// 向前台返回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="https://www.jb51.cc/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="https://www.jb51.cc/tag/qiantai/" target="_blank" class="keywords">前台</a><a href="https://www.jb51.cc/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为：

var userDao = require('../dao/userDao');

/ 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="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>.update,param.age,+param.id],result) {
            // 使用<a href="https://www.jb51.cc/tag/yemian/" target="_blank" class="keywords">页面</a>进行<a href="https://www.jb51.cc/tag/tiaozhuan/" target="_blank" class="keywords">跳转</a><a href="https://www.jb51.cc/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="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>语句，这里要转下整数
    pool.getConnection(function(err,connection) {
        connection.query($<a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>.queryById,result) {
            jsonWrite(res,result);
            connection.release();

        });
    });
},queryAll: function (req,connection) {
        connection.query($<a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>.queryAll,result);
            connection.release();
        });
    });
}

};

除了update测试外，其它get请求都可以直接在浏览器中使用地址+参数完成测试。为了模拟post请求，同时简单使用下jade模板（Express支持的一种模板引擎），我们在/views目录新建三个jade文件

updateUser.jade

新用户资料 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

fail.jade

以下是更新测试结果