lkddi/nexusphp
1
0
Fork 0
mirror of https://github.com/lkddi/nexusphp.git synced 2026-04-24 12:07:23 +08:00
Code Issues Packages Projects Releases Wiki Activity

install import data

Browse Source
This commit is contained in:
xiaomlove
2021-01-28 18:00:54 +08:00
parent c4ecaa0793
commit 96e9eb42db
5 changed files with 52 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files
nexus/Database/DB.php
+17 -10
View File
@@ -29,6 +29,11 @@ class DB
return $this;
}
public function getDriver()
{
return $this->driver;
}
public static function getInstance()
{
if (self::$instance) {
@@ -42,25 +47,27 @@ class DB
public function connect($host, $username, $password, $database, $port)
{
$this->driver->connect($host, $username, $password, $database, $port);
$result = $this->driver->connect($host, $username, $password, $database, $port);
if (!$result) {
throw new DatabaseException(sprintf('[%s]: %s', $this->errno(), $this->error()));
}
$this->driver->query("SET NAMES UTF8");
$this->driver->query("SET collation_connection = 'utf8_general_ci'");
$this->driver->query("SET sql_mode=''");
$this->isConnected = true;
do_log("do mysql_connect with: " . json_encode(func_get_args()));
$log = json_encode(func_get_args());
do_log($log);
return true;
}
public function autoConnect()
{
if ($this->isConnected()) {
return;
return null;
}
$config = config('database.mysql');
if (!mysql_connect($config['host'], $config['username'], $config['password'], $config['database'], $config['port'])) {
throw new DatabaseException(sprintf("mysql connect error: [%s] %s", mysql_errno(), mysql_error()));
}
mysql_query("SET NAMES UTF8");
mysql_query("SET collation_connection = 'utf8_general_ci'");
mysql_query("SET sql_mode=''");
$this->isConnected = true;
do_log(json_encode($config));
return $this->connect($config['host'], $config['username'], $config['password'], $config['database'], $config['port']);
}
public function query(string $sql)
nexus/Install/Install.php
+28 -2
View File
@@ -10,7 +10,13 @@ class Install
private $minimumPhpVersion = '7.2.0';
protected $steps = ['环境检测', '添加 .env 文件', '新建数据表', '导入数据', '创建管理员账号'];
protected $steps = ['环境检测', '添加 .env 文件', '创建数据表', '导入数据', '创建管理员账号'];
protected $initializeTables = [
'adminpanel', 'agent_allowed_exception', 'agent_allowed_family', 'allowedemails', 'audiocodecs', 'avps', 'bannedemails', 'categories',
'caticons', 'codecs', 'countries', 'downloadspeed', 'faq', 'isp', 'language', 'media', 'modpanel', 'processings', 'rules', 'schools',
'searchbox', 'secondicons', 'sources', 'standards', 'stylesheets', 'sysoppanel', 'teams', 'torrents_state', 'uploadspeed', 'agent_allowed_family',
];
public function __construct()
@@ -421,7 +427,7 @@ class Install
public function saveSettings($settings)
{
foreach ($settings as $prefix => &$group) {
foreach ($settings as $prefix => $group) {
$this->doLog("[SAVE SETTING], prefix: $prefix, nameAndValues: " . json_encode($group));
saveSetting($prefix, $group);
}
@@ -443,4 +449,24 @@ class Install
}
return true;
}
public function importInitialData($sqlFile = '')
{
if (empty($sqlFile)) {
$sqlFile = ROOT_PATH . '_db/dbstructure_v1.6.sql';
}
$string = file_get_contents($sqlFile);
$pattern = "/INSERT INTO `(\w+)` VALUES \(.*\);\n/i";
preg_match_all($pattern, $string, $matches, PREG_SET_ORDER);
foreach ($matches as $match) {
$table = $match[1];
$sql = trim($match[0]);
if (!in_array($table, $this->initializeTables)) {
continue;
}
$this->doLog("[IMPORT DATA] $table, $sql");
sql_query($sql);
}
return true;
}
}