Skip to content

yskit/ys-dbo

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

17 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

ys-dbo

YS 架构之请求线程的引擎管理类,用于完善处理请求自定义逻辑,支持自定义回滚机制。

Install

npm i ys-dbo --save

Usage

const DBO = require('ys-dbo');
const dbo = new DBO([
  // plugins ...
])

目前插件支持以下2个:

  • ys-dbo-mysql MySQL的操作引擎
  • ys-dbo-redis Redis的操作引擎

其他插件用户可以根据DBO提供的生命周期自行开发。

dbo.until(next, options)

用于处理一个线程的逻辑

  • next function 逻辑处理函数
  • options json 参数配置
    • context object dbo将会在这个对象上添加一个命名空间对象
    • name string 命名空间名称
    • error function 错误处理函数 error(err, ctx) {}
      • err error 错误
      • ctx 同上的context
const target = {};
dbo.until(async way => {
  console.log(way.id);
  target.a = 1;
  throw new Error('err');
}, {
  context: target,
  name: 'ys',
  error(err, ctx) {
    console.log(err);
    console.log(ctx.a);
  }
})

Use in koa2 middleware

app.use(dbo.way({
  error(err, ctx) {
    ctx.status = err.code || 500;
    ctx.body = err.stack;
  }
}));

Use events

app.use(dbo.way({
  error(err, ctx) {
    ctx.status = err.code || 500;
    ctx.body = err.stack;
  }
}));

app.use(async (ctx, next) => {
  ctx.dbo.on('beforeCommit', asyncNoop('beforeCommit'));
  ctx.dbo.on('afterCommit', asyncNoop('afterCommit'));
  ctx.dbo.on('beforeRollback', asyncNoop('beforeRollback'));
  ctx.dbo.on('afterRollback', asyncNoop('afterRollback'));
  ctx.dbo.on('beforeEnd', asyncNoop('beforeEnd'));
  ctx.dbo.on('afterEnd', asyncNoop('afterEnd'));
  await next();
});

function asyncNoop(value) {
  return async () => {
    await new Promise(resolve => {
      setTimeout(() => {
        console.log(value);
        resolve();
      }, 3000);
    })
  }
}

License

It is MIT licensed.

Releases

No releases published

Packages

No packages published