利用angular4和nodejs-express构建一个简单的网站(三)—expres
在上一章中,我们为后端的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(){ //返回唯一的一个pool return pool; } })(); 这是一个立即执行函数,并且其中的pool对象是一个单例对象,这就保证了所有对数据库的操作都针对同一个数据库对象(我是这样理解的,可能有偏差)。 处理用户发来的注册用户请求,并将用户数据存入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,安装方法: 让我们开始处理用户注册请求吧,下面是代码: 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
调用pool.getConnection()函数连接数据库,在连接的回调函数中有连个参数err和conn,err参数包含了在连接数据库时的错误信息。如果在连接中发生错误,可以通过错误处理代码向客户端发送错误信息,并立即返回。如果没有错误,就可以对数据库进行操作了。
注册用户对数据库的操作为插入数据,前边赋值的sql语句就是标准的sql插入语句,只不过将values的值换成了?,以便利用我们的params数组中的变量作为参数。对数据库进行操作的方法是conn.query()函数,里面有3个参数,第一个参数是要执行的sql语句,第二个参数是查询参数,第三个参数是回调函数。 对登录请求的处理对登录请求的处理也很简单,主要是对数据库进行查询操作,找到正确的用户名和密码,就发送认证信息,未找到就发送错误信息。 router.post('/login',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,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处理程序就是这些了。中间可能还有不太合理的地方,希望大家能够给予指正。今天就写到这里了。谢谢大家的关注...... (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |
- 向Angular Application添加多个HTTP拦截器
- angular – 使用IdentityServer4作为IDP的离子
- 如何在scala中优化这个简短的阶乘函数? (创建50000 BigInt
- SOAPpy 调用天气预报WebService
- shell – 在debian系统上通过命令行与华为E3131和HiLink发送
- 免费的Bootstrap管理后台模板集合
- Scala宏:类型化(又称typechecked)与无类型树之间有什么区别
- [后端人员耍前端系列]KnockoutJs篇:使用KnockoutJs+Bootst
- 什么是AngularJS的$$阶段?
- 动态添加和删除angular 2自定义子组件中的formGroup