【Express系列】第3篇——接入mysql

一般来讲，先后端分离的项目，前端负责界面渲染和操做型的业务逻辑，后端则负责数据存取和数据处理相关的业务逻辑。

既然设计数据，那就少不了数据库的使用。目前市面上流行着各类各样的数据库，这里不打算一一列举，我所选用的是 mysql。

若是对各数据库之间的差别感兴趣的，能够本身去查阅相关资料。

 

先打开命令行工具，进入到项目根目录，而后执行下面指令，安装 mysql 模块：

npm install mysql --save

 

而后啪啪啪，啪啪啪，码字过程省略...咱们来看一下码字结束以后的项目目录结构是啥样子的~

不难发现，项目中多了一个 data 目录，里面的内容结构和 routes 目录十分类似。

相信你立刻就会联想到，难道他们直接有什么关系么？

下面我就说说我这样作的设计初衷：

首先，data 目录下的全部脚本，都是跟 mysql 数据查询有关系的，它们最终的执行结果是返回查询所获得的数据。

其次，data/modules 目录下的各个服务模块，和 routes/modules 目录下的各个业务逻辑模块是一一对应关系，各个逻辑模块引入了对应的服务模块，调用服务模块提供的各个方法取得想要的数据。

setting.js 是数据库连接的配置文件，方便在须要的时候引入使用。

connPool.js 最终导出一个能够建立多个连接的链接池对象，由各个服务模块引入使用。

 

下面看看代码...

routes/modules/userMod.js

var userSrv = require('../../data/modules/userSrv'),
    userMod = {
    getUserList: function (req, res) {
        userSrv.getUserList(function (data) { res.send(data); });
    },
    checkStatus: function (req, res) {
        res.send('userStatus');
    },
    save: function (req, res) {
        res.send('userSave');
    }
};

module.exports = userMod;

标红的代码是修改过的，这里引入了 userSrv 服务模块，在 userMod.getUserList 方法中又调用了 userSrv.getUserList 方法获取用户列表数据，成功获取后发送请求响应。

须要补充说明一下的是，这里只是直接把请求回来的数据输出到请求响应中去，并不表明实际项目中就这么简单。

更多的时候，在请求到数据之后，须要对数据再作处理，包装成须要的数据格式以后，才输入到请求响应中。

这些细节这里就不发散，毕竟需求不一样，这些处理代码也会有巨大差别，举例的意义已经不大。

 

data/settings.js

var settings = {
    host: '127.0.0.1',
    port: 3306,
    database: 'app',
    user: 'root',
    password: 'root'
};

module.exports = settings;

比较简单，相信是一目了然了。

 

data/connPool.js

var settings = require('./settings'),
    mysql = require('mysql'),

    //使用链接池的链接方式
    pool  = mysql.createPool(settings);

module.exports = pool;

也是很是简单的一个模块，不用多讲了。

 

data/modules/userSrv.js

var connPool = require('../connPool'),
    userSrv = {
        getUserList: function (callback) {
            connPool.getConnection(function (err, connection) {
                var sql = 'select * from user';
                connection.query(sql, function (err, data) {
                    if (err) throw err;
                    callback(data);
                    connection.release();//释放连接
                });
            });
        }
    };

module.exports = userSrv;

引入了一个链接池对象，先经过 connPool.getConnection 方法获取链接对象，而后执行 sql 语句查询数据，成功获取数据以后，执行回调函数。

须要补充说明一下的是，这里只是一个最最基础的查询服务，像复杂一些的有按条件查询，排序，多表复合查询等这里就不发散了，这些问题均可以找到资料去解决之。

关键只是你的代码如何实现，那些细节问题就看我的了。

 

data/modules 里面的模块只作 sql 数据操做（查，增，删，改）

routes/modules 里面的模块则负责对取到的数据进行分析处理，格式规范化，最终输出到请求响应中

 

最后，咱们看看数据库。这里我是用 XAMPP 一套搭建的数据库服务，很是方便。

因为自己对数据库的东东也不是特别懂，因此只能提供这个关键字。

后面的就本身下载，搭建，实在弄不起来就去找身边专搞后端的小伙伴详细咨询吧。

搭建好数据服务以后，建了一个名为 app 的数据库，里面建了一个 user 表，而后随便弄了一条数据进去，以下：

 

OK，万事俱备。是时候跑一跑，看看有没有问题了。

老规矩，打开命令行工具，进入到项目根目录，而后执行下面指令，运行应用：

node start

而后用浏览器访问 http://localhost:3000/user/list

看到页面里显示 [{"id":1,"name":"admin","password":"123456"}]

和数据库里的数据一致，也就是成功链接并从数据库中取得数据了~

有了开头，后面的细节就根据需求再慢慢实现了~