手机浏览 RSS 2.0 订阅 膘叔的简单人生 , 腾讯云RDS购买 | 超便宜Qcloud , 注册 | 登陆

laravel mass update can not fire any events

首页 > PHP >

 一个很简单的laravel代码:

PHP代码
  1. User::where('id',1)->update(['last_login'=>time()]);  
这样一个简单的代码,你会发现,它并没有触发:updating,updated事件,然而,你又会发现,updated_at也更新了。这是怎么回事?
跟进代码看一下,你会发现这个update,是Eloquent\Builder的方法,它的update方法代码很简单:
PHP代码
  1. /** 
  2.  * Update a record in the database. 
  3.  * 
  4.  * @param  array  $values 
  5.  * @return int 
  6.  */  
  7. public function update(array $values)  
  8. {  
  9.     return $this->toBase()->update($this->addUpdatedAtColumn($values));  
  10. }  
我擦 ,要不要这么直接?再看一下toBase,这回是调用的是Query\Builder了。这里的update,就纯粹是生成sql,然后execute,不再走EloquentORM的事件了,所以就不会触发任何事件。
 
那么要怎么样才能触发事件呢?方法有两种
1、不要这样简写:先读数据再update,就一定会触发
2、不要用where(),而是直接User::find(1)->update([]),这时候就会从ORM走了。
 
这事儿官方有解释:
https://laravel.com/docs/5.3/eloquent#updates
  1. When issuing a mass update via Eloquent, the saved and updated model events will not be fired for the updated models. This is because the models are never actually retrieved when issuing a mass update.  
同时,这事儿在stackoverflow上也有很多人在问,有人回复的就是和我上面的一样:
http://stackoverflow.com/questions/41295032/laravel-eloquent-model-update-event-is-not-fired
  1. You need to retrieve the user from the database and then save that user in order to fire the event. For example:  
  2.   
  3. This will NOT fire the update event:  
  4.   
  5. User::where('id', $id)->update(['username' => $newUsername]);  
  6. This will fire the update event:  
  7.   
  8. User::find($id)->update(['username' => $newUsername]);  
官方的解释我是看过了,下面的是我用了很多办法没法解决后才找到的。
我在想,use SoftDeletes可以注入代码,为什么我不行?直到我发现softdeletes是官方自带库,人家都准备了事件:onDelete了。。怎么就没有onUpdate事件可以让我加点字段呢?
然后我又想用其他的Scope,也没有成功(折腾了一个下午)
 
暂时放弃!就这样吧,不过我还在想想,有没有什么办法可以注入,因为在sql生成完后,它还是有触发的事件的,比如:
PHP代码
  1. /** 
  2.   * Log a query in the connection's query log. 
  3.   * 
  4.   * @param  string  $query 
  5.   * @param  array   $bindings 
  6.   * @param  float|null  $time 
  7.   * @return void 
  8.   */  
  9.  public function logQuery($query$bindings$time = null)  
  10.  {  
  11.      if (isset($this->events)) {  
  12.          $this->events->fire(new Events\QueryExecuted(  
  13.              $query$bindings$time$this  
  14.          ));  
  15.      }  
  16.   
  17.      if ($this->loggingQueries) {  
  18.          $this->queryLog[] = compact('query', 'bindings', 'time'); 
  19.      } 
  20.  } 
  21.  
  22.  /** 
  23.   * Register a database query listener with the connection. 
  24.   * 
  25.   * @param  \Closure  $callback 
  26.   * @return void 
  27.   */ 
  28.  public function listen(Closure $callback) 
  29.  { 
  30.      if (isset($this->events)) { 
  31.          $this->events->listen(Events\QueryExecuted::class, $callback); 
  32.      } 
  33.  } 
  34.  
  35.  /** 
  36.   * Fire an event for this connection. 
  37.   * 
  38.   * @param  string  $event 
  39.   * @return void 
  40.   */ 
  41.  protected function fireConnectionEvent($event) 
  42.  { 
  43.      if (! isset($this->events)) { 
  44.          return; 
  45.      } 
  46.  
  47.      switch ($event) { 
  48.          case 'beganTransaction': 
  49.              return $this->events->fire(new Events\TransactionBeginning($this)); 
  50.          case 'committed': 
  51.              return $this->events->fire(new Events\TransactionCommitted($this)); 
  52.          case 'rollingBack':  
  53.              return $this->events->fire(new Events\TransactionRolledBack($this));  
  54.      }  
  55.  }  
实在不行了,还可以在事务上面想想办法,但是总归是只能一次处理,如果是需要两次执行sql。那还不如直接写代码呢。等有空再看了
 
 
 



本站采用创作共享版权协议, 要求署名、非商业和保持一致. 本站欢迎任何非商业应用的转载, 但须注明出自"膘叔", 保留原始链接, 此外还必须标注原文标题和链接.

« 上一篇 | 下一篇 »

发表评论

评论内容 (必填):