在上一章中,我们为后端的express服务设置了跨域访问,并未前端的angular安装了bootstrap和ng-bootstrap依赖,并进行了配置,为后端的express安装了mysql和处理文件上传的multiparty依赖并创建了mysql数据库birthday在这一章中,我准备介绍一下express对mysql数据库的访问。
对mysql访问的基本配置
用visual studio code(以下简称为vs code)打开后端程序目录server,在server目录下创建一个db目录,用于存放路由初始化文件。在db目录下新建议dbconnpool.js文件,文件中的代码为:
var mysql = require('mysql');module.exports = (function(){var pool = mysql.createPool({host:'localhost',user:'root',password:'******',database:'birthday',port:'3306'});pool.on('connection',function(connection){connection.query('SET SESSION auto_increment_increment=1');});return function(){//返回唯一的一个poolreturn pool;}})();
这是一个立即执行函数,并且其中的pool对象是一个单例对象,这就保证了所有对数据库的操作都针对同一个数据库对象(我是这样理解的,可能有偏差)。
mysql.createPool(<options>)方法创建了一个mysql访问池,options是一个参数对象,其中包括了mysql的主机名,登录mysql用户名、密码和需要访问的数据库以及端口(默认为3306)。关于数据库连接池的概念,向大家推荐这个地址,里面介绍的很详细。
pool.on('connection',function(conection){...})这个函数是数据库进行连接时的回调函数,在这里我主要设置了一下自增长型数据的步进值为1。
处理用户发来的注册用户请求,并将用户数据存入mysql数据库
打开server目录下的routers目录的users.js文件,这是一个express-generator已经构建好的文件,我就用这个文件作为处理用户请求的文件。在这个文件中加载了Router 实例,Router是一个完整的中间件和路由系统。用这个中间件,可以方便的处理所有的路由访问。另外还要加载我们刚刚建立的dbconnpool.js文件。
var express = require('express');var router = express.Router();var connPool = require('../db/dbconnpool');var pool = connPool();
这里还涉及了jwt用户认证的处理,作为用户注册,我们只需要将用户认证信息发到前端就OK了!我对jwt的使用也不是很精通,只是明白大概的原理和使用方法,在这里发个原理图供大家参考。
如果大家感兴趣,可以参考这篇文章,这里介绍的还是很详细的。我们为了程序的完整性,先将这个中间件安装并加载进来。在express中使用jwt,需要使用两个中间件express-jwt和jsonwebtoken,安装方法:
cnpm install express-jwt --save
cnpm install --save jsonwebtoken
在user.js文件中我们只需要使用jsonwebtoken,让我们引入这个文件:
var jwt = require('jsonwebtoken');
让我们开始处理用户注册请求吧,下面是代码:
router.post('/register', function (req, res, next) {let userName = req.body['name'];let userPass = req.body['password'];let email = req.body['email'];if(userName.length === 0 || userPass.length === 0){res.status(400).json({ code: '-200', msg: '用户名或密码未输入' });return;}let params = [userName, userPass, email];let sqlStr = 'insert into user (uname, upass, uemail)values(?,?,?);'pool.getConnection(function (err, conn) {if (err) {res.status(400).json({ code: '-200', msg: '数据库连接失败' });return;}conn.query(sqlStr, params, function (err, rs) {if (err) {if(err.message.includes('Duplicate')){res.status(400).json({ code: '-200', msg: '注册用户出错:用户名重复' });return;}else{res.status(400).json({ code: '-200', msg: '注册用户出错:' + err.message });return;}}res.status(200).json({ token: jwt.sign({ userid: rs.insertId }, 'secret') });});conn.release();});});
我们把这段代码分析一下:
先让我们准备一些数据
客户端用POST方法发送的注册信息有用户名(name)、密码(password)和邮箱地址(email),分别从req.body中取出这3个数据,并分别赋值给userName、userPass、email三个变量。将mysql查询语句赋值给变量sqlStr
let sqlStr = 'insert into user (uname, upass, uemail)values(?,?,?);'
,
并利用上面赋值的userName、userPass、email变量声明查询参数数组params(其实就是为sql查询语句的那3个?赋值)。
获取数据库连接
调用pool.getConnection()函数连接数据库,在连接的回调函数中有连个参数err和conn,err参数包含了在连接数据库时的错误信息。如果在连接中发生错误,可以通过错误处理代码向客户端发送错误信息,并立即返回。如果没有错误,就可以对数据库进行操作了。
执行对数据库的操作
注册用户对数据库的操作为插入数据,前边赋值的sql语句就是标准的sql插入语句,只不过将values的值换成了?,以便利用我们的params数组中的变量作为参数。对数据库进行操作的方法是conn.query()函数,里面有3个参数,第一个参数是要执行的sql语句,第二个参数是查询参数,第三个参数是回调函数。
回调函数包括两个参数,第一个参数同样是err参数,用于对发生的错误进行处理,我把重复注册同一个用户的错误处理放在了这里,如果发生重复注册,mysql会返回一条包含'ER_DUP_ENTRY: Duplicate entry '<username>' for key 'un''的语句,证明你发送到mysql的信息违背了数据的唯一性属性。根据这个错误信息,就可以对重复注册用户进行处理。
第二个参数rs包含了一些新插入的数据信息,其中最重要的一个信息是insertId,这个就是我们的user id。如果向mysql数据库插入数据成功,就返回200的状态信息,并向客户端发送一个json对象,对象包含一个token键,这个键对应了用'jsonwebtoken'的sign函数生成的认证信息,信息中包含了从rs中取得的insertId。
最后用conn.release();
释放掉对数据库的连接。
对登录请求的处理
对登录请求的处理也很简单,主要是对数据库进行查询操作,找到正确的用户名和密码,就发送认证信息,未找到就发送错误信息。
具体代码如下:
router.post('/login', function (req, res, next) {let userName = req.body['name'];let userPass = req.body['password'];let params = [userName, userPass];let sqlStr = "select * from user where uname=? and upass=?";pool.getConnection(function(err, conn){if(err){res.status(400).json({code:'-200',msg:'数据库连接失败'});return;}conn.query(sqlStr, params, function(err,rs){if(err){res.status(400).json({ code: '-200', msg: '查询用户出错:' + err.message });return;}if(rs.length === 0){res.status(401).json({ code: '-200', msg: '登录失败,用户名或密码输入错误!'});return;}res.status(200).json({token: jwt.sign({ userid: rs[0].uid }, 'secret') });});conn.release();});});
这次在jwt认证信息中的用户id来自查询到的uid。
用户注册和登录的express处理程序就是这些了。中间可能还有不太合理的地方,希望大家能够给予指正。今天就写到这里了。谢谢大家的关注......