js连接数据库（实现Mysql增删查改功能）

在上一篇文章中，我给大家介绍了如何用Egg框架连接我们的MySQL数据库，然后也给大家说明了如何在Egg框架中写业务逻辑代码，并且也给大家说明了如何编写一个用户新增的功能。那么本文将会接着上文的内容继续给大家分享对user表进行查询、修改、删除的操作。接下来我们进入正题。

用户查询

首先我们要知道，用户查询功能的实现要根据实际业务需求进行开发。一般来说我们可以把这个查询功能分成两大方式一种是查询单条详细数据，另一种可以根据模糊条件进行分页查询，那么接下来我将会分别介绍这两种方式。

首先给大家介绍通过id查询单条数据的方式。

我们找到app/service/user.js文件，然后在里面新建一个查询用户的方法。在这这个方法里，我们通过id去获取某个用户的详细信息。代码如下。

//通过id查询用户信息 async getUser(id) { const {ctx, app} = this; let result = {}; try { //通过id查询用户表，并且将返回值赋值给info; const info = await this.app.mysql.get('user', { id }); //给前端返回一个Json的对象 result = { state: 0, //自定义的状态码 msg: "查询成功", //返回的消息 data: info, //查询的记录 } } catch (err) { //获取数据失败的返回结果 result = { state: 1, msg: err, data: null, } } return result; }

完成了数据库查询功能后，我们在app/controller/user.js中写控制层的代码。在控制层中我们只需要获取前端传过来的id，然后将逻辑层查询到的数据返回给前端即可。在逻辑层中我们只需要写逻辑代码，而控制层我们仅用于获取数据和发送数据即可。具体代码如下所示。

//通过id查询用户信息 /** * @summary 根据ID查询用户信息 * @router get /user/get * @request query string id * @response 200 * @Authorization */ async getUser() { const { ctx } = this; //通过ctx.query的方式，可以获取到前端由url拼接提交上来的数据 const id = ctx.query.id; //调用service层的getUser方法。并且返回相应的结果 const userInfo = await ctx.service.user.getUser(id); //向前端接口响应数据。 ctx.body = userInfo; }

最后我们定义一个路由，将路由路径配置成/user/get。请求方式为get，当监听到前端请求接口时，就执行控制层中获取用户信息的方法。这样方便前端通过请求这个路由传递参数上来。路由定义如下所示。

//通过id查询用户 router.get('/user/get', controller.user.getUser);

为了验证功能的正确性，我们直接在swagger-ui中进行接口测试。前端请求接口：http://127.0.0.1:7001/user/get?id=1，传递的参名为id，值是1，最后后台返回id是1的用户信息。测试结果如下。

修改用户

修改用户主要的核心点是首先找到相对应要修改的用户然后再更新信息。主要的实现方式是通过id在数据库中找到对应的用户，然后直接修改该用户的信息。那么结合Egg框架，我们实现修改功能其实也是很简单的。具体实现的功能如下：

// app/router.js //定义路由 //通过id修改用户，PUT方式请求 router.put('/user/put', controller.user.putUser); // app/controller/user.js //修改用户信息 /** * @summary 根据ID修改用户信息 * @router put /user/put * @request query string id * @request body userAddRequest * @response 200 * @Authorization */ async putUser() { const { ctx } = this; //通过ctx.query的方式，可以获取到前端由url拼接提交上来的数据 const id = ctx.query.id; //通过ctx.request.body的方式，可以获取到请求Body的数据 const body = ctx.request.body; //调用service层的putUser方法。并且返回相应的结果 const putInfo = await ctx.service.user.putUser(id, body); //向前端接口响应数据。 ctx.body = putInfo; } // app/service/user.js //修改用户信息 async putUser(id, body) { const {ctx, app} = this; let result = {}; try { //定义查询用户的主键，我们现在定义的是id const options = { where :{ id } } //Egg的更新方式，"user"：数据库表名,body:要修改的信息json格式，options：查询条件 const info = await this.app.mysql.update('user', body, options); // 更新 posts 表中的记录 //修改成功后。 if(info.affectedRows === 1){ //给前端返回一个Json的对象 result = { state: 0, //自定义的状态码 msg: "修改成功", //返回的消息 data: id, //修改的记录的id } } } catch (err) { result = { state: 1, msg: err, data: null, } } return result; }

删除用户

删除用户的功能相对来说就简单一点，只需要传入主键id，然后后端直接删除数据库数据即可。具体代码如下。

// app/router.js //通过id删除用户，delete方式请求 router.delete('/user/delete', controller.user.deleteUser); // app/controller/user.js //删除用户 /** * @summary 根据ID删除用户 * @router delete /user/delete * @request query string id * @response 200 * @Authorization */ async deleteUser() { const { ctx } = this; //通过ctx.query的方式，可以获取到前端由url拼接提交上来的数据 const id = ctx.query.id; //调用service层的putUser方法。并且返回相应的结果 const deleteInfo = await ctx.service.user.deleteUser(id); //向前端接口响应数据。 ctx.body = deleteInfo; } // app/service/user.js //删除用户 async deleteUser(id) { const {ctx, app} = this; let result = {}; try { //Egg删除记录的方法，通过主键id去删除user表的记录 const info = await this.app.mysql.delete('user', { id }); //给前端返回一个Json的对象 result = { state: 0, //自定义的状态码 msg: "删除成功", //返回的消息 data: null, } } catch (err) { result = { state: 1, msg: err, data: null, } } return result; }

结语

至此，我们一个基本的nodejs服务端搭建完毕了。同时我们也实现了用户表的新增删除修改查询功能。其余的业务逻辑功能也是类似的，后续我再分享给大家。

本次分享暂时先告一段落。请各位小伙伴抬起你们发财的小手，点个赞呗。下次我将会和大家分享用户注册登录功能，同时分享带token的登录。关注我！！！更多精彩分享不迷路。