findOne(); } catch (\Exception $ex) { $database = new Database($con->getWrappedConnection()); $database->insertSql(null, array(__DIR__ . '/Config/thelia.sql')); } } public function update($currentVersion, $newVersion, ConnectionInterface $con = null) { $finder = (new Finder) ->files() ->name('#.*?\.sql#') ->sortByName() ->in(__DIR__ . DS . 'Config' . DS . 'update' . DS . 'sql'); $database = new Database($con); /** @var \Symfony\Component\Finder\SplFileInfo $updateSQLFile */ foreach ($finder as $updateSQLFile) { if (version_compare($currentVersion, str_replace('.sql', '', $updateSQLFile->getFilename()), '<')) { $database->insertSql( null, [ $updateSQLFile->getPathname() ] ); } } } }