1924 lines
83 KiB
PHP
1924 lines
83 KiB
PHP
|
<?php
|
|||
|
|
|
|||
|
|
declare(strict_types = 1);
|
|||
|
|
|
|||
|
|
/***************************************************************************\
|
|||
|
|
* | Sypex Dumper version 2.0.11 |
|
|||
|
|
* | (c) 2003-2011 zapimir zapimir@zapimir.net http://sypex.net/ |
|
|||
|
|
* | (c) 2005-2011 BINOVATOR info@sypex.net |
|
|||
|
|
* |---------------------------------------------------------------------------|
|
|||
|
|
* | created: 2003.09.02 19:07 modified: 2013.08.27 06:27 |
|
|||
|
|
* |---------------------------------------------------------------------------|
|
|||
|
|
* | Sypex Dumper is released under the terms of the BSD license |
|
|||
|
|
* | http://sypex.net/bsd_license.txt |
|
|||
|
|
* \***************************************************************************/
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* PSR-2 & PHP7 support fixed by Beaten_Sect0r
|
|||
|
|
*/
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* PHP7.1 support fixed by MaxiSoft
|
|||
|
|
*/
|
|||
|
|
|
|||
|
|
header('Expires: Wed, 19 Nov 2008 19:19:19 GMT');
|
|||
|
|
header('Cache-Control: no-store, no-cache, must-revalidate');
|
|||
|
|
header('Content-Type: text/html; charset=utf-8');
|
|||
|
|
error_reporting(E_ALL);
|
|||
|
|
//error_reporting(0);
|
|||
|
|
if (!ini_get('zlib.output_compression') && function_exists('ob_gzhandler')) {
|
|||
|
|
ob_start('ob_gzhandler');
|
|||
|
|
}
|
|||
|
|
set_error_handler('sxd_error_handler');
|
|||
|
|
register_shutdown_function('sxd_shutdown');
|
|||
|
|
$SXD = new SypexDumper();
|
|||
|
|
chdir(__DIR__);
|
|||
|
|
$SXD->init(!empty($argc) && $argc > 1 ? $argv : false);
|
|||
|
|
|
|||
|
|
class SypexDumper
|
|||
|
|
{
|
|||
|
|
|
|||
|
|
public function __construct()
|
|||
|
|
{
|
|||
|
|
define('C_DEFAULT', 1);
|
|||
|
|
define('C_RESULT', 2);
|
|||
|
|
define('C_ERROR', 3);
|
|||
|
|
define('C_WARNING', 4);
|
|||
|
|
define('SXD_DEBUG', false);
|
|||
|
|
define('TIMER', array_sum(explode(' ', microtime())));
|
|||
|
|
define('V_SXD', 20011);
|
|||
|
|
define('V_PHP', sxd_ver2int(phpversion()));
|
|||
|
|
$this->name = 'Sypex Dumper 2.0.11';
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function loadLang($lng_name = 'auto')
|
|||
|
|
{
|
|||
|
|
if ($lng_name == 'auto') {
|
|||
|
|
include 'lang/list.php';
|
|||
|
|
$this->langs = &$langs;
|
|||
|
|
$lng = 'en';
|
|||
|
|
if (preg_match_all('/[a-z]{2}(-[a-z]{2})?/', $_SERVER['HTTP_ACCEPT_LANGUAGE'], $m)) {
|
|||
|
|
foreach ($m[0] as $l) {
|
|||
|
|
if (isset($langs[ $l ])) {
|
|||
|
|
$lng_name = $l;
|
|||
|
|
break;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
if (file_exists("lang/lng_{$lng_name}.php")) {
|
|||
|
|
include "lang/lng_{$lng_name}.php";
|
|||
|
|
} else {
|
|||
|
|
include 'lang/lng_en.php';
|
|||
|
|
}
|
|||
|
|
$this->LNG = &$LNG;
|
|||
|
|
$this->LNG['name'] = $lng_name;
|
|||
|
|
|
|||
|
|
return true;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function init($args = false)
|
|||
|
|
{
|
|||
|
|
if (get_magic_quotes_gpc()) {
|
|||
|
|
$_POST = sxd_antimagic($_POST);
|
|||
|
|
}
|
|||
|
|
include 'cfg.php';
|
|||
|
|
$this->loadLang($CFG['lang']);
|
|||
|
|
if (function_exists('set_time_limit') && strpos(ini_get('disable_functions'), 'set_time_limit') === false) {
|
|||
|
|
set_time_limit((int)$CFG['time_web']);
|
|||
|
|
} elseif (ini_get('max_execution_time') < $CFG['time_web']) {
|
|||
|
|
$CFG['time_web'] = ini_get('max_execution_time');
|
|||
|
|
}
|
|||
|
|
$this->CFG = &$CFG;
|
|||
|
|
$this->try = false;
|
|||
|
|
$this->virtualize = false;
|
|||
|
|
$this->cron_mode = false;
|
|||
|
|
// Проверяем авторизацию и делаем коннект к базе
|
|||
|
|
if (empty($this->CFG['my_user'])) {
|
|||
|
|
$this->CFG['my_host'] = 'localhost';
|
|||
|
|
$this->CFG['my_port'] = 3306;
|
|||
|
|
$this->CFG['my_user'] = 'root';
|
|||
|
|
$this->CFG['my_pass'] = '';
|
|||
|
|
$this->CFG['my_comp'] = 0;
|
|||
|
|
$this->CFG['my_db'] = '';
|
|||
|
|
}
|
|||
|
|
if ($args) { // консольный режим
|
|||
|
|
foreach ($args as $key => $arg) {
|
|||
|
|
if (preg_match('/^-([hupoj])=(.*?)$/', $arg, $m)) {
|
|||
|
|
switch ($m[1]) {
|
|||
|
|
case 'h':
|
|||
|
|
$this->CFG['my_host'] = $m[2];
|
|||
|
|
break; // хост
|
|||
|
|
case 'o':
|
|||
|
|
$this->CFG['my_port'] = $m[2];
|
|||
|
|
break; // порт
|
|||
|
|
case 'u':
|
|||
|
|
$this->CFG['my_user'] = $m[2];
|
|||
|
|
break; // логин
|
|||
|
|
case 'p':
|
|||
|
|
$this->CFG['my_pass'] = $m[2];
|
|||
|
|
break; // пароль
|
|||
|
|
case 'j':
|
|||
|
|
$this->CFG['sjob'] = $m[2];
|
|||
|
|
break; // job-файл
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
$this->cron_mode = true;
|
|||
|
|
set_time_limit((int)$CFG['time_cron']);
|
|||
|
|
// Загружаем конфиг файл, если нужно
|
|||
|
|
$auth = $this->connect();
|
|||
|
|
if ($auth && !empty($this->CFG['sjob'])) {
|
|||
|
|
$this->ajax($this->loadJob($this->CFG['sjob']));
|
|||
|
|
echo file_get_contents($this->JOB['file_log']);
|
|||
|
|
if (file_exists($this->JOB['file_log'])) {
|
|||
|
|
unlink($this->JOB['file_log']);
|
|||
|
|
}
|
|||
|
|
if (file_exists($this->JOB['file_rtl'])) {
|
|||
|
|
unlink($this->JOB['file_rtl']);
|
|||
|
|
}
|
|||
|
|
} else {
|
|||
|
|
echo 'Auth error';
|
|||
|
|
}
|
|||
|
|
exit;
|
|||
|
|
} elseif (!empty($this->CFG['auth'])) { // Авторизация
|
|||
|
|
$auth = false;
|
|||
|
|
$sfile = 'ses.php';
|
|||
|
|
|
|||
|
|
if (!empty($_COOKIE['sxd']) && preg_match('/^[\da-f]{32}$/', $_COOKIE['sxd'])) {
|
|||
|
|
include $sfile;
|
|||
|
|
if (isset($SES[ $_COOKIE['sxd'] ])) {
|
|||
|
|
$auth = true;
|
|||
|
|
$this->CFG = $SES[ $_COOKIE['sxd'] ]['cfg'];
|
|||
|
|
$this->SES = &$SES;
|
|||
|
|
$this->loadLang($this->CFG['lang']);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
if (!$auth) {
|
|||
|
|
$user = !empty($_POST['user']) ? $_POST['user'] : '';
|
|||
|
|
$pass = !empty($_POST['pass']) ? $_POST['pass'] : '';
|
|||
|
|
$host = !empty($_POST['host']) ? $_POST['host'] : (!empty($this->CFG['my_host']) ? $this->CFG['my_host'] : 'localhost');
|
|||
|
|
$port = !empty($_POST['port']) && is_numeric($_POST['port']) ? $_POST['port'] : 3306;
|
|||
|
|
$temp = preg_split('/\s+/', $this->CFG['auth']);
|
|||
|
|
if (!empty($_REQUEST['lang']) && preg_match('/^[a-z]{2}(-[a-z]{2})?$/', $_REQUEST['lang'])) {
|
|||
|
|
$this->loadLang($_REQUEST['lang']);
|
|||
|
|
}
|
|||
|
|
foreach ($temp as $a) {
|
|||
|
|
switch ($a) {
|
|||
|
|
case 'cfg':
|
|||
|
|
if (empty($user)) {
|
|||
|
|
continue;
|
|||
|
|
}
|
|||
|
|
$auth = !empty($CFG['user']) && isset($CFG['pass']) && $CFG['user'] == $user && $CFG['pass'] == $pass;
|
|||
|
|
break;
|
|||
|
|
case 'mysql':
|
|||
|
|
if (empty($user)) {
|
|||
|
|
continue;
|
|||
|
|
}
|
|||
|
|
if ($host != 'localhost' && !empty($this->CFG['my_host']) && $this->CFG['my_host'] != $host) {
|
|||
|
|
continue;
|
|||
|
|
}
|
|||
|
|
$auth = $this->connect($host, $port, $user, $pass);
|
|||
|
|
break;
|
|||
|
|
default:
|
|||
|
|
$file = 'auth_' . $a . '.php';
|
|||
|
|
if (!file_exists($file)) {
|
|||
|
|
continue;
|
|||
|
|
}
|
|||
|
|
include $file;
|
|||
|
|
}
|
|||
|
|
if ($auth) {
|
|||
|
|
break;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
if ($auth) {
|
|||
|
|
$key = md5(rand(1, 100000) . $user . microtime());
|
|||
|
|
$CFG['lang'] = $this->LNG['name'];
|
|||
|
|
$_COOKIE['sxd'] = $key;
|
|||
|
|
$this->saveCFG();
|
|||
|
|
if (V_PHP > 50200) {
|
|||
|
|
setcookie('sxd', $key, !empty($_POST['save']) ? time() + 31536000 : 0, '', '', false, true);
|
|||
|
|
} else {
|
|||
|
|
setcookie('sxd', $key, !empty($_POST['save']) ? time() + 31536000 : 0, '', '', false);
|
|||
|
|
}
|
|||
|
|
header('Location: ./');
|
|||
|
|
exit;
|
|||
|
|
}
|
|||
|
|
foreach (['user', 'pass', 'host', 'port'] as $key) {
|
|||
|
|
$_POST[ $key ] = !empty($_POST[ $key ]) ? htmlspecialchars($_POST[ $key ], ENT_NOQUOTES) : '';
|
|||
|
|
}
|
|||
|
|
$_POST['save'] = !empty($_POST['save']) ? ' CHECKED' : '';
|
|||
|
|
}
|
|||
|
|
if (!$auth) {
|
|||
|
|
if (!empty($_POST['ajax'])) {
|
|||
|
|
echo "sxd.hideLoading();alert('Session not found');";
|
|||
|
|
exit;
|
|||
|
|
}
|
|||
|
|
$this->lng_list = '<option value="auto">- auto -</opinion>';
|
|||
|
|
if (!isset($this->langs)) {
|
|||
|
|
include 'lang/list.php';
|
|||
|
|
$this->langs = &$langs;
|
|||
|
|
}
|
|||
|
|
foreach ($this->langs as $k => $v) {
|
|||
|
|
$this->lng_list .= "<option value=\"{$k}\"" . ($k == (!empty($_REQUEST['lang']) ? $this->LNG['name'] : $this->CFG['lang']) ? ' SELECTED' : '') . ">{$v}</opinion>";
|
|||
|
|
}
|
|||
|
|
include 'tmpl.php';
|
|||
|
|
echo sxd_tpl_auth();
|
|||
|
|
exit;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
if (empty($_POST['ajax']['act']) || $_POST['ajax']['act'] != 'save_connect') {
|
|||
|
|
$this->connect();
|
|||
|
|
}
|
|||
|
|
if (isset($_POST['ajax'])) {
|
|||
|
|
$this->ajax($_POST['ajax']);
|
|||
|
|
} else {
|
|||
|
|
$this->main();
|
|||
|
|
}
|
|||
|
|
exit;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function saveToFile($name, $content)
|
|||
|
|
{
|
|||
|
|
$fp = fopen($name, 'w');
|
|||
|
|
fwrite($fp, $content);
|
|||
|
|
fclose($fp);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function connect($host = null, $port = null, $user = null, $pass = null)
|
|||
|
|
{
|
|||
|
|
$this->error = '';
|
|||
|
|
$this->try = true;
|
|||
|
|
if (!empty($user) && isset($pass)) {
|
|||
|
|
$this->CFG['my_host'] = $host;
|
|||
|
|
$this->CFG['my_port'] = $port;
|
|||
|
|
$this->CFG['my_user'] = $user;
|
|||
|
|
$this->CFG['my_pass'] = $pass;
|
|||
|
|
}
|
|||
|
|
if ($GLOBALS['mysqlilink'] = mysqli_connect($this->CFG['my_host'] . ($this->CFG['my_host']{0} != ':' ? ":{$this->CFG['my_port']}" : ''), $this->CFG['my_user'], $this->CFG['my_pass'])) {
|
|||
|
|
if (V_PHP > 50202) {
|
|||
|
|
mysqli_set_charset($GLOBALS['mysqlilink'], 'utf8') or sxd_my_error();
|
|||
|
|
} else {
|
|||
|
|
mysqli_query($GLOBALS['mysqlilink'], 'SET NAMES utf8') or sxd_my_error();
|
|||
|
|
}
|
|||
|
|
define('V_MYSQL', sxd_ver2int(mysqli_get_server_info($GLOBALS['mysqlilink'])));
|
|||
|
|
} else {
|
|||
|
|
define('V_MYSQL', 0);
|
|||
|
|
$this->error = 'sxd.actions.tab_connects();alert(' . sxd_esc(mysqli_error()) . ');';
|
|||
|
|
}
|
|||
|
|
$this->try = false;
|
|||
|
|
|
|||
|
|
return V_MYSQL ? true : false;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function main()
|
|||
|
|
{
|
|||
|
|
// Тулбар
|
|||
|
|
$this->VAR['toolbar'] = sxd_php2json(
|
|||
|
|
[
|
|||
|
|
['backup', $this->LNG['tbar_backup'], 1, 3],
|
|||
|
|
['restore', $this->LNG['tbar_restore'], 2, 3],
|
|||
|
|
['|'],
|
|||
|
|
['files', $this->LNG['tbar_files'], 3, 1],
|
|||
|
|
['services', $this->LNG['tbar_services'], 5, 1],
|
|||
|
|
['|'],
|
|||
|
|
['createdb', $this->LNG['tbar_createdb'], 7, 0],
|
|||
|
|
['connects', $this->LNG['tbar_connects'], 6, 0],
|
|||
|
|
['|'],
|
|||
|
|
['options', $this->LNG['tbar_options'], 4, 1],
|
|||
|
|
['|'],
|
|||
|
|
['exit', $this->LNG['tbar_exit'], 8, 1],
|
|||
|
|
]
|
|||
|
|
);
|
|||
|
|
$this->db = 'temp';
|
|||
|
|
$zip = [$this->LNG['zip_none']];
|
|||
|
|
if (function_exists('gzopen')) {
|
|||
|
|
for ($i = 1; $i < 10; ++$i) {
|
|||
|
|
$zip[] = "GZip: {$i}";
|
|||
|
|
}
|
|||
|
|
$zip[1] .= " ({$this->LNG['zip_min']})";
|
|||
|
|
$zip[7] .= " ({$this->LNG['default']})";
|
|||
|
|
}
|
|||
|
|
if (function_exists('bzopen')) {
|
|||
|
|
$zip[10] = 'BZip';
|
|||
|
|
}
|
|||
|
|
end($zip);
|
|||
|
|
$zip[ key($zip) ] .= " ({$this->LNG['zip_max']})";
|
|||
|
|
$this->VAR['combos'] =
|
|||
|
|
$this->addCombo('backup_db', $this->db, 11, 'db', []/*$this->getDBList()*/) .
|
|||
|
|
$this->addCombo('backup_charset', 0, 9, 'charset', $this->getCharsetList()) .
|
|||
|
|
$this->addCombo('backup_zip', 7, 10, 'zip', $zip) .
|
|||
|
|
$this->addCombo('restore_db', $this->db, 11, 'db') .
|
|||
|
|
$this->addCombo('restore_charset', 0, 9, 'charset') .
|
|||
|
|
$this->addCombo('restore_file', 0, 12, 'files', $this->getFileList()) .
|
|||
|
|
$this->addCombo('restore_type', 0, 13, 'types', ["CREATE + INSERT ({$this->LNG['default']})", 'TRUNCATE + INSERT', 'REPLACE', 'INSERT IGNORE']) .
|
|||
|
|
$this->addCombo('services_db', $this->db, 11, 'db') .
|
|||
|
|
$this->addCombo('services_check', 0, 5, 'check', ["- {$this->LNG['default']} -", 'QUICK', 'FAST', 'CHANGED', 'MEDIUM', 'EXTENDED']) .
|
|||
|
|
$this->addCombo('services_repair', 0, 5, 'repair', ["- {$this->LNG['default']} -", 'QUICK', 'EXTENDED']) .
|
|||
|
|
$this->addCombo('db_charset', 0, 9, 'collation', $this->getCollationList()) .
|
|||
|
|
$this->addCombo('db_charset_col', 0, 15, 'collation:db_charset');
|
|||
|
|
if (!V_MYSQL) {
|
|||
|
|
$this->VAR['combos'] .= $this->error;
|
|||
|
|
}
|
|||
|
|
$this->VAR['combos'] .= $this->getSavedJobs() . "sxd.confirms = {$this->CFG['confirm']};sxd.actions.dblist();";
|
|||
|
|
$this->LNG['del_date'] = sprintf($this->LNG['del_date'], '<input type="text" id="del_time" class=txt style="width:24px;" maxlength="3">');
|
|||
|
|
$this->LNG['del_count'] = sprintf($this->LNG['del_count'], '<input id="del_count" type="text" class=txt style="width:18px;" maxlength="2">');
|
|||
|
|
|
|||
|
|
include 'tmpl.php';
|
|||
|
|
echo sxd_tpl_page();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function addCombo($name, $sel, $ico, $opt_name, $opts = '')
|
|||
|
|
{
|
|||
|
|
$opts = !empty($opts) ? "{{$opt_name}:" . sxd_php2json($opts) . '}' : "'{$opt_name}'";
|
|||
|
|
|
|||
|
|
return "sxd.addCombo('{$name}', '{$sel}', {$ico}, {$opts});\n";
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function ajax($req)
|
|||
|
|
{
|
|||
|
|
$res = '';
|
|||
|
|
$act = $req['act'];
|
|||
|
|
if ($req['act'] == 'run_savedjob') {
|
|||
|
|
$req = $this->loadJob($req);
|
|||
|
|
}
|
|||
|
|
switch ($req['act']) {
|
|||
|
|
case 'load_db':
|
|||
|
|
$res = $this->getObjects(str_replace('_db', '', $req['name']), $req['value']);
|
|||
|
|
break;
|
|||
|
|
case 'load_files':
|
|||
|
|
$res = $this->getFileObjects('restore', $req['value']);
|
|||
|
|
break;
|
|||
|
|
case 'filelist':
|
|||
|
|
$res = "sxd.clearOpt('files');sxd.addOpt(" . sxd_php2json(['files' => $this->getFileList()]) . ');';
|
|||
|
|
break;
|
|||
|
|
case 'dblist':
|
|||
|
|
$res = "sxd.clearOpt('db');sxd.addOpt(" . sxd_php2json(['db' => $this->getDBList()]) . ");sxd.combos.restore_db.select(0,'-');sxd.combos.services_db.select(0,'-');sxd.combos.backup_db.select(0,'-');";
|
|||
|
|
break;
|
|||
|
|
case 'load_connect':
|
|||
|
|
$CFG = $this->cfg2js($this->CFG);
|
|||
|
|
$res = "z('con_host').value = '{$CFG['my_host']}', z('con_port').value = '{$CFG['my_port']}', z('con_user').value = '{$CFG['my_user']}',
|
|||
|
|
z('con_pass').value = '', z('con_comp').checked = {$CFG['my_comp']}, z('con_db').value = '{$CFG['my_db']}', z('con_pass').changed = false;";
|
|||
|
|
break;
|
|||
|
|
case 'save_connect':
|
|||
|
|
$res = $this->saveConnect($req);
|
|||
|
|
break;
|
|||
|
|
case 'save_job':
|
|||
|
|
unset($req['act']);
|
|||
|
|
$this->saveJob('sj_' . $req['job'], $req);
|
|||
|
|
$res = $this->getSavedJobs();
|
|||
|
|
break;
|
|||
|
|
case 'add_db':
|
|||
|
|
$res = $this->addDb($req);
|
|||
|
|
break;
|
|||
|
|
case 'load_options':
|
|||
|
|
$CFG = $this->cfg2js($this->CFG);
|
|||
|
|
$res = "z('time_web').value = '{$CFG['time_web']}', z('time_cron').value = '{$CFG['time_cron']}', z('backup_path').value = '{$CFG['backup_path']}',
|
|||
|
|
z('backup_url').value = '{$CFG['backup_url']}', z('globstat').checked = {$CFG['globstat']}, z('charsets').value = '{$CFG['charsets']}', z('only_create').value = '{$CFG['only_create']}', z('auth').value = '{$CFG['auth']}', z('conf_import').checked = {$CFG['confirm']} & 1, z('conf_file').checked = {$CFG['confirm']} & 2, z('conf_db').checked = {$CFG['confirm']} & 4;sxd.confirms = {$this->CFG['confirm']};";
|
|||
|
|
break;
|
|||
|
|
case 'save_options':
|
|||
|
|
$res = $this->saveOptions($req);
|
|||
|
|
break;
|
|||
|
|
case 'delete_file':
|
|||
|
|
if (preg_match('/^[^\/]+?\.sql(\.(gz|bz2))?$/', $req['name'])) {
|
|||
|
|
$file = $this->CFG['backup_path'] . $req['name'];
|
|||
|
|
if (file_exists($file)) {
|
|||
|
|
unlink($file);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
$res = $this->getFileListExtended();
|
|||
|
|
break;
|
|||
|
|
case 'delete_db':
|
|||
|
|
$res = $this->deleteDB($req['name']);
|
|||
|
|
break;
|
|||
|
|
case 'load_files_ext':
|
|||
|
|
$res .= $this->getFileListExtended();
|
|||
|
|
break;
|
|||
|
|
case 'services':
|
|||
|
|
$this->runServices($req);
|
|||
|
|
break;
|
|||
|
|
case 'backup':
|
|||
|
|
$this->addBackupJob($req);
|
|||
|
|
break;
|
|||
|
|
case 'restore':
|
|||
|
|
$this->addRestoreJob($req);
|
|||
|
|
break;
|
|||
|
|
case 'resume':
|
|||
|
|
$this->resumeJob($req);
|
|||
|
|
break;
|
|||
|
|
case 'exit':
|
|||
|
|
setcookie('sxd', '', 0);
|
|||
|
|
$res = 'top.location.href = ' . sxd_esc($this->CFG['exitURL']) . ';';
|
|||
|
|
break;
|
|||
|
|
}
|
|||
|
|
echo $res;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function loadJob($job)
|
|||
|
|
{
|
|||
|
|
$file = $this->CFG['backup_path'] . 'sj_' . (is_array($job) ? $job['job'] : $job) . '.job.php';
|
|||
|
|
if (!file_exists($file)) {
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
include $file;
|
|||
|
|
$JOB['act'] = $JOB['type'];
|
|||
|
|
$JOB['type'] = 'run';
|
|||
|
|
|
|||
|
|
return $JOB;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function deleteDB($name)
|
|||
|
|
{
|
|||
|
|
$r = mysqli_query($GLOBALS['mysqlilink'], 'DROP DATABASE `' . sxd_esc($name, false) . '`') or sxd_my_error();
|
|||
|
|
if ($r) {
|
|||
|
|
echo "sxd.clearOpt('db');sxd.addOpt(" . sxd_php2json(['db' => $this->getDBList()]) . ");sxd.combos.services_db.select(0,'-');";
|
|||
|
|
} else {
|
|||
|
|
echo 'alert(' . sxd_esc(mysqli_error()) . ');';
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function cfg2js($cfg)
|
|||
|
|
{
|
|||
|
|
foreach ($cfg as $k => $v) {
|
|||
|
|
$cfg[ $k ] = sxd_esc($v, false);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return $cfg;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function addDb($req)
|
|||
|
|
{
|
|||
|
|
$r = mysqli_query($GLOBALS['mysqlilink'], 'CREATE DATABASE `' . sxd_esc($req['name'], false) . '`' . (V_MYSQL > 40100 ? "CHARACTER SET {$req['charset']} COLLATE {$req['collate']}" : ''));
|
|||
|
|
if ($r) {
|
|||
|
|
echo 'sxd.addOpt(' . sxd_php2json(['db' => [$req['name'] => "{$req['name']} (0)"]]) . ');';
|
|||
|
|
} else {
|
|||
|
|
sxd_my_error();
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function saveConnect($req)
|
|||
|
|
{
|
|||
|
|
$this->CFG['my_host'] = $req['host'];
|
|||
|
|
$this->CFG['my_port'] = (int)$req['port'];
|
|||
|
|
$this->CFG['my_user'] = $req['user'];
|
|||
|
|
if (isset($req['pass'])) {
|
|||
|
|
$this->CFG['my_pass'] = $req['pass'];
|
|||
|
|
}
|
|||
|
|
$this->CFG['my_comp'] = $req['comp'] ? 1 : 0;
|
|||
|
|
$this->CFG['my_db'] = $req['db'];
|
|||
|
|
$this->saveCFG();
|
|||
|
|
$this->connect();
|
|||
|
|
if (V_MYSQL) {
|
|||
|
|
$tmp = [
|
|||
|
|
'db' => $this->getDBList(),
|
|||
|
|
'charset' => $this->getCharsetList(),
|
|||
|
|
'collation' => $this->getCollationList(),
|
|||
|
|
];
|
|||
|
|
echo "sxd.clearOpt('db');sxd.clearOpt('charset');sxd.clearOpt('collation');sxd.addOpt(" . sxd_php2json($tmp) . ");sxd.combos.backup_db.select(0,'-');sxd.combos.restore_db.select(0,'-');sxd.combos.services_db.select(0,'-');sxd.combos.backup_charset.select(0,'-');sxd.combos.services_db.select(0,'-');sxd.combos.db_charset.select(0,'-');";
|
|||
|
|
} else {
|
|||
|
|
echo $this->error;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function saveOptions($req)
|
|||
|
|
{
|
|||
|
|
$this->CFG['time_web'] = $req['time_web'];
|
|||
|
|
$this->CFG['time_cron'] = $req['time_cron'];
|
|||
|
|
$this->CFG['backup_path'] = $req['backup_path'];
|
|||
|
|
$this->CFG['backup_url'] = $req['backup_url'];
|
|||
|
|
$this->CFG['globstat'] = $req['globstat'] ? 1 : 0;
|
|||
|
|
$this->CFG['charsets'] = $req['charsets'];
|
|||
|
|
$this->CFG['only_create'] = $req['only_create'];
|
|||
|
|
$this->CFG['auth'] = $req['auth'];
|
|||
|
|
$this->CFG['confirm'] = $req['confirm'];
|
|||
|
|
$this->saveCFG();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function saveCFG()
|
|||
|
|
{
|
|||
|
|
if (isset($_COOKIE['sxd'])) {
|
|||
|
|
$this->SES[ $_COOKIE['sxd'] ] = ['cfg' => $this->CFG, 'time' => time(), 'lng' => $this->LNG['name']];
|
|||
|
|
$this->saveToFile('ses.php', "<?php\n\$SES = " . var_export($this->SES, true) . ";\n" . '?>');
|
|||
|
|
}
|
|||
|
|
/*if (!$this->virtualize){
|
|||
|
|
$this->saveToFile('cfg.php', "<?php\n\$CFG = " . var_export($this->CFG, true) . ";\n" . "?>");
|
|||
|
|
}*/
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function runServices($job)
|
|||
|
|
{
|
|||
|
|
$serv = ['optimize' => 'OPTIMIZE', 'analyze' => 'ANALYZE', 'check' => 'CHECK', 'repair' => 'REPAIR'];
|
|||
|
|
$add = ['check' => ['', 'QUICK', 'FAST', 'CHANGED', 'MEDIUM', 'EXTENDED'], 'repair' => ['', 'QUICK', 'EXTENDED']];
|
|||
|
|
if (isset($serv[ $job['type'] ])) {
|
|||
|
|
mysqli_select_db($GLOBALS['mysqlilink'], $job['db']);
|
|||
|
|
$filter = $object = [];
|
|||
|
|
$this->createFilters($job['obj'], $filter, $object);
|
|||
|
|
$r = mysqli_query($GLOBALS['mysqlilink'], 'SHOW TABLE STATUS') or sxd_my_error();
|
|||
|
|
if (!$r) {
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
$tables = [];
|
|||
|
|
while ($item = mysqli_fetch_assoc($r)) {
|
|||
|
|
if (V_MYSQL > 40101 && is_null($item['Engine']) && preg_match('/^VIEW/i', $item['Comment'])) {
|
|||
|
|
continue;
|
|||
|
|
}
|
|||
|
|
if (sxd_check($item['Name'], $object['TA'], $filter['TA'])) {
|
|||
|
|
$tables[] = "`{$item['Name']}`";
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
$sql = $serv[ $job['type'] ] . ' TABLE ' . implode(',', $tables);
|
|||
|
|
|
|||
|
|
if ($job['type'] == 'check' || $job['type'] == 'repair') {
|
|||
|
|
$sql .= isset($add[ $job['type'] ][ $job[ $job['type'] ] ]) ? ' ' . $add[ $job['type'] ][ $job[ $job['type'] ] ] : '';
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
$r = mysqli_query($GLOBALS['mysqlilink'], $sql) or sxd_my_error();
|
|||
|
|
if (!$r) {
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
$res = [];
|
|||
|
|
while ($item = mysqli_fetch_row($r)) {
|
|||
|
|
$res[] = $item;
|
|||
|
|
}
|
|||
|
|
echo 'sxd.result.add(' . sxd_php2json($res) . ');';
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function createFilters(&$obj, &$filter, &$object)
|
|||
|
|
{
|
|||
|
|
$types = ['TA', 'TC', 'VI', 'PR', 'FU', 'TR', 'EV'];
|
|||
|
|
foreach ($types as $type) {
|
|||
|
|
$filter[ $type ] = [];
|
|||
|
|
$object[ $type ] = [];
|
|||
|
|
if (!empty($obj[ $type ])) {
|
|||
|
|
foreach ($obj[ $type ] as $v) {
|
|||
|
|
if (strpos($v, '*') !== false) {
|
|||
|
|
$filter[ $type ][] = str_replace('*', '.*?', $v);
|
|||
|
|
} else {
|
|||
|
|
$object[ $type ][ $v ] = true;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
$filter[ $type ] = count($filter[ $type ]) > 0 ? '/^(' . implode('|', $filter[ $type ]) . ')$/i' : '';
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function closeConnect()
|
|||
|
|
{
|
|||
|
|
//return;
|
|||
|
|
@ignore_user_abort(true);
|
|||
|
|
header("SXD: {$this->name}");
|
|||
|
|
$size = ob_get_length();
|
|||
|
|
//@fastcgi_finish_request();
|
|||
|
|
header("Content-Length: {$size}");
|
|||
|
|
header('Connection: close');
|
|||
|
|
@ob_end_flush();
|
|||
|
|
@flush();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function resumeJob($job)
|
|||
|
|
{
|
|||
|
|
$this->closeConnect();
|
|||
|
|
include $this->CFG['backup_path'] . $job['job'] . '.job.php';
|
|||
|
|
$this->JOB = &$JOB;
|
|||
|
|
if (file_exists($this->JOB['file_stp'])) {
|
|||
|
|
unlink($this->JOB['file_stp']);
|
|||
|
|
}
|
|||
|
|
$this->fh_rtl = fopen($this->JOB['file_rtl'], 'r+b');
|
|||
|
|
$this->fh_log = fopen($this->JOB['file_log'], 'ab');
|
|||
|
|
$t = fgets($this->fh_rtl);
|
|||
|
|
if (!empty($t)) {
|
|||
|
|
$this->rtl = explode("\t", $t);
|
|||
|
|
} else {
|
|||
|
|
$this->addLog($this->LNG['not_found_rtl']);
|
|||
|
|
exit;
|
|||
|
|
}
|
|||
|
|
// TODO: проверить удаление кодировки
|
|||
|
|
//$this->rtl[6] = '';
|
|||
|
|
fseek($this->fh_rtl, 0);
|
|||
|
|
$this->rtl[1] = time();
|
|||
|
|
$this->rtl[9] = 0;
|
|||
|
|
fwrite($this->fh_rtl, implode("\t", $this->rtl));
|
|||
|
|
if ($this->JOB['act'] == 'backup') {
|
|||
|
|
$this->runBackupJob(true);
|
|||
|
|
} elseif ($this->JOB['act'] == 'restore') {
|
|||
|
|
$this->runRestoreJob(true);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function addRestoreJob($job)
|
|||
|
|
{
|
|||
|
|
$this->closeConnect();
|
|||
|
|
$this->JOB = $job;
|
|||
|
|
// Создаем список объектов и фильтр
|
|||
|
|
$filter = $object = [];
|
|||
|
|
$this->createFilters($this->JOB['obj'], $filter, $object);
|
|||
|
|
|
|||
|
|
$objects = $this->getFileObjects('restore', $this->JOB['file'], false);
|
|||
|
|
$todo = [];
|
|||
|
|
$rows = 0;
|
|||
|
|
$this->tab_rows = [];
|
|||
|
|
$todo = [];
|
|||
|
|
foreach ($objects as $t => $list) {
|
|||
|
|
if ($t == 'TA' && (!empty($object['TC']) || !empty($filter['TC']))) {
|
|||
|
|
} elseif (empty($object[ $t ]) && empty($filter[ $t ])) {
|
|||
|
|
continue;
|
|||
|
|
}
|
|||
|
|
if (empty($list)) {
|
|||
|
|
continue;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
foreach ($list as $item) {
|
|||
|
|
switch ($t) {
|
|||
|
|
case 'TA':
|
|||
|
|
$type = '';
|
|||
|
|
if (sxd_check($item[0], $object['TA'], $filter['TA'])) {
|
|||
|
|
$type = empty($item[1]) ? 'TC' : 'TA';
|
|||
|
|
} elseif (sxd_check($item[0], $object['TC'], $filter['TC'])) {
|
|||
|
|
$type = 'TC';
|
|||
|
|
} else {
|
|||
|
|
continue;
|
|||
|
|
}
|
|||
|
|
$todo['TA'][] = [$type, $item[0], $item[1], $item[2]];
|
|||
|
|
$rows += $type == 'TA' ? $item[1] : 0;
|
|||
|
|
break;
|
|||
|
|
default:
|
|||
|
|
if (sxd_check($item, $object[ $t ], $filter[ $t ])) {
|
|||
|
|
$todo[ $t ][] = [$t, $item];
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
$this->JOB['file_tmp'] = $this->JOB['file_name'] = $this->CFG['backup_path'] . $this->JOB['file'];
|
|||
|
|
$this->JOB['file_rtl'] = $this->CFG['backup_path'] . $this->JOB['job'] . '.rtl';
|
|||
|
|
$this->JOB['file_log'] = $this->CFG['backup_path'] . $this->JOB['job'] . '.log';
|
|||
|
|
$this->JOB['file_stp'] = $this->CFG['backup_path'] . $this->JOB['job'] . '.stp';
|
|||
|
|
if (file_exists($this->JOB['file_stp'])) {
|
|||
|
|
unlink($this->JOB['file_stp']);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
$this->fh_tmp = $this->openFile($this->JOB['file_tmp'], 'r');
|
|||
|
|
// Для чужих дампов определяем разделители строк
|
|||
|
|
if (is_null($this->JOB['obj'])) {
|
|||
|
|
$s = fread($this->fh_tmp, 2048);
|
|||
|
|
if (strpos($s, "\r\n")) {
|
|||
|
|
$this->JOB['eol'] = "\r\n";
|
|||
|
|
} elseif (strpos($s, "\n")) {
|
|||
|
|
$this->JOB['eol'] = "\n";
|
|||
|
|
} else {
|
|||
|
|
$this->JOB['eol'] = "\r";
|
|||
|
|
}
|
|||
|
|
$bom = strncmp($s, "\xEF\xBB\xBF", 3) == 0 ? 3 : ((strncmp($s, "\xFE\xFF", 2) == 0 || strncmp($s, "\xFF\xFE", 2) == 0) ? 2 : 0);
|
|||
|
|
fseek($this->fh_tmp, $bom);
|
|||
|
|
}
|
|||
|
|
$this->JOB['todo'] = $todo;
|
|||
|
|
$this->saveJob($this->JOB['job'], $this->JOB);
|
|||
|
|
$this->fh_rtl = fopen($this->JOB['file_rtl'], 'wb');
|
|||
|
|
$this->fh_log = fopen($this->JOB['file_log'], 'wb');
|
|||
|
|
$this->rtl = [time(), time(), $rows, 0, '', '', '', 0, 0, 0, 0, TIMER, "\n"];
|
|||
|
|
$this->addLog(sprintf($this->LNG['restore_begin'], $this->JOB['db']));
|
|||
|
|
$this->addLog("{$this->LNG['combo_file']} {$this->JOB['file']}");
|
|||
|
|
$this->runRestoreJob();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function runRestoreJob($continue = false)
|
|||
|
|
{
|
|||
|
|
$ei = false;
|
|||
|
|
if ($continue) {
|
|||
|
|
$this->fh_tmp = $this->openFile($this->JOB['file_tmp'], 'r');
|
|||
|
|
fseek($this->fh_tmp, $this->rtl[3]);
|
|||
|
|
if (!empty($this->rtl[6])) {
|
|||
|
|
$this->setNames($this->JOB['correct'] == 1 && !empty($this->JOB['charset']) ? $this->JOB['charset'] : $this->rtl[6]);
|
|||
|
|
}
|
|||
|
|
if ($this->rtl[7] < $this->rtl[10]) {
|
|||
|
|
$ei = true;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
mysqli_select_db($GLOBALS['mysqlilink'], $this->JOB['db']);
|
|||
|
|
if (is_null($this->JOB['obj'])) {
|
|||
|
|
$this->runRestoreJobForeign($continue);
|
|||
|
|
}
|
|||
|
|
//mysqli_query($GLOBALS['mysqlilink'], "SET NAMES 'UTF8'");
|
|||
|
|
$types = ['VI' => 'View', 'PR' => 'Procedure', 'FU' => 'Function', 'TR' => 'Trigger', 'EV' => 'Event'];
|
|||
|
|
$fcache = '';
|
|||
|
|
$writes = 0;
|
|||
|
|
$old_charset = '';
|
|||
|
|
$tab = '';
|
|||
|
|
$seek = 0;
|
|||
|
|
$this->rtl[3] = ftell($this->fh_tmp);
|
|||
|
|
fseek($this->fh_rtl, 0);
|
|||
|
|
$this->rtl[1] = time();
|
|||
|
|
fwrite($this->fh_rtl, implode("\t", $this->rtl));
|
|||
|
|
$c = 0;
|
|||
|
|
switch ($this->JOB['strategy']) {
|
|||
|
|
case 1:
|
|||
|
|
$tc = 'TRUNCATE';
|
|||
|
|
$td = 'INSERT';
|
|||
|
|
break;
|
|||
|
|
case 2:
|
|||
|
|
$tc = '';
|
|||
|
|
$td = 'REPLACE';
|
|||
|
|
break;
|
|||
|
|
case 3:
|
|||
|
|
$tc = '';
|
|||
|
|
$td = 'INSERT IGNORE';
|
|||
|
|
break;
|
|||
|
|
default:
|
|||
|
|
$tc = 'DROP TABLE IF EXISTS';
|
|||
|
|
$td = 'INSERT';
|
|||
|
|
}
|
|||
|
|
$tab_exists = [];
|
|||
|
|
if ($this->JOB['strategy'] > 0) {
|
|||
|
|
$r = mysqli_query($GLOBALS['mysqlilink'], 'SHOW TABLES') or sxd_my_error();
|
|||
|
|
while ($item = mysqli_fetch_row($r)) {
|
|||
|
|
$tab_exists[ $item[0] ] = true;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
$insert = $continue && $this->rtl[7] < $this->rtl[10] ? "{$td} INTO `{$this->rtl[5]}` VALUES " : '';
|
|||
|
|
//$enable_index = [];
|
|||
|
|
if (V_MYSQL > 40014) {
|
|||
|
|
mysqli_query($GLOBALS['mysqlilink'], 'SET UNIQUE_CHECKS=0');
|
|||
|
|
mysqli_query($GLOBALS['mysqlilink'], 'SET FOREIGN_KEY_CHECKS=0');
|
|||
|
|
if (V_MYSQL > 40101) {
|
|||
|
|
mysqli_query($GLOBALS['mysqlilink'], "SET SQL_MODE='NO_AUTO_VALUE_ON_ZERO'");
|
|||
|
|
}
|
|||
|
|
if (V_MYSQL > 40111) {
|
|||
|
|
mysqli_query($GLOBALS['mysqlilink'], 'SET SQL_NOTES=0');
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
$log_sql = false;
|
|||
|
|
$fields = '';
|
|||
|
|
$time_old = time();
|
|||
|
|
$exit_time = $time_old + $this->CFG['time_web'] - 1;
|
|||
|
|
while ($q = sxd_read_sql($this->fh_tmp, $seek, $ei)) {
|
|||
|
|
if ($time_old < time()) {
|
|||
|
|
if (file_exists($this->JOB['file_stp'])) {
|
|||
|
|
$type = file_get_contents($this->JOB['file_stp']);
|
|||
|
|
$this->rtl[9] = !empty($type) ? $type : 2;
|
|||
|
|
fseek($this->fh_rtl, 0);
|
|||
|
|
$this->rtl[1] = time();
|
|||
|
|
fwrite($this->fh_rtl, implode("\t", $this->rtl));
|
|||
|
|
//if($type == 1) {}
|
|||
|
|
unset($this->rtl);
|
|||
|
|
exit;
|
|||
|
|
}
|
|||
|
|
$time_old = time();
|
|||
|
|
if ($time_old >= $exit_time) {
|
|||
|
|
$this->rtl[9] = 3;
|
|||
|
|
fseek($this->fh_rtl, 0);
|
|||
|
|
$this->rtl[1] = time();
|
|||
|
|
fwrite($this->fh_rtl, implode("\t", $this->rtl));
|
|||
|
|
unset($this->rtl);
|
|||
|
|
exit;
|
|||
|
|
}
|
|||
|
|
clearstatcache();
|
|||
|
|
}
|
|||
|
|
switch ($q{0}) {
|
|||
|
|
case '(':
|
|||
|
|
if ($continue) {
|
|||
|
|
$this->addLog(sprintf("{$this->LNG['restore_TC']} {$this->LNG['continue_from']}", $this->rtl[5], $this->rtl[3]));
|
|||
|
|
$continue = false;
|
|||
|
|
}
|
|||
|
|
$q = $insert . $q;
|
|||
|
|
$ex = 1;
|
|||
|
|
$c = 1;
|
|||
|
|
break;
|
|||
|
|
case 'I':
|
|||
|
|
if (preg_match('/^INSERT( INTO `(.+?)`) VALUES/', $q, $m)) {
|
|||
|
|
$insert = $td . $m[1] . $fields . " VALUES \n";
|
|||
|
|
$tab = $m[2];
|
|||
|
|
$this->rtl[7] = 0;
|
|||
|
|
$this->rtl[8] = 0;
|
|||
|
|
foreach ($this->JOB['todo']['TA'] as $t) {
|
|||
|
|
if ($t[1] == $tab) {
|
|||
|
|
$this->rtl[8] = $t[2];
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
if ($this->JOB['strategy']) {
|
|||
|
|
$q = substr_replace($q, $insert, 0, strlen($m[0]));
|
|||
|
|
}
|
|||
|
|
//mysqli_query($GLOBALS['mysqlilink'], "LOCK TABLES `{$tab}` WRITE") or die (mysqli_error());
|
|||
|
|
mysqli_query($GLOBALS['mysqlilink'], "ALTER TABLE `{$tab}` DISABLE KEYS") or sxd_my_error();
|
|||
|
|
//if(!empty($this->JOB['autoinc'])) mysqli_query($GLOBALS['mysqlilink'], "ALTER TABLE `{$tab}` AUTO_INCREMENT = 1") or sxd_my_error();
|
|||
|
|
$ex = 1;
|
|||
|
|
}
|
|||
|
|
break;
|
|||
|
|
case 'C':
|
|||
|
|
$ex = 1;
|
|||
|
|
if (preg_match('/^CREATE TABLE `/', $q)) {
|
|||
|
|
if ($this->JOB['strategy'] != 0 && isset($tab_exists[ $this->rtl[5] ])) {
|
|||
|
|
$ex = 0;
|
|||
|
|
} else {
|
|||
|
|
$ex = 1;
|
|||
|
|
if ((!empty($this->JOB['correct']) && !empty($this->JOB['charset']))) {
|
|||
|
|
$q = preg_replace('/(DEFAULT)?\s*(CHARSET|CHARACTER SET|COLLATE)[=\s]+\w+/i', '', $q) . (V_MYSQL < 40100 ? '' : ' DEFAULT CHARSET=' . $this->JOB['charset']);
|
|||
|
|
}
|
|||
|
|
if (!empty($this->JOB['autoinc'])) {
|
|||
|
|
$q = preg_replace("/AUTO_INCREMENT=\d+/", 'AUTO_INCREMENT=1', $q);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
// Достаем имена полей таблицы
|
|||
|
|
$fields = $this->JOB['strategy'] > 0 && preg_match_all('/^\s+(`.+?`) /m', $q, $f, PREG_PATTERN_ORDER) ? '(' . implode(',', $f[1]) . ')' : '';
|
|||
|
|
}
|
|||
|
|
break;
|
|||
|
|
case '#': // Команды для дампера
|
|||
|
|
if (preg_match("/\#\t(TC|TD|VI|PR|FU|TR|EV)`(.+?)`(([^_]+?)_.+?)?$/", $q, $m)) {
|
|||
|
|
//if(!empty($tab)) $enable_index[] = $tab;
|
|||
|
|
//$this->setNames($this->JOB['correct'] == 1 && !empty($this->JOB['charset']) ? $this->JOB['charset'] : empty($m[3]) ? '' : $m[3]);
|
|||
|
|
$this->setNames('binary');
|
|||
|
|
if ($m[1] == 'TC') {
|
|||
|
|
$this->addLog(sprintf($this->LNG['restore_TC'], $m[2]));
|
|||
|
|
$insert = '';
|
|||
|
|
$tab = '';
|
|||
|
|
$this->rtl[4] = 'TD';
|
|||
|
|
$this->rtl[5] = $m[2];
|
|||
|
|
$ei = 0;
|
|||
|
|
if ($tc && ($this->JOB['strategy'] == 0 || isset($tab_exists[ $m[2] ]))) {
|
|||
|
|
mysqli_query($GLOBALS['mysqlilink'], "{$tc} `{$m[2]}`") or sxd_my_error();
|
|||
|
|
}
|
|||
|
|
} elseif ($m[1] == 'TD') {
|
|||
|
|
$ei = 1;
|
|||
|
|
} else {
|
|||
|
|
$this->rtl[4] = $m[1];
|
|||
|
|
$this->rtl[5] = $m[2];
|
|||
|
|
$this->rtl[7] = 0;
|
|||
|
|
$this->rtl[8] = 0;
|
|||
|
|
mysqli_query($GLOBALS['mysqlilink'], "DROP {$types[$m[1]]} IF EXISTS `{$m[2]}`") or sxd_my_error();
|
|||
|
|
$this->addLog(sprintf($this->LNG["restore_{$m[1]}"], $m[2]));
|
|||
|
|
$ei = 0;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
$ex = 0;
|
|||
|
|
break;
|
|||
|
|
default:
|
|||
|
|
$insert = '';
|
|||
|
|
$ex = 1;
|
|||
|
|
}
|
|||
|
|
if ($ex) {
|
|||
|
|
$this->rtl[3] = ftell($this->fh_tmp) - $seek;
|
|||
|
|
fseek($this->fh_rtl, 0);
|
|||
|
|
$this->rtl[1] = time();
|
|||
|
|
fwrite($this->fh_rtl, implode("\t", $this->rtl));
|
|||
|
|
if (mysqli_query($GLOBALS['mysqlilink'], $q)) {
|
|||
|
|
if ($insert) {
|
|||
|
|
$c = 1;
|
|||
|
|
}
|
|||
|
|
} else {
|
|||
|
|
error_log(date('r') . "\n----------\n{$q}\n", 3, 'backup/sql_error.log');
|
|||
|
|
sxd_my_error();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if ($c) {
|
|||
|
|
$i = mysqli_affected_rows($GLOBALS['mysqlilink']);
|
|||
|
|
$this->rtl[3] = ftell($this->fh_tmp) - $seek;
|
|||
|
|
$this->rtl[7] += $i;
|
|||
|
|
$this->rtl[10] += $i;
|
|||
|
|
fseek($this->fh_rtl, 0);
|
|||
|
|
$this->rtl[1] = time();
|
|||
|
|
fwrite($this->fh_rtl, implode("\t", $this->rtl));
|
|||
|
|
$c = 1;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
// Включаем ключи
|
|||
|
|
$this->addLog($this->LNG['restore_keys']);
|
|||
|
|
$this->rtl[4] = 'EK';
|
|||
|
|
$this->rtl[5] = '';
|
|||
|
|
$this->rtl[6] = '';
|
|||
|
|
$this->rtl[7] = 0;
|
|||
|
|
$this->rtl[8] = 0;
|
|||
|
|
foreach ($this->JOB['todo']['TA'] as $tab) {
|
|||
|
|
if ($tab[0] == 'TC') {
|
|||
|
|
continue;
|
|||
|
|
}
|
|||
|
|
mysqli_query($GLOBALS['mysqlilink'], "ALTER TABLE `{$tab[1]}` ENABLE KEYS") or sxd_my_error();
|
|||
|
|
$this->rtl[1] = time();
|
|||
|
|
$this->rtl[5] = $tab[1];
|
|||
|
|
fseek($this->fh_rtl, 0);
|
|||
|
|
fwrite($this->fh_rtl, implode("\t", $this->rtl));
|
|||
|
|
}
|
|||
|
|
$this->rtl[4] = 'EOJ';
|
|||
|
|
$this->rtl[5] = round(array_sum(explode(' ', microtime())) - $this->rtl[11], 4);
|
|||
|
|
|
|||
|
|
fseek($this->fh_rtl, 0);
|
|||
|
|
fwrite($this->fh_rtl, implode("\t", $this->rtl));
|
|||
|
|
$this->addLog(sprintf($this->LNG['restore_end'], $this->JOB['db']));
|
|||
|
|
fclose($this->fh_log);
|
|||
|
|
fclose($this->fh_rtl);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function runRestoreJobForeign($continue = false)
|
|||
|
|
{
|
|||
|
|
$ei = false;
|
|||
|
|
|
|||
|
|
$fcache = '';
|
|||
|
|
$writes = 0;
|
|||
|
|
$old_charset = '';
|
|||
|
|
$tab = '';
|
|||
|
|
$seek = 0;
|
|||
|
|
$this->rtl[3] = ftell($this->fh_tmp);
|
|||
|
|
fseek($this->fh_rtl, 0);
|
|||
|
|
$this->rtl[1] = time();
|
|||
|
|
fwrite($this->fh_rtl, implode("\t", $this->rtl));
|
|||
|
|
$c = 0;
|
|||
|
|
|
|||
|
|
$log_sql = false;
|
|||
|
|
$fields = '';
|
|||
|
|
$insert = '';
|
|||
|
|
$last_tab = '';
|
|||
|
|
$time_old = time();
|
|||
|
|
$exit_time = $time_old + $this->CFG['time_web'] - 1;
|
|||
|
|
$delimiter = ';';
|
|||
|
|
while ($q = sxd_read_sql($this->fh_tmp, $seek, $ei, $delimiter, $this->JOB['eol'])) {
|
|||
|
|
$q = ltrim($q);
|
|||
|
|
if (empty($q)) {
|
|||
|
|
break;
|
|||
|
|
}
|
|||
|
|
if ($time_old < time()) {
|
|||
|
|
if (file_exists($this->JOB['file_stp'])) {
|
|||
|
|
$type = file_get_contents($this->JOB['file_stp']);
|
|||
|
|
$this->rtl[9] = !empty($type) ? $type : 2;
|
|||
|
|
fseek($this->fh_rtl, 0);
|
|||
|
|
$this->rtl[1] = time();
|
|||
|
|
fwrite($this->fh_rtl, implode("\t", $this->rtl));
|
|||
|
|
//if($type == 1) {}
|
|||
|
|
unset($this->rtl);
|
|||
|
|
exit;
|
|||
|
|
}
|
|||
|
|
$time_old = time();
|
|||
|
|
if ($time_old >= $exit_time) {
|
|||
|
|
$this->rtl[9] = 3;
|
|||
|
|
fseek($this->fh_rtl, 0);
|
|||
|
|
$this->rtl[1] = time();
|
|||
|
|
fwrite($this->fh_rtl, implode("\t", $this->rtl));
|
|||
|
|
unset($this->rtl);
|
|||
|
|
exit;
|
|||
|
|
}
|
|||
|
|
clearstatcache();
|
|||
|
|
}
|
|||
|
|
do {
|
|||
|
|
$repeat = false;
|
|||
|
|
//error_log("-----------------\n[{$q}]\n", 3, "q.log");
|
|||
|
|
//if(empty($q)) {continue 2;}
|
|||
|
|
switch ($q{0}) {
|
|||
|
|
case '(':
|
|||
|
|
if ($continue) {
|
|||
|
|
$this->addLog(sprintf("{$this->LNG['restore_TC']} {$this->LNG['continue_from']}", $this->rtl[5], $this->rtl[3]));
|
|||
|
|
$continue = false;
|
|||
|
|
}
|
|||
|
|
$q = $insert . $q;
|
|||
|
|
$ex = 1;
|
|||
|
|
$c = 1;
|
|||
|
|
break;
|
|||
|
|
case 'I':
|
|||
|
|
|
|||
|
|
if (preg_match('/^(INSERT( INTO `?(.+?)`?).+?\sVALUES)/s', $q, $m)) {
|
|||
|
|
$insert = trim($m[1]) . ' ';
|
|||
|
|
$tab = $m[3];
|
|||
|
|
$this->rtl[7] = 0;
|
|||
|
|
$this->rtl[8] = 0;
|
|||
|
|
$ex = 1;
|
|||
|
|
}
|
|||
|
|
break;
|
|||
|
|
case 'C':
|
|||
|
|
$ex = 1;
|
|||
|
|
$ei = 1;
|
|||
|
|
if (preg_match('/^CREATE TABLE.+?`(.+?)`/', $q, $m)) {
|
|||
|
|
$ex = 1;
|
|||
|
|
$tab = $m[1];
|
|||
|
|
$this->addLog(sprintf($this->LNG['restore_TC'], $tab));
|
|||
|
|
//mysqli_query($GLOBALS['mysqlilink'], "DROP TABLE IF EXISTS `{$tab}`");
|
|||
|
|
if ((!empty($this->JOB['correct']) && !empty($this->JOB['charset']))) {
|
|||
|
|
$q = preg_replace('/(DEFAULT)?\s*(CHARSET|CHARACTER SET|COLLATE)[=\s]+\w+/i', '', $q) . (V_MYSQL < 40100 ? '' : ' DEFAULT CHARSET=' . $this->JOB['charset']);
|
|||
|
|
} elseif (empty($this->JOB['charset'])) {
|
|||
|
|
if (preg_match("/(CHARACTER SET|CHARSET)[=\s]+(\w+)/i", $q, $charset)) {
|
|||
|
|
$this->setNames($charset[2]);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
break;
|
|||
|
|
case '-' && $q{1} == '-':
|
|||
|
|
case '#':
|
|||
|
|
$repeat = true;
|
|||
|
|
$q = ltrim(substr($q, strpos($q, $this->JOB['eol'])));
|
|||
|
|
$ex = 0;
|
|||
|
|
break;
|
|||
|
|
case '/':
|
|||
|
|
case 'S':
|
|||
|
|
if (preg_match('/SET NAMES (\w+)/', $q, $m)) {
|
|||
|
|
$this->JOB['charset'] = $m[1];
|
|||
|
|
$this->setNames($this->JOB['charset']);
|
|||
|
|
$ex = 0;
|
|||
|
|
} else {
|
|||
|
|
$ex = 1;
|
|||
|
|
}
|
|||
|
|
break;
|
|||
|
|
default:
|
|||
|
|
$insert = '';
|
|||
|
|
$ex = 1;
|
|||
|
|
$ei = 0;
|
|||
|
|
}
|
|||
|
|
} while ($repeat);
|
|||
|
|
if ($ex) {
|
|||
|
|
$this->rtl[3] = ftell($this->fh_tmp) - $seek;
|
|||
|
|
fseek($this->fh_rtl, 0);
|
|||
|
|
$this->rtl[1] = time();
|
|||
|
|
fwrite($this->fh_rtl, implode("\t", $this->rtl));
|
|||
|
|
error_log("-----------------\n{$q}\n", 3, 'sql.log');
|
|||
|
|
if (mysqli_query($GLOBALS['mysqlilink'], $q)) {
|
|||
|
|
if ($insert) {
|
|||
|
|
$c = 1;
|
|||
|
|
}
|
|||
|
|
} else {
|
|||
|
|
error_log("-----------------\n{$q}\n", 3, 'error.log');
|
|||
|
|
sxd_my_error();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if ($c) {
|
|||
|
|
$i = mysqli_affected_rows($GLOBALS['mysqlilink']);
|
|||
|
|
$this->rtl[3] = ftell($this->fh_tmp) - $seek;
|
|||
|
|
$this->rtl[7] += $i;
|
|||
|
|
$this->rtl[10] += $i;
|
|||
|
|
fseek($this->fh_rtl, 0);
|
|||
|
|
$this->rtl[1] = time();
|
|||
|
|
fwrite($this->fh_rtl, implode("\t", $this->rtl));
|
|||
|
|
$c = 1;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
$this->rtl[4] = 'EOJ';
|
|||
|
|
$this->rtl[5] = round(array_sum(explode(' ', microtime())) - $this->rtl[11], 4);
|
|||
|
|
$this->rtl[7] = 0;
|
|||
|
|
$this->rtl[8] = 0;
|
|||
|
|
|
|||
|
|
fseek($this->fh_rtl, 0);
|
|||
|
|
fwrite($this->fh_rtl, implode("\t", $this->rtl));
|
|||
|
|
$this->addLog(sprintf($this->LNG['restore_end'], $this->JOB['db']));
|
|||
|
|
fclose($this->fh_log);
|
|||
|
|
fclose($this->fh_rtl);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function addBackupJob($job)
|
|||
|
|
{
|
|||
|
|
$this->closeConnect();
|
|||
|
|
// Создаем новое задание
|
|||
|
|
$this->JOB = $job;
|
|||
|
|
mysqli_select_db($GLOBALS['mysqlilink'], $this->JOB['db']);
|
|||
|
|
// Создаем список объектов и фильтр
|
|||
|
|
$filter = $object = [];
|
|||
|
|
$this->createFilters($this->JOB['obj'], $filter, $object);
|
|||
|
|
$queries = [
|
|||
|
|
['TABLE STATUS', 'Name', 'TA'],
|
|||
|
|
];
|
|||
|
|
if (V_MYSQL > 50014) {
|
|||
|
|
$queries[] = ["PROCEDURE STATUS WHERE db='{$this->JOB['db']}'", 'Name', 'PR'];
|
|||
|
|
$queries[] = ["FUNCTION STATUS WHERE db='{$this->JOB['db']}'", 'Name', 'FU'];
|
|||
|
|
$queries[] = ['TRIGGERS', 'Trigger', 'TR'];
|
|||
|
|
if (V_MYSQL > 50100) {
|
|||
|
|
$queries[] = ['EVENTS', 'Name', 'EV'];
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
$todo = $header = [];
|
|||
|
|
$tabs = $rows = 0;
|
|||
|
|
$only_create = explode(' ', $this->CFG['only_create']);
|
|||
|
|
foreach ($queries as $query) {
|
|||
|
|
$t = $query[2];
|
|||
|
|
if ($t == 'TA' && (!empty($object['TC']) || !empty($filter['TC']))) {
|
|||
|
|
} elseif (empty($object[ $t ]) && empty($filter[ $t ])) {
|
|||
|
|
continue;
|
|||
|
|
}
|
|||
|
|
$r = mysqli_query($GLOBALS['mysqlilink'], 'SHOW ' . $query[0]) or sxd_my_error();
|
|||
|
|
if (!$r) {
|
|||
|
|
continue;
|
|||
|
|
}
|
|||
|
|
$todo[ $t ] = [];
|
|||
|
|
$header[ $t ] = [];
|
|||
|
|
|
|||
|
|
while ($item = mysqli_fetch_assoc($r)) {
|
|||
|
|
$n = $item[ $query[1] ];
|
|||
|
|
switch ($t) {
|
|||
|
|
case 'TA':
|
|||
|
|
case 'TC':
|
|||
|
|
if (V_MYSQL > 40101 && is_null($item['Engine']) && preg_match('/^VIEW/i', $item['Comment'])) {
|
|||
|
|
if (sxd_check($n, $object['VI'], $filter['VI'])) {
|
|||
|
|
$todo['VI'] = [];
|
|||
|
|
$header['VI'] = [];
|
|||
|
|
}
|
|||
|
|
continue;
|
|||
|
|
} elseif (sxd_check($n, $object['TA'], $filter['TA'])) {
|
|||
|
|
$engine = V_MYSQL > 40101 ? $item['Engine'] : $item['Type'];
|
|||
|
|
$t = in_array($engine, $only_create) ? 'TC' : 'TA';
|
|||
|
|
} elseif (sxd_check($n, $object['TC'], $filter['TC'])) {
|
|||
|
|
$t = 'TC';
|
|||
|
|
$item['Rows'] = $item['Data_length'] = '';
|
|||
|
|
} else {
|
|||
|
|
continue;
|
|||
|
|
}
|
|||
|
|
$todo['TA'][] = [$t, $n, !empty($item['Collation']) ? $item['Collation'] : '', $item['Auto_increment'], $item['Rows'], $item['Data_length']];
|
|||
|
|
$header['TA'][] = "{$n}`{$item['Rows']}`{$item['Data_length']}";
|
|||
|
|
++$tabs;
|
|||
|
|
$rows += $item['Rows'];
|
|||
|
|
break;
|
|||
|
|
default:
|
|||
|
|
if (sxd_check($n, $object[ $t ], $filter[ $t ])) {
|
|||
|
|
$todo[ $t ][] = [$t, $n, !empty($item['collation_connection']) ? $item['collation_connection'] : ''];
|
|||
|
|
$header[ $t ][] = $n;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
if (V_MYSQL > 50014 && (!empty($object['VI']) || !empty($filter['VI']))) {
|
|||
|
|
// Бэкап обзоров, нужно отсортировать зависимые
|
|||
|
|
$r = mysqli_query($GLOBALS['mysqlilink'], "SELECT table_name, view_definition /*!50121 , collation_connection */ FROM INFORMATION_SCHEMA.VIEWS WHERE TABLE_SCHEMA = '{$this->JOB['db']}'") or sxd_my_error();
|
|||
|
|
$views = $dumped = $views_collation = [];
|
|||
|
|
$re = "/`{$this->JOB['db']}`.`(.+?)`/";
|
|||
|
|
while ($item = mysqli_fetch_assoc($r)) {
|
|||
|
|
preg_match_all($re, preg_replace('/^select.+? from/i', '', $item['view_definition']), $m);
|
|||
|
|
$used = $m[1];
|
|||
|
|
$views_collation[ $item['table_name'] ] = !empty($item['collation_connection']) ? $item['collation_connection'] : '';
|
|||
|
|
$views[ $item['table_name'] ] = $used;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
while (count($views) > 0) {
|
|||
|
|
foreach ($views as $n => $view) {
|
|||
|
|
$can_dumped = true;
|
|||
|
|
foreach ($view as $k) {
|
|||
|
|
if (isset($views[ $k ]) && !isset($dumped[ $k ])) {
|
|||
|
|
$can_dumped = false;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
if ($can_dumped) {
|
|||
|
|
if (sxd_check($n, $object['VI'], $filter['VI'])) {
|
|||
|
|
$todo['VI'][] = ['VI', $n, $views_collation[ $n ]];
|
|||
|
|
$header['VI'][] = $n;
|
|||
|
|
}
|
|||
|
|
$dumped[ $n ] = 1;
|
|||
|
|
unset($views[ $n ]);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
unset($dumped);
|
|||
|
|
unset($views);
|
|||
|
|
unset($views_collation);
|
|||
|
|
}
|
|||
|
|
$this->JOB['file_tmp'] = $this->CFG['backup_path'] . $this->JOB['job'] . '.tmp';
|
|||
|
|
$this->JOB['file_rtl'] = $this->CFG['backup_path'] . $this->JOB['job'] . '.rtl';
|
|||
|
|
$this->JOB['file_log'] = $this->CFG['backup_path'] . $this->JOB['job'] . '.log';
|
|||
|
|
$this->JOB['file_stp'] = $this->CFG['backup_path'] . $this->JOB['job'] . '.stp';
|
|||
|
|
if (file_exists($this->JOB['file_stp'])) {
|
|||
|
|
unlink($this->JOB['file_stp']);
|
|||
|
|
}
|
|||
|
|
$this->fh_tmp = $this->openFile($this->JOB['file_tmp'], 'w');
|
|||
|
|
$this->JOB['file'] = sprintf('%s_%s.%s', (isset($this->JOB['title']) ? $this->JOB['job'] : $this->JOB['db']), date('Y-m-d_H-i-s'), $this->JOB['file_ext']);
|
|||
|
|
$this->JOB['file_name'] = $this->CFG['backup_path'] . $this->JOB['file'];
|
|||
|
|
$this->JOB['todo'] = $todo;
|
|||
|
|
$this->saveJob($this->JOB['job'], $this->JOB);
|
|||
|
|
$fcache = implode('|', ['#SXD20', V_SXD, V_MYSQL, V_PHP, date('Y.m.d H:i:s'), $this->JOB['db'], $this->JOB['charset'], $tabs, $rows, sxd_esc($this->JOB['comment'], false)]) . "\n";
|
|||
|
|
foreach ($header as $t => $o) {
|
|||
|
|
if (!empty($o)) {
|
|||
|
|
$fcache .= "#{$t} " . implode('|', $o) . "\n";
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
$this->fh_rtl = fopen($this->JOB['file_rtl'], 'wb');
|
|||
|
|
$this->fh_log = fopen($this->JOB['file_log'], 'wb');
|
|||
|
|
$this->rtl = [time(), time(), $rows, 0, '', '', '', 0, 0, 0, 0, TIMER, "\n"];
|
|||
|
|
$fcache .= "#EOH\n\n";
|
|||
|
|
$this->write($fcache);
|
|||
|
|
$this->addLog(sprintf($this->LNG['backup_begin'], $this->JOB['db']));
|
|||
|
|
$this->runBackupJob();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function runBackupJob($continue = false)
|
|||
|
|
{
|
|||
|
|
if ($continue) {
|
|||
|
|
$this->fh_tmp = $this->openFile($this->JOB['file_tmp'], 'a');
|
|||
|
|
mysqli_select_db($GLOBALS['mysqlilink'], $this->JOB['db']);
|
|||
|
|
}
|
|||
|
|
mysqli_query($GLOBALS['mysqlilink'], 'SET SQL_QUOTE_SHOW_CREATE = 1');
|
|||
|
|
$types = ['VI' => 'View', 'PR' => 'Procedure', 'FU' => 'Function', 'TR' => 'Trigger', 'EV' => 'Event'];
|
|||
|
|
$fcache = '';
|
|||
|
|
$writes = 0;
|
|||
|
|
|
|||
|
|
if (V_MYSQL > 40101) {
|
|||
|
|
mysqli_query($GLOBALS['mysqlilink'], "SET SESSION character_set_results = '" . ($this->JOB['charset'] ? $this->JOB['charset'] : 'binary') . "'") or sxd_my_error();
|
|||
|
|
}
|
|||
|
|
$time_old = time();
|
|||
|
|
$exit_time = $time_old + $this->CFG['time_web'] - 1;
|
|||
|
|
$no_cache = V_MYSQL < 40101 ? 'SQL_NO_CACHE ' : '';
|
|||
|
|
foreach ($this->JOB['todo'] as $t => $o) {
|
|||
|
|
if (empty($this->rtl[4])) {
|
|||
|
|
$this->rtl[4] = $t;
|
|||
|
|
} elseif ($this->rtl[4] != $t) {
|
|||
|
|
continue;
|
|||
|
|
}
|
|||
|
|
foreach ($o as $n) {
|
|||
|
|
if (empty($this->rtl[5])) {
|
|||
|
|
$this->rtl[5] = $n[1];
|
|||
|
|
$this->rtl[7] = 0;
|
|||
|
|
$this->rtl[8] = !empty($n[4]) ? $n[4] : 0;
|
|||
|
|
} elseif ($this->rtl[5] != $n[1]) {
|
|||
|
|
continue;
|
|||
|
|
}
|
|||
|
|
// Делаем бэкап
|
|||
|
|
switch ($n[0]) {
|
|||
|
|
case 'TC':
|
|||
|
|
case 'TD':
|
|||
|
|
case 'TA':
|
|||
|
|
$from = '';
|
|||
|
|
if ($n[0] == 'TC' || $this->rtl[7] == 0) {
|
|||
|
|
// Бэкап структуры таблицы
|
|||
|
|
$r = mysqli_query($GLOBALS['mysqlilink'], "SHOW CREATE TABLE `{$n[1]}`") or sxd_my_error();
|
|||
|
|
$item = mysqli_fetch_assoc($r);
|
|||
|
|
$fcache .= "#\tTC`{$n[1]}`{$n[2]}\t;\n{$item['Create Table']}\t;\n";
|
|||
|
|
$this->addLog(sprintf($this->LNG['backup_TC'], $n[1]));
|
|||
|
|
$this->rtl[7] = 0;
|
|||
|
|
if ($n[0] == 'TC' || !$n[4]) {
|
|||
|
|
break;
|
|||
|
|
}
|
|||
|
|
// Бэкапим данные таблицы
|
|||
|
|
$fcache .= "#\tTD`{$n[1]}`{$n[2]}\t;\nINSERT INTO `{$n[1]}` VALUES \n";
|
|||
|
|
} else {
|
|||
|
|
$from = " LIMIT {$this->rtl[7]}, {$this->rtl[8]}";
|
|||
|
|
$this->addLog(sprintf("{$this->LNG['backup_TC']} {$this->LNG['continue_from']}", $n[1], $this->rtl[7]));
|
|||
|
|
}
|
|||
|
|
// Определяем типы полей
|
|||
|
|
$notNum = [];
|
|||
|
|
$r = mysqli_query($GLOBALS['mysqlilink'], "SHOW COLUMNS FROM `{$n[1]}`") or sxd_my_error();
|
|||
|
|
$fields = 0;
|
|||
|
|
while ($col = mysqli_fetch_array($r)) {
|
|||
|
|
// TODO: проверить типы SET, ENUM и BIT
|
|||
|
|
$notNum[ $fields ] = preg_match('/^(tinyint|smallint|mediumint|bigint|int|float|double|real|decimal|numeric|year)/', $col['Type']) ? 0 : 1;
|
|||
|
|
++$fields;
|
|||
|
|
}
|
|||
|
|
$time_old = time();
|
|||
|
|
$z = 0;
|
|||
|
|
// Достаем данные
|
|||
|
|
$r = mysqli_query($GLOBALS['mysqlilink'], "SELECT {$no_cache}* FROM `{$n[1]}`{$from}", MYSQLI_USE_RESULT);
|
|||
|
|
while ($row = mysqli_fetch_row($r)) {
|
|||
|
|
if (strlen($fcache) >= 61440) {
|
|||
|
|
$z = 0;
|
|||
|
|
if ($time_old < time()) {
|
|||
|
|
if (file_exists($this->JOB['file_stp'])) {
|
|||
|
|
$type = file_get_contents($this->JOB['file_stp']);
|
|||
|
|
$this->rtl[9] = !empty($type) ? $type : 2;
|
|||
|
|
$this->write($fcache);
|
|||
|
|
if ($type == 1) {
|
|||
|
|
}
|
|||
|
|
unset($this->rtl);
|
|||
|
|
exit;
|
|||
|
|
}
|
|||
|
|
$time_old = time();
|
|||
|
|
if ($time_old >= $exit_time) {
|
|||
|
|
$this->rtl[9] = 3;
|
|||
|
|
$this->write($fcache);
|
|||
|
|
unset($this->rtl);
|
|||
|
|
exit;
|
|||
|
|
}
|
|||
|
|
clearstatcache();
|
|||
|
|
}
|
|||
|
|
$this->write($fcache);
|
|||
|
|
}
|
|||
|
|
for ($k = 0; $k < $fields; ++$k) {
|
|||
|
|
if (!isset($row[ $k ])) {
|
|||
|
|
$row[ $k ] = '\N';
|
|||
|
|
} elseif ($notNum[ $k ]) {
|
|||
|
|
$row[ $k ] = '\'' . mysqli_real_escape_string($GLOBALS['mysqlilink'], $row[ $k ]) . '\'';
|
|||
|
|
} // TODO: Потестить скорость эскэйпинга строк
|
|||
|
|
}
|
|||
|
|
$fcache .= '(' . implode(',', $row) . "),\n";
|
|||
|
|
++$this->rtl[7];
|
|||
|
|
++$this->rtl[10];
|
|||
|
|
}
|
|||
|
|
unset($row);
|
|||
|
|
mysqli_free_result($r);
|
|||
|
|
$fcache = substr_replace($fcache, "\t;\n", -2, 2);
|
|||
|
|
break;
|
|||
|
|
|
|||
|
|
default:
|
|||
|
|
if (V_MYSQL < 50121 && $n[0] == 'TR') {
|
|||
|
|
// SHOW CREATE TRIGGER отсутствует до MySQL 5.1.21
|
|||
|
|
$r = mysqli_query($GLOBALS['mysqlilink'], "SELECT * FROM `INFORMATION_SCHEMA`.`TRIGGERS` WHERE `TRIGGER_SCHEMA` = '{$this->JOB['db']}' AND `TRIGGER_NAME` = '{$n[1]}'") or sxd_my_error();
|
|||
|
|
$item = mysqli_fetch_assoc($r);
|
|||
|
|
$fcache .= "#\tTR`{$n[1]}`{$n[2]}\t;\nCREATE TRIGGER `{$item['TRIGGER_NAME']}` {$item['ACTION_TIMING']} {$item['EVENT_MANIPULATION']} ON `{$item['EVENT_OBJECT_TABLE']}` FOR EACH ROW {$item['ACTION_STATEMENT']}\t;\n";
|
|||
|
|
} else {
|
|||
|
|
$this->addLog(sprintf($this->LNG[ 'backup_' . $n[0] ], $n[1]));
|
|||
|
|
$r = mysqli_query($GLOBALS['mysqlilink'], "SHOW CREATE {$types[$n[0]]} `{$n[1]}`") or sxd_my_error();
|
|||
|
|
$item = mysqli_fetch_assoc($r);
|
|||
|
|
$fcache .= "#\t{$n[0]}`{$n[1]}`{$n[2]}\t;\n" . preg_replace('/DEFINER=`.+?`@`.+?` /', '', ($n[0] == 'TR' ? $item['SQL Original Statement'] : $item[ 'Create ' . $types[ $n[0] ] ])) . "\t;\n";
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
$this->rtl[5] = '';
|
|||
|
|
}
|
|||
|
|
$this->rtl[4] = '';
|
|||
|
|
}
|
|||
|
|
$this->rtl[4] = 'EOJ';
|
|||
|
|
$this->rtl[5] = round(array_sum(explode(' ', microtime())) - $this->rtl[11], 4);
|
|||
|
|
$this->rtl[6] = '';
|
|||
|
|
$this->rtl[7] = 0;
|
|||
|
|
$this->rtl[8] = 0;
|
|||
|
|
$this->write($fcache);
|
|||
|
|
fclose($this->fh_tmp);
|
|||
|
|
rename($this->JOB['file_tmp'], $this->JOB['file_name']);
|
|||
|
|
$this->addLog(sprintf($this->LNG['backup_end'], $this->JOB['db']));
|
|||
|
|
if (file_exists('sxd2ftp.php')) {
|
|||
|
|
include 'sxd2ftp.php';
|
|||
|
|
}
|
|||
|
|
if ($this->JOB['del_time'] || $this->JOB['del_count']) {
|
|||
|
|
$this->addLog($this->LNG['autodelete']);
|
|||
|
|
$deldate = '';
|
|||
|
|
if (!empty($this->JOB['del_time'])) { // Удаление по дням
|
|||
|
|
$deldate = date('Y-m-d_H-i-s', time() - intval($this->JOB['del_time']) * 86400);
|
|||
|
|
}
|
|||
|
|
$deleted = false;
|
|||
|
|
if ($dh = opendir($this->CFG['backup_path'])) {
|
|||
|
|
$files = [];
|
|||
|
|
$name = isset($this->JOB['title']) ? $this->JOB['job'] : $this->JOB['db'];
|
|||
|
|
while (false !== ($file = readdir($dh))) {
|
|||
|
|
if (preg_match("/^{$name}_(\d{4}-\d{2}-\d{2}_\d{2}-\d{2}-\d{2})\.sql/", $file, $m)) {
|
|||
|
|
if ($deldate && $m[1] < $deldate) {
|
|||
|
|
if (unlink($this->CFG['backup_path'] . $file)) {
|
|||
|
|
$this->addLog(sprintf($this->LNG['del_by_date'], $file));
|
|||
|
|
} else {
|
|||
|
|
$this->addLog(sprintf($this->LNG['del_fail'], $file));
|
|||
|
|
}
|
|||
|
|
$deleted = true;
|
|||
|
|
} else {
|
|||
|
|
$files[ $m[1] ] = $file;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
closedir($dh);
|
|||
|
|
// Сортируем файлы по дате и удаляем самые старые
|
|||
|
|
if (!empty($this->JOB['del_count'])) {
|
|||
|
|
ksort($files);
|
|||
|
|
$file_to_delete = count($files) - $this->JOB['del_count'];
|
|||
|
|
foreach ($files as $file) {
|
|||
|
|
if ($file_to_delete-- > 0) {
|
|||
|
|
if (unlink($this->CFG['backup_path'] . $file)) {
|
|||
|
|
$this->addLog(sprintf($this->LNG['del_by_count'], $file));
|
|||
|
|
} else {
|
|||
|
|
$this->addLog(sprintf($this->LNG['del_fail'], $file));
|
|||
|
|
}
|
|||
|
|
$deleted = true;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
if (!$deleted) {
|
|||
|
|
$this->addLog($this->LNG['del_nothing']);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
fclose($this->fh_log);
|
|||
|
|
fclose($this->fh_rtl);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function setNames($collation)
|
|||
|
|
{
|
|||
|
|
if (empty($collation)) {
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
if ($this->rtl[6] != $collation) {
|
|||
|
|
mysqli_query($GLOBALS['mysqlilink'], 'SET NAMES \'' . preg_replace('/^(\w+?)_/', '\\1\' COLLATE \'\\1_', $collation) . '\'') or sxd_my_error();
|
|||
|
|
/*if(!$this->rtl[7])*/
|
|||
|
|
$this->addLog(sprintf($this->LNG['set_names'], $collation));
|
|||
|
|
$this->rtl[6] = $collation;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function write(&$str)
|
|||
|
|
{
|
|||
|
|
fseek($this->fh_rtl, 0);
|
|||
|
|
$this->rtl[1] = time();
|
|||
|
|
$this->rtl[3] += fwrite($this->fh_tmp, $str);
|
|||
|
|
fwrite($this->fh_rtl, implode("\t", $this->rtl));
|
|||
|
|
$str = '';
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function addLog($str, $type = 1)
|
|||
|
|
{
|
|||
|
|
fwrite($this->fh_log, date('Y.m.d H:i:s') . "\t{$type}\t{$str}\n");
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function getDBList()
|
|||
|
|
{
|
|||
|
|
$dbs = $items = [];
|
|||
|
|
if (!V_MYSQL) {
|
|||
|
|
return $dbs;
|
|||
|
|
}
|
|||
|
|
$qq = (V_MYSQL < 50000) ? '' : '\'';
|
|||
|
|
if ($this->CFG['my_db']) {
|
|||
|
|
$tmp = explode(',', $this->CFG['my_db']);
|
|||
|
|
foreach ($tmp as $d) {
|
|||
|
|
$d = trim($d);
|
|||
|
|
$items[] = $qq . sxd_esc($d, false) . $qq;
|
|||
|
|
$dbs[ $d ] = "{$d} (0)";
|
|||
|
|
}
|
|||
|
|
} else {
|
|||
|
|
$result = mysqli_query($GLOBALS['mysqlilink'], 'SHOW DATABASES') or sxd_my_error();
|
|||
|
|
while ($item = mysqli_fetch_row($result)) {
|
|||
|
|
if ($item[0] == 'information_schema' || $item[0] == 'mysql' || $item[0] == 'performance_schema') {
|
|||
|
|
continue;
|
|||
|
|
}
|
|||
|
|
$items[] = $qq . sxd_esc($item[0], false) . $qq;
|
|||
|
|
$dbs[ $item[0] ] = "{$item[0]} (0)";
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
if (V_MYSQL < 50000) {
|
|||
|
|
foreach ($items as $item) {
|
|||
|
|
$tables = mysqli_query($GLOBALS['mysqlilink'], "SHOW TABLES FROM `{$item}`") or sxd_my_error();
|
|||
|
|
if ($tables) {
|
|||
|
|
$tabs = mysqli_num_rows($tables);
|
|||
|
|
$dbs[ $item ] = "{$item} ({$tabs})";
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
} else {
|
|||
|
|
$where = (count($items) > 0) ? 'WHERE `table_schema` IN (' . implode(',', $items) . ')' : '';
|
|||
|
|
$result = mysqli_query($GLOBALS['mysqlilink'], "SELECT `table_schema`, COUNT(*) FROM `information_schema`.`tables` {$where} GROUP BY `table_schema`") or sxd_my_error();
|
|||
|
|
while ($item = mysqli_fetch_row($result)) {
|
|||
|
|
if ($item[0] == 'information_schema' || $item[0] == 'mysql' || $item[0] == 'performance_schema') {
|
|||
|
|
continue;
|
|||
|
|
}
|
|||
|
|
$dbs[ $item[0] ] = "{$item[0]} ({$item[1]})";
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return $dbs;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function getCharsetList()
|
|||
|
|
{
|
|||
|
|
$tmp = [0 => '- auto -'];
|
|||
|
|
if (!V_MYSQL) {
|
|||
|
|
return $tmp;
|
|||
|
|
}
|
|||
|
|
if (V_MYSQL > 40101) {
|
|||
|
|
$def_charsets = '';
|
|||
|
|
if (!empty($this->CFG['charsets'])) {
|
|||
|
|
$def_charsets = preg_match_all("/([\w*?]+)\s*/", $this->CFG['charsets'], $m, PREG_PATTERN_ORDER) ? '/^(' . str_replace(['?', '*'], ['.', '\w+?'], implode('|', $m[1])) . ')$/i' : '';
|
|||
|
|
}
|
|||
|
|
$r = mysqli_query($GLOBALS['mysqlilink'], 'SHOW CHARACTER SET') or sxd_my_error();
|
|||
|
|
if ($r) {
|
|||
|
|
while ($item = mysqli_fetch_assoc($r)) {
|
|||
|
|
if (empty($def_charsets) || preg_match($def_charsets, $item['Charset'])) {
|
|||
|
|
$tmp[ $item['Charset'] ] = "{$item['Charset']}";
|
|||
|
|
} // ({$item['Description']})
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return $tmp;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function getCollationList()
|
|||
|
|
{
|
|||
|
|
$tmp = [];
|
|||
|
|
if (!V_MYSQL) {
|
|||
|
|
return $tmp;
|
|||
|
|
}
|
|||
|
|
if (V_MYSQL > 40101) {
|
|||
|
|
$def_charsets = '';
|
|||
|
|
if (!empty($this->CFG['charsets'])) {
|
|||
|
|
$def_charsets = preg_match_all("/([\w*?]+)\s*/", $this->CFG['charsets'], $m, PREG_PATTERN_ORDER) ? '/^(' . str_replace(['?', '*'], ['.', '\w+?'], implode('|', $m[1])) . ')$/i' : '';
|
|||
|
|
}
|
|||
|
|
$r = mysqli_query($GLOBALS['mysqlilink'], 'SHOW COLLATION') or sxd_my_error();
|
|||
|
|
if ($r) {
|
|||
|
|
while ($item = mysqli_fetch_assoc($r)) {
|
|||
|
|
if (empty($def_charsets) || preg_match($def_charsets, $item['Charset'])) {
|
|||
|
|
$tmp[ $item['Charset'] ][ $item['Collation'] ] = $item['Default'] == 'Yes' ? 1 : 0;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return $tmp;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function getObjects($tree, $db_name)
|
|||
|
|
{
|
|||
|
|
mysqli_select_db($GLOBALS['mysqlilink'], $db_name);
|
|||
|
|
// Достаем таблицы
|
|||
|
|
$r = mysqli_query($GLOBALS['mysqlilink'], 'SHOW TABLE STATUS');
|
|||
|
|
$tab_prefix_last = $tab_prefix = '*';
|
|||
|
|
$objects = ['TA' => [], 'VI' => [], 'PR' => [], 'FU' => [], 'TR' => [], 'EV' => []];
|
|||
|
|
if ($r) {
|
|||
|
|
while ($item = mysqli_fetch_assoc($r)) {
|
|||
|
|
if (V_MYSQL > 40101 && is_null($item['Engine']) && preg_match('/^VIEW/i', $item['Comment'])) {
|
|||
|
|
$objects['VI'][] = $item['Name'];
|
|||
|
|
} else {
|
|||
|
|
$objects['TA'][] = [$item['Name'], $item['Rows'], $item['Data_length']];
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if (V_MYSQL > 50014 && $tree != 'services') {
|
|||
|
|
$shows = [
|
|||
|
|
"PROCEDURE STATUS WHERE db='{$db_name}'",
|
|||
|
|
"FUNCTION STATUS WHERE db='{$db_name}'",
|
|||
|
|
'TRIGGERS',
|
|||
|
|
];
|
|||
|
|
if (V_MYSQL > 50100) {
|
|||
|
|
$shows[] = "EVENTS WHERE db='{$db_name}'";
|
|||
|
|
}
|
|||
|
|
// TODO: Поправить проверку событий и триггеров
|
|||
|
|
for ($i = 0, $l = count($shows); $i < $l; ++$i) {
|
|||
|
|
$r = mysqli_query($GLOBALS['mysqlilink'], 'SHOW ' . $shows[ $i ]);
|
|||
|
|
if ($r && mysqli_num_rows($r) > 0) {
|
|||
|
|
$col_name = $shows[ $i ] == 'TRIGGERS' ? 'Trigger' : 'Name';
|
|||
|
|
$type = substr($shows[ $i ], 0, 2);
|
|||
|
|
while ($item = mysqli_fetch_assoc($r)) {
|
|||
|
|
$objects[ $type ][] = $item[ $col_name ];
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
} else {
|
|||
|
|
$objects['VI'] = [];
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return $this->formatTree($tree, $objects);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function getFileObjects($tree, $name, $formatTree = true)
|
|||
|
|
{
|
|||
|
|
// Достаем таблицы
|
|||
|
|
$objects = ['TA' => [], 'VI' => [], 'PR' => [], 'FU' => [], 'TR' => [], 'EV' => []];
|
|||
|
|
if (!preg_match('/\.sql(\.(gz|bz2))?$/i', $name, $m)) {
|
|||
|
|
return '';
|
|||
|
|
}
|
|||
|
|
$name = $this->CFG['backup_path'] . $name;
|
|||
|
|
if (!is_readable($name)) {
|
|||
|
|
return "sxd.tree.{$tree}.error(sxd.lng('err_fopen'))";
|
|||
|
|
}
|
|||
|
|
$fp = $this->openFile($name, 'r');
|
|||
|
|
$temp = fread($fp, 60000);
|
|||
|
|
// Формат файла Sypex Dumper 2 - SXD20
|
|||
|
|
//if(!preg_match('/^(#SXD20\|.+?)\n#EOH\n/s', $temp, $m)) return "sxd.tree.{$tree}.error(sxd.lng('err_sxd2'));z('restore_savejob').disabled = z('restore_runjob').disabled = true;";
|
|||
|
|
if (preg_match('/^(#SXD20\|.+?)\n#EOH\n/s', $temp, $m)) {
|
|||
|
|
$head = explode("\n", $m[1]);
|
|||
|
|
$h = explode('|', $head[0]);
|
|||
|
|
for ($i = 1, $c = count($head); $i < $c; ++$i) {
|
|||
|
|
$objects[ substr($head[ $i ], 1, 2) ] = explode('|', substr($head[ $i ], 4));
|
|||
|
|
}
|
|||
|
|
for ($i = 0, $l = count($objects['TA']); $i < $l; ++$i) {
|
|||
|
|
$objects['TA'][ $i ] = explode('`', $objects['TA'][ $i ]);
|
|||
|
|
}
|
|||
|
|
} else {
|
|||
|
|
$h[9] = '';
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return $formatTree ? $this->formatTree($tree, $objects) . "sxd.comment.restore.value = '{$h[9]}';z('restore_savejob').disabled = z('restore_runjob').disabled = false;" : $objects;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function formatTree($tree, &$objects)
|
|||
|
|
{
|
|||
|
|
$obj = '';
|
|||
|
|
$pid = $row = 1;
|
|||
|
|
$info = [
|
|||
|
|
'TA' => [$this->LNG['obj_tables'], 1],
|
|||
|
|
'VI' => [$this->LNG['obj_views'], 3],
|
|||
|
|
'PR' => [$this->LNG['obj_procs'], 5],
|
|||
|
|
'FU' => [$this->LNG['obj_funcs'], 7],
|
|||
|
|
'TR' => [$this->LNG['obj_trigs'], 9],
|
|||
|
|
'EV' => [$this->LNG['obj_events'], 11],
|
|||
|
|
];
|
|||
|
|
// Находим таблицы с префиксами
|
|||
|
|
$tab_prefix_last = $tab_prefix = '*';
|
|||
|
|
for ($i = 0, $l = count($objects['TA']); $i < $l; ++$i) {
|
|||
|
|
$t = $objects['TA'][ $i ];
|
|||
|
|
$tab_prefix = preg_match('/^([a-z0-9]+_)/', $t[0], $m) ? $m[1] : '*';
|
|||
|
|
if ($tab_prefix != $tab_prefix_last) {
|
|||
|
|
if ($tab_prefix != '*') {
|
|||
|
|
$objects['TA']['*'][] = $tab_prefix;
|
|||
|
|
}
|
|||
|
|
$tab_prefix_last = $tab_prefix;
|
|||
|
|
}
|
|||
|
|
$objects['TA'][ $tab_prefix ][] = $t;
|
|||
|
|
unset($objects['TA'][ $i ]);
|
|||
|
|
}
|
|||
|
|
foreach ($objects as $type => $o) {
|
|||
|
|
if (!count($o)) {
|
|||
|
|
continue;
|
|||
|
|
}
|
|||
|
|
if ($type == 'TA') {
|
|||
|
|
$open_childs = count($o['*']) > 1 ? 0 : 1;
|
|||
|
|
$obj .= "[{$row},0," . sxd_esc($info[ $type ][0]) . ',1,1,1],';
|
|||
|
|
++$row;
|
|||
|
|
foreach ($o['*'] as $value) {
|
|||
|
|
if (is_string($value)) {
|
|||
|
|
if (count($o[ $value ]) > 1) {
|
|||
|
|
$obj .= "[{$row},1,'{$value}*',1,1,{$open_childs}],";
|
|||
|
|
$pid = $row++;
|
|||
|
|
for ($i = 0, $l = count($o[ $value ]); $i < $l; ++$i) {
|
|||
|
|
$checked = ($o[ $value ][ $i ][1] == '' && $o[ $value ][ $i ][2] == '') ? 2 : 1;
|
|||
|
|
$obj .= "[{$row},{$pid}," . sxd_esc($o[ $value ][ $i ][0]) . ",2,{$checked},{$o[$value][$i][2]}],";
|
|||
|
|
++$row;
|
|||
|
|
}
|
|||
|
|
} else {
|
|||
|
|
$value = $o[ $value ][0];
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
//$pid = 1;
|
|||
|
|
if (is_array($value)) {
|
|||
|
|
$checked = ($value[1] == '' && $value[2] == '') ? 2 : 1;
|
|||
|
|
$obj .= "[{$row},1,'{$value[0]}',2,{$checked},{$value[2]}],";
|
|||
|
|
++$row;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
} else {
|
|||
|
|
$obj .= "[{$row},0," . sxd_esc($info[ $type ][0]) . ",{$info[$type][1]},1,1],";
|
|||
|
|
$pid = $row++;
|
|||
|
|
++$info[ $type ][1];
|
|||
|
|
for ($i = 0, $l = count($o); $i < $l; ++$i) {
|
|||
|
|
$o[ $i ] = sxd_esc($o[ $i ], false);
|
|||
|
|
$obj .= "[{$row},{$pid},'{$o[$i]}',{$info[$type][1]},1,0],";
|
|||
|
|
++$row;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
$add = '';
|
|||
|
|
if ($tree == 'restore') {
|
|||
|
|
$add = "z('autoinc').disabled = z('restore_type').disabled = " . ($obj ? 'false' : 'true') . ';';
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return ($obj ? 'sxd.tree.' . $tree . '.drawTree([' . substr_replace($obj, ']', -1) . ');' : "sxd.tree.{$tree}.error(sxd.lng('err_sxd2'));") . $add;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function getFileList()
|
|||
|
|
{
|
|||
|
|
$files = [];
|
|||
|
|
if (is_dir($this->CFG['backup_path']) && false !== ($handle = opendir($this->CFG['backup_path']))) {
|
|||
|
|
while (false !== ($file = readdir($handle))) {
|
|||
|
|
if (preg_match("/^.+?\.sql(\.(gz|bz2))?$/", $file)) {
|
|||
|
|
$files[ $file ] = $file;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
closedir($handle);
|
|||
|
|
}
|
|||
|
|
ksort($files);
|
|||
|
|
|
|||
|
|
return $files;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function getSavedJobs()
|
|||
|
|
{
|
|||
|
|
$sj = ['sj_backup' => [], 'sj_restore' => []];
|
|||
|
|
if (is_dir($this->CFG['backup_path']) && false !== ($handle = opendir($this->CFG['backup_path']))) {
|
|||
|
|
while (false !== ($file = readdir($handle))) {
|
|||
|
|
if (preg_match("/^sj_(.+?)\.job.php$/", $file)) {
|
|||
|
|
include $this->CFG['backup_path'] . $file;
|
|||
|
|
$sj[ 'sj_' . $JOB['type'] ][ $JOB['job'] ] = "<b>{$JOB['job']}</b><br><i>{$JOB['title']} </i>";
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
closedir($handle);
|
|||
|
|
}
|
|||
|
|
if (count($sj['sj_backup']) > 0) {
|
|||
|
|
ksort($sj['sj_backup']);
|
|||
|
|
} else {
|
|||
|
|
$sj['sj_backup'] = [0 => '<b>No Saved Jobs</b><br>' . $this->LNG['no_saved']];
|
|||
|
|
}
|
|||
|
|
if (count($sj['sj_restore']) > 0) {
|
|||
|
|
ksort($sj['sj_restore']);
|
|||
|
|
} else {
|
|||
|
|
$sj['sj_restore'] = [0 => '<b>No Saved Jobs</b><br>' . $this->LNG['no_saved']];
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return "sxd.clearOpt('sj_backup');sxd.clearOpt('sj_restore');sxd.addOpt(" . sxd_php2json($sj) . ');';
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function getFileListExtended()
|
|||
|
|
{
|
|||
|
|
$files = [];
|
|||
|
|
if (is_dir($this->CFG['backup_path']) && false !== ($handle = opendir($this->CFG['backup_path']))) {
|
|||
|
|
while (false !== ($file = readdir($handle))) {
|
|||
|
|
if (preg_match("/^.+?\.sql(\.(gz|bz2))?$/", $file, $m)) {
|
|||
|
|
$fp = $this->openFile($this->CFG['backup_path'] . $file, 'r');
|
|||
|
|
$ext = !empty($m[2]) ? $m[2] : 'sql';
|
|||
|
|
$temp = fgets($fp);
|
|||
|
|
if (preg_match('/^(#SXD20\|.+?)\n/s', $temp, $m)) {
|
|||
|
|
$h = explode('|', $m[1]);
|
|||
|
|
$files[] = [$h[5], substr($h[4], 0, -3), $ext, $h[7], number_format((float)$h[8], 0, '', ' '), filesize((string)$this->CFG['backup_path'] . $file), $h[9], $file];
|
|||
|
|
} elseif (preg_match('/^(#SKD101\|.+?)\n/s', $temp, $m)) {
|
|||
|
|
$h = explode('|', $m[1]);
|
|||
|
|
$files[] = [$h[1], substr($h[3], 0, -3), $ext, $h[2], number_format((float)$h[4], 0, '', ' '), filesize((string)$this->CFG['backup_path'] . $file), 'SXD 1.0.x', $file];
|
|||
|
|
} else {
|
|||
|
|
$files[] = [$file, '-', $ext, '-', '-', filesize((string)$this->CFG['backup_path'] . $file), '', $file];
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
closedir($handle);
|
|||
|
|
}
|
|||
|
|
function s($a, $b)
|
|||
|
|
{
|
|||
|
|
return strcmp($b[1], $a[1]);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
usort($files, 's');
|
|||
|
|
|
|||
|
|
return 'sxd.files.clear();sxd.files.add(' . sxd_php2json($files) . ');';
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function saveJob($job, $config)
|
|||
|
|
{
|
|||
|
|
$this->saveToFile($this->CFG['backup_path'] . $job . '.job.php', "<?php\n\$JOB = " . var_export($config, true) . ";\n" . '?>');
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function openFile($name, $mode)
|
|||
|
|
{
|
|||
|
|
if ($mode == 'r') {
|
|||
|
|
if (preg_match('/\.(sql|sql\.bz2|sql\.gz)$/i', $name, $m)) {
|
|||
|
|
$this->JOB['file_ext'] = strtolower($m[1]);
|
|||
|
|
}
|
|||
|
|
} else {
|
|||
|
|
switch ($this->JOB['zip']) {
|
|||
|
|
case 0 :
|
|||
|
|
$this->JOB['file_ext'] = 'sql';
|
|||
|
|
break;
|
|||
|
|
case 10:
|
|||
|
|
$this->JOB['file_ext'] = 'sql.bz2';
|
|||
|
|
break;
|
|||
|
|
default:
|
|||
|
|
$this->JOB['file_ext'] = 'sql.gz';
|
|||
|
|
break;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
switch ($this->JOB['file_ext']) {
|
|||
|
|
case 'sql':
|
|||
|
|
return fopen($name, "{$mode}b");
|
|||
|
|
break;
|
|||
|
|
case 'sql.bz2':
|
|||
|
|
return bzopen($name, $mode);
|
|||
|
|
break;
|
|||
|
|
case 'sql.gz':
|
|||
|
|
return gzopen($name, $mode . ($mode == 'w' ? $this->JOB['zip'] : ''));
|
|||
|
|
break;
|
|||
|
|
default:
|
|||
|
|
return false;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
function sxd_read_sql($f, &$seek, $ei, $delimiter = "\t;", $eol = "\n")
|
|||
|
|
{
|
|||
|
|
static $l = '';
|
|||
|
|
static $r = 0;
|
|||
|
|
$fs = ftell($f);
|
|||
|
|
$delim_len = strlen($delimiter . $eol);
|
|||
|
|
while ($r || $s = fread($f, 61440)) {
|
|||
|
|
if (!$r) {
|
|||
|
|
$l .= $s;
|
|||
|
|
}
|
|||
|
|
$pos = strpos($l, $delimiter . $eol);
|
|||
|
|
if ($pos !== false) {
|
|||
|
|
// Есть окончание запроса
|
|||
|
|
$q = substr($l, 0, $pos);
|
|||
|
|
$l = substr($l, $pos + $delim_len);
|
|||
|
|
$r = 1;
|
|||
|
|
$seek = strlen($l);
|
|||
|
|
|
|||
|
|
return $q;
|
|||
|
|
}
|
|||
|
|
if ($ei) {
|
|||
|
|
$pos = strrpos($l, $eol);
|
|||
|
|
if ($pos > 0 && $l{$pos - 1} === ',') {
|
|||
|
|
// Окончание не найдено
|
|||
|
|
$q = substr($l, 0, $pos - 1);
|
|||
|
|
$l = substr($l, $pos + strlen($eol));
|
|||
|
|
$seek = strlen($l);
|
|||
|
|
$r = 0;
|
|||
|
|
|
|||
|
|
return $q;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
$r = 0;
|
|||
|
|
}
|
|||
|
|
if (!empty($l)) {
|
|||
|
|
return $l;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return false;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
function sxd_check($n, $obj, $filt)
|
|||
|
|
{
|
|||
|
|
return isset($obj[ $n ]) || ($filt && preg_match($filt, $n));
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
function sxd_php2json($obj)
|
|||
|
|
{
|
|||
|
|
if (count($obj) == 0) {
|
|||
|
|
return '[]';
|
|||
|
|
}
|
|||
|
|
$is_obj = isset($obj[0]) && isset($obj[ count($obj) - 1 ]) ? false : true;
|
|||
|
|
$str = $is_obj ? '{' : '[';
|
|||
|
|
foreach ($obj as $key => $value) {
|
|||
|
|
$str .= $is_obj ? "'" . addcslashes((string)$key, "\n\r\t'\\/") . "'" . ':' : '';
|
|||
|
|
if (is_array($value)) {
|
|||
|
|
$str .= sxd_php2json($value);
|
|||
|
|
} elseif (is_null($value)) {
|
|||
|
|
$str .= 'null';
|
|||
|
|
} elseif (is_bool($value)) {
|
|||
|
|
$str .= $value ? 'true' : 'false';
|
|||
|
|
} elseif (is_numeric($value)) {
|
|||
|
|
$str .= $value;
|
|||
|
|
} else {
|
|||
|
|
$str .= "'" . addcslashes((string)$value, "\n\r\t'\\/") . "'";
|
|||
|
|
}
|
|||
|
|
$str .= ',';
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return substr_replace($str, $is_obj ? '}' : ']', -1);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
function sxd_ver2int($ver)
|
|||
|
|
{
|
|||
|
|
return preg_match("/^(\d+)\.(\d+)\.(\d+)/", $ver, $m) ? sprintf('%d%02d%02d', $m[1], $m[2], $m[3]) : 0;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
function sxd_error_handler($errno, $errmsg, $filename, $linenum, $vars)
|
|||
|
|
{
|
|||
|
|
global $SXD;
|
|||
|
|
if ($SXD->try) {
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
if ($errno == 8192) {
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
if (strpos($errmsg, 'timezone settings')) {
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
$errortype = [
|
|||
|
|
1 => 'Error',
|
|||
|
|
2 => 'Warning',
|
|||
|
|
4 => 'Parsing Error',
|
|||
|
|
8 => 'Notice',
|
|||
|
|
16 => 'Core Error',
|
|||
|
|
32 => 'Core Warning',
|
|||
|
|
64 => 'Compile Error',
|
|||
|
|
128 => 'Compile Warning',
|
|||
|
|
256 => 'MySQL Error',
|
|||
|
|
512 => 'Warning',
|
|||
|
|
1024 => 'Notice',
|
|||
|
|
2048 => 'Strict',
|
|||
|
|
8192 => 'Deprecated',
|
|||
|
|
16384 => 'Deprecated',
|
|||
|
|
];
|
|||
|
|
$str = sxd_esc("{$errortype[$errno]}: {$errmsg} ({$filename}:{$linenum})", false);
|
|||
|
|
if (SXD_DEBUG) {
|
|||
|
|
error_log("[index.php]\n{$str}\n", 3, 'backup/error.log');
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if ($errno == 8 || $errno == 1024) {
|
|||
|
|
if (!$SXD->fh_log && !$SXD->fh_rtl) {
|
|||
|
|
echo isset($_POST['ajax']) ? "alert('" . ($str) . "');" : $str;
|
|||
|
|
} else {
|
|||
|
|
fwrite($SXD->fh_log, date('Y.m.d H:i:s') . "\t3\t{$str}\n");
|
|||
|
|
}
|
|||
|
|
} elseif ($errno < 1024) {
|
|||
|
|
$SXD->error = true;
|
|||
|
|
if (!$SXD->fh_log && !$SXD->fh_rtl) {
|
|||
|
|
echo isset($_POST['ajax']) ? "alert('" . ($str) . "');" : $str;
|
|||
|
|
} else {
|
|||
|
|
$SXD->rtl[1] = time();
|
|||
|
|
$SXD->rtl[9] = 5;
|
|||
|
|
fseek($SXD->fh_rtl, 0);
|
|||
|
|
fwrite($SXD->fh_rtl, implode("\t", $SXD->rtl));
|
|||
|
|
fwrite($SXD->fh_log, date('Y.m.d H:i:s') . "\t4\t{$str}\n");
|
|||
|
|
unset($SXD->rtl);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
die;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
function sxd_esc($str, $quoted = true)
|
|||
|
|
{
|
|||
|
|
return $quoted ? "'" . addcslashes((string)$str, "\\\0\n\r\t\'") . "'" : addcslashes((string)$str, "\\\0\n\r\t\'");
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
function sxd_my_error()
|
|||
|
|
{
|
|||
|
|
trigger_error(mysqli_error(), E_USER_ERROR);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
function sxd_shutdown()
|
|||
|
|
{
|
|||
|
|
global $SXD;
|
|||
|
|
if (isset($SXD->fh_rtl) && is_resource($SXD->fh_rtl) && !empty($SXD->rtl) && empty($SXD->error)) {
|
|||
|
|
$SXD->rtl[1] = time();
|
|||
|
|
if (!empty($SXD->JOB['file_stp']) && file_exists(dirname(__FILE__) . '/' . $SXD->JOB['file_stp'])) {
|
|||
|
|
$type = file_get_contents(dirname(__FILE__) . '/' . $SXD->JOB['file_stp']);
|
|||
|
|
$SXD->rtl[9] = !empty($type) ? $type : 2;
|
|||
|
|
} else {
|
|||
|
|
$SXD->rtl[9] = 5;
|
|||
|
|
}
|
|||
|
|
fseek($SXD->fh_rtl, 0);
|
|||
|
|
fwrite($SXD->fh_rtl, implode("\t", $SXD->rtl));
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
function sxd_antimagic($arr)
|
|||
|
|
{
|
|||
|
|
return is_array($arr) ? array_map('sxd_antimagic', $arr) : stripslashes($arr);
|
|||
|
|
}
|