您正在学习的是试看内容，报名后可学习全部内容
报名课程
Koa2封装数据库高级操作
相关视频：
特点
- 成熟项目经验，经过总结、提炼、精简、重构，实现数据库批量更新与事务等高级操作。
- 课程内容与结构经过精心准备，设计合理、节奏紧凑、内容翔实。
- 真实再现了思考、编码、调试、除错的整个开发过程。
项目介绍
这是标准数据库封装的下半部分，数据库批量更新与事务等高级操作的实现。
设计思路
将前端送到后端的json对象自动映射成为标准的SQL查询语句。我的这种ORM方式，服务端不需要写一行代码，只需完成关系数据库的设计，就能为前端提供标准服务接口。遵循一套统一的接口来实现数据库封装，达到业务层可以随意切换数据库的目的。
适合人群
- Typescript初学者与中级者，带你逐步进入后端开发奇妙世界
- 适合从实战角度来学习编程的人，带你一步步实现一个完整的项目
- node.js平台开发者，与你分享个人的设计思想与编程技巧
- 数据库高级操作实践，深入理解事务机制
安装运行
运行数据脚本
SET NAMES utf8; SET FOREIGN_KEY_CHECKS = 0; -- ---------------------------- -- Table structure for `users` -- ---------------------------- DROP TABLE IF EXISTS `users`; CREATE TABLE `users` ( `id` int(11) NOT NULL AUTO_INCREMENT, `username` varchar(255) DEFAULT NULL, `password` varchar(255) DEFAULT NULL, `age` int(11) DEFAULT NULL, `power` json DEFAULT NULL, PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=7 DEFAULT CHARSET=utf8mb4; -- ---------------------------- -- Records of `users` -- ---------------------------- BEGIN; INSERT INTO `users` VALUES ('1', 'white', '123', '22', null), ('2', 'john', '456i', '25', null), ('3', 'marry', null, '22', null), ('4', 'bill', '123', '11', null), ('5', 'alice', '122', '16', null), ('6', 'zhoutk', '123456', '26', null); COMMIT; SET FOREIGN_KEY_CHECKS = 1;配置文件示例，./src/config/configs.ts
export default { inits: { directory: { run: false, dirs: ['public/upload', 'public/temp'] } }, port: 5000, db_dialect: 'mysql', dbconfig: { db_host: 'localhost', db_port: 3306, db_name: 'strest', db_user: 'root', db_pass: '123456', db_char: 'utf8mb4', db_conn: 10, }, jwt: { secret: 'zh-tf2Gp4SFU>a4bh_$3#46d0e85W10aGMkE5xKQ', expires_max: 36000 //10小时，单位：秒 }, }在终端（Terminal）中依次运行如下命令
git clone https://github.com/zhoutk/gels cd gels npm i -g yarn yarn global install typescript tslint nodemon yarn install tsc -w //或 command + shift + B，选 tsc:监视 yarn start //或 node ./dist/index.js项目结构
├── package.json
├── src //源代码目录
│ ├── app.ts //koa配置及启动
│ ├── common //通用函数或元素目录
│ │ ├── globUtils.ts
│ ├── config //配置文件目录
│ │ ├── configs.ts
│ ├── db //数据封装目录
│ │ ├── baseDao.ts
│ ├── globals.d.ts //全局声明定义文件
│ ├── index.ts //运行入口
│ ├── inits //启动初始化配置目录
│ │ ├── global.ts
│ │ ├── index.ts
│ │ ├── initDirectory.ts
│ ├── middlewares //中间件目录
│ │ ├── globalError.ts
│ │ ├── logger.ts
│ │ ├── router
│ │ └── session.ts
│ └── routers //路由配置目录
│ ├── index.ts
│ └── router_rs.ts
├── tsconfig.json
└── tslint.json数据库接口设计
事务元素接口，sql参数用于手动书写sql语句，id会作为最后一个参数被送入参数数组。
export default interface TransElement { table: string; method: string; params: object | Array<any>; sql?: string; id?: string | number; }数据库操作接口，包括基本CURD，两个执行手写sql接口，一个批量插入与更新二合一接口，一个事务操作接口。实践证明，下面八个接口，在绝大部分情况下已经足够。
export default interface IDao { select(tablename: string, params: object, fields?: Array<string>): Promise<any>; insert(tablename: string, params: object): Promise<any>; update(tablename: string, params: object, id: string|number): Promise<any>; delete(tablename: string, id: string|number): Promise<any>; querySql(sql: string, values: Array<any>, params: object, fields?: Array<string>): Promise<any>; execSql(sql: string, values: Array<any>): Promise<any>; insertBatch(tablename: string, elements: Array<any>): Promise<any>; transGo(elements: Array<TransElement>, isAsync?: boolean): Promise<any>; }BaseDao，为业务层提供标准数据库访问的基类，是自动提供标准rest微服务的关键
import IDao from './idao' let dialect = G.CONFIGS.db_dialect //依赖注入 let Dao = require(`./${dialect}Dao`).default export default class BaseDao { private table: string static dao: IDao //以组合的模式，解耦业务层与数据库访问层 constructor(table?: string) { this.table = table || '' if (!BaseDao.dao) { BaseDao.dao = new Dao() } } async retrieve(params = {}, fields = [], session = {userid: ''}): Promise<any> { let rs try { rs = await BaseDao.dao.select(this.table, params, fields) } catch (err) { err.message = `data query fail: ${err.message}` return err } return rs } async create(params = {}, fields = [], session = {userid: ''}): Promise<any> { let rs try { rs = await BaseDao.dao.insert(this.table, params) } catch (err) { err.message = `data insert fail: ${err.message}` return err } let { affectedRows } = rs return G.jsResponse(200, 'data insert success.', { affectedRows, id: rs.insertId }) } async update(params, fields = [], session = { userid: '' }): Promise<any> { params = params || {} const { id, ...restParams } = params let rs try { rs = await BaseDao.dao.update(this.table, restParams, id) } catch (err) { err.message = `data update fail: ${err.message}` return err } let { affectedRows } = rs return G.jsResponse(200, 'data update success.', { affectedRows, id }) } async delete(params = {}, fields = [], session = {userid: ''}): Promise<any> { let id = params['id'] let rs try { rs = await BaseDao.dao.delete(this.table, id) } catch (err) { err.message = `data delete fail: ${err.message}` return err } let {affectedRows} = rs return G.jsResponse(200, 'data delete success.', { affectedRows, id }) } }
高级操作
execSql执行手写sql语句，供后端内部调用
使用示例
await new BaseDao().execSql("update users set username = ?, age = ? where id = ? ", ["gels","99","6"])返回参数
{ "affectedRows": 1, "status": 200, "message": "data execSql success." }
insertBatch批量插入与更新二合一接口，供后端内部调用
使用示例
let params = [ { "username":"bill2", "password":"523", "age":4 }, { "username":"bill3", "password":"4", "age":44 }, { "username":"bill6", "password":"46", "age":46 } ] await new BaseDao().insertBatch('users', params)返回参数
{ "affectedRows": 3, "status": 200, "message": "data batch success." }
tranGo事务处理接口，供后端内部调用
使用示例
let trs = [ { table: 'users', method: 'Insert', params: { username: 'zhou1', password: '1', age: 1 } }, { table: 'users', method: 'Insert', params: { username: 'zhou2', password: '2', age: 2 } }, { table: 'users', method: 'Insert', params: { username: 'zhou3', password: '3', age: 3 } } ] await new BaseDao().transGo(trs, true) //true，异步执行；false,同步执行返回参数
{ "affectedRows": 3, "status": 200, "message": "data trans success." }
相关视频课程
运用typescript进行node.js后端开发精要
nodejs实战之智能微服务快速开发框架
JSON-ORM（对象关系映射）设计与实现
Koa2封装数据库高级操作
蜘蛛实时爬取数据提供图书信息微服务
资源地址
凝胶（gels）项目： https://github.com/zhoutk/gels
视频讲座资料： https://github.com/zhoutk/sifou
个人博客： https://segmentfault.com/blog...