sql = $sql; } /** * @return void * * @throws Exception */ public function postConnect(ConnectionEventArgs $args) { $args->getConnection()->executeStatement($this->sql); } /** * {@inheritDoc} */ public function getSubscribedEvents() { return [Events::postConnect]; } }