@clusic / mysql

mysql数据库操作类

Install

npm i @clusic/mysql

Usage

const MySQL = require('@clusic/mysql');
const mysql = new MySQL(options, isPool);
await mysql.begin();
await mysql.insert(table, data);
await mysql.update(table, data, ...conditions);
await mysql.delete(table, ...conditions);
await mysql.commit();
await mysql.rollback();
mysql.release();

Events

• beforeBegin 事务开启前
• begin 事务开启后
• beforeCommit 提交前
• commit 提交后
• beforeRollback 回滚前
• rollback 回滚后
• beforeExec 执行SQL语句前
• exec 执行SQL语句后

mysql.on('begin', () => console.log('事务开始了'));
mysql.on('exec', (sql, ...args) => console.log(sql, ...args));

In Clusic Plugin

在worker中，ctx上会存在一个你在配置[contextName]属性名的对象，指向当前mysql操作对象。

await ctx.mysql.begin();
await ctx.mysql.insert(...);
await ctx.mysql.commit();

在agent中，全局app[contextName]指向对应的操作对象。

app.feed(name, async () => {
  await app.mysql.begin();
  await app.mysql.insert(...);
  await app.mysql.commit();
})