回调事件

针对全局 onQuery

针对全局设置回调事件方式如下:

  1. // 注册ORM时, 调用回调函数
  2. public static function mainServerCreate(EventRegister $register)
  3. {
  4. ...
  5. DbManager::getInstance()->addConnection(new Connection($config));
  6. DbManager::getInstance()->onQuery(function ($res, $builder, $start) {
  7. // 打印参数 OR 写入日志
  8. });
  9. }

onQuery回调会注入三个参数

  • res查询结果对象, 类名为EasySwoole\ORM\Db\Result

可以参考 执行结果 文档, 以获取更多的结果内容

  • builder查询语句对象, 类名为EasySwoole\Mysqli\QueryBuilder

  • start开始查询时间戳, 单位为s, 类型为float

如果查询过程中调用withTotalCount()方法, 那么还会产生第二个回调结果

需要注意的是, 此回调方法务必在注册ORM时调用, 否则不会产生任何结果

针对特定模型 onQuery

如果不想使用全局性的onQuery, 我们可以在执行操作的时候调用onQuery方法, 以此来实现针对特定模型的回调

  1. $res = User::create()->onQuery(function ($res, $builder, $start) {
  2. // 打印参数 OR 写入日志
  3. })->get(1);

回调注入的三个参数与全局性onQuery相同

记录慢日志

我们可以通过手动判断执行时间, 来实现一个记录慢日志的功能

  1. public static function mainServerCreate(EventRegister $register)
  2. {
  3. ...
  4. DbManager::getInstance()->addConnection(new Connection($config));
  5. DbManager::getInstance()->onQuery(function ($res, $builder, $start) {
  6. $queryTime = 查询时间阈值;
  7. if (bcsub(time(), $start, 3) > $queryTime) {
  8. // 写入日志
  9. }
  10. });
  11. }