{$content} <--------- EOF; $result = fwrite($handle, $string); fclose($handle); return $result ? true : false; } /** * 执行SQL * @param string $sql 要运行的SQL * @param bool $split 自动拆分SQL * @param bool $continueOnError 遇到错误继续执行 * @throws Exception */ function sql_execute($sql, $split = true, $continueOnError = true) { if ($split) { $list = SqlFormatter::splitQuery($sql); } else { $list = [$sql]; } foreach ($list as $item) { try { set_error_handler(function ($errno, $errstr) { upgrade_log($errstr); }); pdo_run($item); restore_error_handler(); } catch (Exception $exception) { upgrade_log($exception->getMessage()); if (!$continueOnError) { throw $exception; } } } } /** * 检查数据表是否存在 * @param $tableName * @return bool */ function sql_table_exists($tableName) { $sql = "SHOW TABLES LIKE '{$tableName}';"; $result = pdo_fetch($sql); if (is_array($result) && count($result)) { return true; } else { return false; } } $dbConfigFile = __DIR__ . '/config/db.php'; if (!file_exists($dbConfigFile)) { file_put_contents($dbConfigFile, << \$we7DbConfig['host'], 'port' => \$we7DbConfig['port'], 'dbname' => \$we7DbConfig['database'], 'username' => \$we7DbConfig['username'], 'password' => \$we7DbConfig['password'], ]; } \$we7DbConfig = getWe7DbConfig(); return [ 'host' => \$we7DbConfig['host'], 'port' => \$we7DbConfig['port'], 'dbname' => \$we7DbConfig['dbname'], 'username' => \$we7DbConfig['username'], 'password' => \$we7DbConfig['password'], 'tablePrefix' => 'zjhj_bd_', ]; EOF ); } $optionTableName = 'zjhj_bd_option'; try { if (sql_table_exists($optionTableName)) { $result = pdo_fetch("SELECT * FROM `{$optionTableName}` WHERE `name`='version' ORDER BY `id` DESC LIMIT 1;"); if (is_array($result) && count($result)) { $currentVersion = isset($result['value']) ? json_decode($result['value']) : null; } else { $currentVersion = null; } } else { $currentVersion = null; } } catch (Exception $exception) { $currentVersion = null; } $isNewInstall = $currentVersion ? false : true; $currentVersion = $currentVersion ? $currentVersion : '0.0.0'; $lastVersion = $currentVersion; // 运行各个版本的升级脚本 $versions = require __DIR__ . '/versions.php'; foreach ($versions as $v => $f) { $lastVersion = $v; if (version_compare($v, $currentVersion) > 0) { if ($f instanceof \Closure) { $f(); } } } if (sql_table_exists($optionTableName)) { // 结束，更新数据库标记的版本号 $nowDateTime = date('Y-m-d H:i:s'); if ($isNewInstall) { $updateVersionSql = <<