node.js+express+mysql

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

Express 工程环境准备

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

安装 express

npm install express -g

安装 express

npm install express-generator -g

2. 创建工程。进入工程目录，运行命令

express projectName

expresst 项目种子生成器会帮我们生成 express 相应的工程结构，如下

/bin: 用于应用启动
/public: 静态资源目录
/routes：可以认为是 controller（控制器）目录
/views: jade 模板目录，可以认为是 view(视图)目录
app.js 程序 main 文件

3. 进入工程，安装依赖，然后启动应用
在工程根目录，使用 npm install 安装依赖，使用 npm start 启动应用。完成后，你在命令行工具里会看出如下界面，在浏览器中访问会得到我们应用的默认页面

MySQL 环境准备

1. 当然，首先你要准备好 MySQL 环境。可以参看 http://supportopensource.iteye.com/blog/1415527 进行安装，同时也建议安装一个数据库管理工具，如 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 数据库连接配置

// conf/db.js

// MySQL 数据库联接配置

module.exports = {

mysql: {

host: ‘127.0.0.1’,

user: ‘root’,

password: ”,

database:‘test’, // 前面建的 user 表位于这个数据库中

port: 3306

}

};

2. 编写 CRUD SQL 语句

// dao/userSqlMapping.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 中增加一个路由

    

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

在 userDao 中实现 add 方法

// dao/userDao.js
// 实现与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, res, next) {
        pool.getConnection(function(err, connection) {
            // 获取前台页面传过来的参数
            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形式，把操作结果返回给前台页面
                jsonWrite(res, result);

                // 释放连接 
                connection.release();
            });
        });
    }
};

测试整合是否成功

因为前面实现的是一个 get 请求的 add 方法，所以可以在浏览器中直接使用地址访问，进入路由, http://localhost:3000/users/addUser?name=xyz&age=18.如果你得到如下 JSON 返回或看到数据表中有上面的数据插入，表示整合成功了

5. 同理，实现 CRUD 其它的方法，最终完整的的 routes/user.js 为：

    

        
        
            
                
            
                123456789101112131415161718192021222324252627282930313233
            
                    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 同时支持get,postrouter.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
// 实现与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));

// 向前台返回JSON方法的简单封装
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) {
            // 获取前台页面传过来的参数
            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形式，把操作结果返回给前台页面
                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
        // 为了简单，要求同时传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($sql.update, [param.name, param.age, +param.id], function(err, result) {
                // 使用页面进行跳转提示
                if(result.affectedRows > 0) {
                    res.render('suc', {
                        result: result
                    }); // 第二个参数可以直接在jade中使用
                } else {
                    res.render('fail',  {
                        result: result
                    });
                }

                connection.release();
            });
        });

    },
    queryById: function (req, res, next) {
        var id = +req.query.id; // 为了拼凑正确的sql语句，这里要转下整数
        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 测试外，其它 get 请求都可以直接在浏览器中使用地址 + 参数完成测试。为了模拟 post 请求，同时简单使用下 jade 模板（Express 支持的一种模板引擎），
我们在/views 目录新建三个 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)}

以下是更新测试结果

最后，如果你使用的是 idea 或 webStrom 这样的 IDE，你就不需要安装 express 和 express 项目种子生成器了。这两个 IDE 是可以直接创建 NodeJS 项目

小结：

一个 Express 的 helloWorld 就差不多完成了, 可以通过这个链接下载此例子源代码 http://pan.baidu.com/s/1jGvd4Bc。更多 Express 的功能（如日志，自动化测试等），等待大家去解锁，愿玩得愉快！

[转载自：TAT.Fujun的《初识NodeJS服务端开发（Express+MySQL）》](http://www.alloyteam.com/2015/03/sexpressmysql/)

生财有迹 | 您专属的资产跟踪与分析工具

[链接]（Wealth Tracker）是一款专注于个人资产分析的应用程序。其核心功能是：全面记录并展示用户的资产状况，帮助用户轻松了解财务现状；运用 AI 能力，结合每种资产的特性和当前环境，提供适宜的财务建议。项目愿景在当今多元化的经济环境中，个人资产管理变得日益重要。它往往分散于各类金融账户和服务中，例如银行 ..

安装 nodejs Ubuntu20.4

‍ nvm、node、npm 区别 nvm：nodejs 版本管理工具，也就是说，一个 nvm 可以管理很多 node 版本好 npm 版本。 nodejs：在项目开发时所需要的代码库 npm：nodejs 管理工具，在安装 nodejs 时，npm 也会跟着一起安装，它是包管理工具，npm 管理 nodejs 中的第 ..

nodejs- 从 0 写一个 websocket

搬运了我 b 站的文，原创指数 100() [链接] 我写的源码只有 200 行，已经足够完成 websocket 服务器的基础功能了。无论是自己添加功能，排查问题的便利度还是性能方面，都一定是比主流框架强的。学习也好，自己的小项目用也好，我的代码是不二之选。可以直接使用 npm i iiws 来安装。注意如果要修改源 ..

HV-Com——一个全程使用 Vditor 的评论系统

HV-Com WIP - 功能和结构可能迅速变化，且兼容性不被保证 [链接] 简介 HV-Com 是一个使用 TypeScript 编写的评论系统。它使用 [链接] 作为 markdown 编辑器，[链接] 作为 markdown 引擎。特性 HV-Com 的 HV 有很多个意思： HeaVy - 这套评论系统的规模 ..

某豆瓣小组删帖考察——基于我的豆瓣小组爬虫

爬虫地址：https://github.com/lixiang810/NSDBG-Next 我在今年 8 月开发出了这个爬虫，用于保存我所在某小组的讨论。此后我加入了检验帖子是否被删除的功能：指定爬取页数，将爬取下的每页帖子列表与数据库中这一段时间的帖子列表进行比较，存在于数据库而不存在于爬取数据中的帖子即为疑似删除。 ..

近日项目介绍：哔哩哔哩 - 瓦尔基里

后端源代码地址：https://github.com/lixiang810/bilibili-valkyrie 前端尚未开发，且可能以包括但不限于浏览器插件、油猴脚本、独立网页的形式存在。如果乐意开发，也可以仿照后端里的测试代码写一下。请以包括但不限于 star / watch / fork / pr / 点赞 / ..

欢迎来到这里！

我们正在构建一个小众社区，大家在这里相互信任，以平等 • 自由 • 奔放的价值观进行分享交流。最终，希望大家能够找到与自己志同道合的伙伴，共同成长。

关于

node.js+express+mysql

相关帖子

生财有迹 | 您专属的资产跟踪与分析工具

安装 nodejs Ubuntu20.4

caniuse-lite 被打包到导致文件打包过大，该如何解决

nodejs- 从 0 写一个 websocket

HV-Com——一个全程使用 Vditor 的评论系统

某豆瓣小组删帖考察——基于我的豆瓣小组爬虫

近日项目介绍：哔哩哔哩 - 瓦尔基里

欢迎来到这里！

近期热议

推荐标签标签

最新标签

node.js+express+mysql

相关帖子

生财有迹 | 您专属的资产跟踪与分析工具

安装 nodejs Ubuntu20.4

caniuse-lite 被打包到导致文件打包过大，该如何解决

nodejs- 从 0 写一个 websocket

HV-Com——一个全程使用 Vditor 的评论系统

某豆瓣小组删帖考察——基于我的豆瓣小组爬虫

近日项目介绍：哔哩哔哩 - 瓦尔基里

欢迎来到这里！

近期热议

推荐标签 标签

最新标签

推荐标签标签