getPdo(); $file = \File::get(base_path() . '/database/update.sql'); if (!$file) { abort(500, '数据库文件不存在'); } $sql = str_replace("\n", "", $file); $sql = preg_split("/;/", $sql); if (!is_array($sql)) { abort(500, '数据库文件格式有误'); } $this->info('正在导入数据库请稍等...'); foreach ($sql as $item) { if (!$item) continue; try { DB::select(DB::raw($item)); } catch (\Exception $e) { } } \Artisan::call('horizon:terminate'); $this->info('更新完毕,队列服务已重启,你无需进行任何操作。'); } }