| Server IP : 94.23.64.18 / Your IP :
216.73.216.185 [
Web Server : Apache System : Linux webm005.cluster107.gra.hosting.ovh.net 5.15.167-ovh-vps-grsec-zfs-classid #1 SMP Tue Sep 17 08:14:20 UTC 2024 x86_64 User : villadal ( 6036) PHP Version : 7.4.33 Disable Function : _dyuweyrj4,_dyuweyrj4r,dl Domains : 2 Domains MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /home/villadal/www/old/wp-content/plugins/backwpup/inc/ |
Upload File : |
<?php
use Symfony\Component\OptionsResolver\OptionsResolver;
use Symfony\Component\OptionsResolver\Options;
use Symfony\Component\OptionsResolver\Exception\InvalidOptionsException;
/**
* Class to create a MYSQL dump with mysqli as sql file
*/
class BackWPup_MySQLDump
{
// Compression flags
const COMPRESS_NONE = '';
const COMPRESS_GZ = 'gz';
/**
* Holder for mysqli resource
*/
private $mysqli = NULL;
/**
* Whether we are connected to the database
*
* @var bool
*/
private $connected = false;
/**
* Holder for dump file handle
*/
private $handle = NULL;
/**
* Table names of Tables in Database
*/
public $tables_to_dump = array();
/**
* View names of Views in Database
*/
public $views_to_dump = array();
/**
* Table names of Tables in Database
*/
private $table_types = array();
/**
* Table information of Tables in Database
*/
private $table_status = array();
/**
* Database name
*/
private $dbname = '';
/**
* Compression to use
* empty for none
* gz for Gzip
*/
private $compression = '';
/**
* Check params and makes confections
* gets the table information too
*
* @param $args array with arguments
* @throws BackWPup_MySQLDump_Exception
* @global $wpdb wpdb
*/
public function __construct( $args = array() ) {
if ( ! class_exists( 'mysqli' ) ) {
throw new BackWPup_MySQLDump_Exception( __( 'No MySQLi extension found. Please install it.', 'backwpup' ) );
}
$resolver = new OptionsResolver();
$this->configureOptions($resolver);
$args = $resolver->resolve($args);
$driver = new mysqli_driver();
$mode = $driver->report_mode;
$driver->report_mode = MYSQLI_REPORT_ERROR | MYSQLI_REPORT_STRICT;
$this->connect($args);
$driver->report_mode = $mode;
//set charset
if ( ! empty( $args[ 'dbcharset' ] ) ) {
$this->setCharset( $args[ 'dbcharset' ] );
}
//set compression
$this->compression = $args[ 'compression' ];
//open file if set
if ( $args[ 'dumpfile' ] ) {
if ( $args['compression'] === self::COMPRESS_GZ ) {
if ( ! function_exists( 'gzencode' ) ) {
throw new BackWPup_MySQLDump_Exception( __( 'Functions for gz compression not available', 'backwpup' ) );
}
$this->handle = fopen( 'compress.zlib://' . $args[ 'dumpfile' ], 'ab' );
} else {
$this->handle = fopen( $args[ 'dumpfile' ], 'ab' );
}
} else {
$this->handle = $args[ 'dumpfilehandle' ];
}
//check file handle
if ( ! $this->handle ) {
throw new BackWPup_MySQLDump_Exception( __( 'Cannot open SQL backup file', 'backwpup' ) );
}
//get table info
$res = $this->mysqli->query( "SHOW TABLE STATUS FROM `" . $this->dbname . "`" );
$GLOBALS[ 'wpdb' ]->num_queries ++;
if ( $this->mysqli->error ) {
throw new BackWPup_MySQLDump_Exception( sprintf( __( 'Database error %1$s for query %2$s', 'backwpup' ), $this->mysqli->error, "SHOW TABLE STATUS FROM `" .$this->dbname . "`" ) );
} else {
while ( $tablestatus = $res->fetch_assoc() ) {
$this->table_status[ $tablestatus[ 'Name' ] ] = $tablestatus;
}
$res->close();
}
//get table names and types from Database
$res = $this->mysqli->query( 'SHOW FULL TABLES FROM `' . $this->dbname . '`' );
$GLOBALS[ 'wpdb' ]->num_queries ++;
if ( $this->mysqli->error ) {
throw new BackWPup_MySQLDump_Exception( sprintf( __( 'Database error %1$s for query %2$s', 'backwpup' ), $this->mysqli->error, 'SHOW FULL TABLES FROM `' . $this->dbname . '`' ) );
} else {
while ( $table = $res->fetch_array( MYSQLI_NUM ) ) {
$this->table_types[ $table[ 0 ] ] = $table[ 1 ];
$this->tables_to_dump[] = $table[ 0 ];
if ( $table[ 1 ] === 'VIEW' ) {
$this->views_to_dump[] = $table[ 0 ];
$this->table_status[ $table[ 0 ] ][ 'Rows' ] = 0;
}
}
$res->close();
}
}
/**
* Configure options
*
* @param \Symfony\Component\OptionsResolver\OptionsResolver $resolver
*/
protected function configureOptions(OptionsResolver $resolver)
{
$resolver->setDefaults([
'dbhost' => DB_HOST,
'dbport' => null,
'dbsocket' => null,
'dbname' => DB_NAME,
'dbuser' => DB_USER,
'dbpassword' => DB_PASSWORD,
'dbcharset' => defined('DB_CHARSET') ? DB_CHARSET : 'utf8mb4',
'dumpfilehandle' => fopen('php://output', 'wb'),
'dumpfile' => null,
'dbclientflags' => defined('MYSQL_CLIENT_FLAGS') ? MYSQL_CLIENT_FLAGS : 0,
'compression' => function (Options $options) {
if ($options['dumpfile'] !== null
&& substr(strtolower($options['dumpfile']), -3) === '.gz') {
return self::COMPRESS_GZ;
}
return self::COMPRESS_NONE;
},
]);
$port = $socket = null;
$resolver->setNormalizer('dbhost', function (Options $options, $value) use (&$port, &$socket) {
if (strpos($value, ':') !== false) {
list($value, $part) = array_map('trim', explode(':', $value, 2));
if (is_numeric($part)) {
$port = intval($part);
} elseif (!empty($part)) {
$socket = $part;
}
}
return $value ?: 'localhost';
});
$resolver->setDefault('dbport', function (Options $options) use (&$port) {
return $port;
});
$resolver->setDefault('dbsocket', function (Options $options) use (&$socket) {
return $socket;
});
$resolver->setAllowedValues('dumpfilehandle', function ($value) {
// Ensure handle is writable
$metadata = stream_get_meta_data($value);
if ($metadata['mode'][0] === 'r' && strpos($metadata['mode'], '+') === false) {
return false;
}
return true;
});
$resolver->setAllowedValues('compression', [self::COMPRESS_NONE, self::COMPRESS_GZ]);
$resolver->setAllowedTypes('dbhost', 'string');
$resolver->setAllowedTypes('dbport', ['null', 'int']);
$resolver->setAllowedTypes('dbsocket', ['null', 'string']);
$resolver->setAllowedTypes('dbname', 'string');
$resolver->setAllowedTypes('dbuser', 'string');
$resolver->setAllowedTypes('dbpassword', 'string');
$resolver->setAllowedTypes('dbcharset', ['null', 'string']);
$resolver->setAllowedTypes('dumpfilehandle', 'resource');
$resolver->setAllowedTypes('dumpfile', ['null', 'string']);
$resolver->setAllowedTypes('dbclientflags', 'int');
}
/**
* Set the best available database charset
*
* @param string $charset The charset to try setting
*
* @return string The set charset
*/
public function setCharset($charset)
{
if ($charset === 'utf8' && $this->getConnection()->set_charset('utf8mb4') === true) {
return 'utf8mb4';
} elseif ($this->getConnection()->set_charset($charset) === true) {
return $charset;
} elseif ($charset === 'utf8mb4' && $this->getConnection()->set_charset('utf8') === true) {
return 'utf8';
}
trigger_error(
sprintf(
__('Cannot set DB charset to %s', 'backwpup'),
$charset
),
E_USER_WARNING
);
return false;
}
/**
* Get the database connection
*
* @return \mysqli
*/
protected function getConnection()
{
if ($this->mysqli === null) {
$this->mysqli = mysqli_init();
}
return $this->mysqli;
}
/**
* Whether the database is connected
*
* @return bool
*/
public function isConnected()
{
return $this->connected === true;
}
/**
* Connect to the database
*
* @param array $args Connection parameters
*/
protected function connect(array $args)
{
if ($this->isConnected()) {
return;
}
$mysqli = $this->getConnection();
if (!$mysqli->options(MYSQLI_OPT_CONNECT_TIMEOUT, 5)) {
trigger_error(__('Setting of MySQLi connection timeout failed', 'backwpup'), E_USER_WARNING); // phpcs:ignore
}
//connect to Database
try {
$mysqli->real_connect(
$args['dbhost'],
$args['dbuser'],
$args['dbpassword'],
$args['dbname'],
$args['dbport'],
$args['dbsocket'],
$args['dbclientflags']
);
} catch (\mysqli_sql_exception $e) {
throw new BackWPup_MySQLDump_Exception(
sprintf(
__('Cannot connect to MySQL database (%1$d: %2$s)', 'backwpup'),
$e->getCode(),
$e->getMessage()
)
);
}
//set db name
$this->dbname = $args['dbname'];
// We are now connected
$this->connected = true;
}
/**
* Get the name of the database
*
* @return string
*/
protected function getDbName()
{
return $this->dbname;
}
/**
* Report a query error
*
* @param \mysqli_sql_exception $exception The thrown exception
* @param string $query The query that caused the error
*/
protected function logQueryError(\mysqli_sql_exception $exception, $query)
{
// phpcs:disable WordPress.PHP.DevelopmentFunctions.error_log_trigger_error, WordPress.XSS.EscapeOutput.OutputNotEscaped
trigger_error(
sprintf(
__('Database error: %1$s. Query: %2$s', 'backwpup'),
$exception->getMessage(),
$query
),
E_USER_WARNING
);
// phpcs:enable WordPress.PHP.DevelopmentFunctions.error_log_trigger_error. WordPress.XSS.EscapeOutput.OutputNotEscaped
}
/**
* Send a query to the database
*
* @param string $query The query to execute
* @return mixed The result of the query
*/
protected function query($sql)
{
$result = $this->getConnection()->query($sql);
backwpup_wpdb()->num_queries++;
return $result;
}
/**
* Start the dump
*/
public function execute() {
//increase time limit
@set_time_limit( 300 );
//write dump head
$this->dump_head();
//write tables
foreach( $this->tables_to_dump as $table ) {
$this->dump_table_head( $table );
$this->dump_table( $table );
$this->dump_table_footer( $table );
}
//write footer
$this->dump_footer();
}
/**
* Write Dump Header
*
* @param bool $wp_info Dump WordPress info in dump head
*/
public function dump_head( $wp_info = FALSE ) {
// get sql timezone
$res = $this->mysqli->query( "SELECT @@time_zone" );
$GLOBALS[ 'wpdb' ]->num_queries ++;
$mysqltimezone = $res->fetch_row();
$mysqltimezone = $mysqltimezone[0];
$res->close();
//For SQL always use \n as MySQL wants this on all platforms.
$dbdumpheader = "-- ---------------------------------------------------------\n";
$dbdumpheader .= "-- Backup with BackWPup ver.: " . BackWPup::get_plugin_data( 'Version' ) . "\n";
$dbdumpheader .= "-- http://backwpup.com/\n";
if ( $wp_info ) {
$dbdumpheader .= "-- Blog Name: " . get_bloginfo( 'name' ) . "\n";
$dbdumpheader .= "-- Blog URL: " . trailingslashit( get_bloginfo( 'url' ) ) . "\n";
$dbdumpheader .= "-- Blog ABSPATH: " . trailingslashit( str_replace( '\\', '/', ABSPATH ) ) . "\n";
$dbdumpheader .= "-- Blog Charset: " . get_bloginfo( 'charset' ) . "\n";
$dbdumpheader .= "-- Table Prefix: " . $GLOBALS[ 'wpdb' ]->prefix . "\n";
}
$dbdumpheader .= "-- Database Name: " . $this->dbname . "\n";
$dbdumpheader .= "-- Backup on: " . date( 'Y-m-d H:i.s', current_time( 'timestamp' ) ) . "\n";
$dbdumpheader .= "-- ---------------------------------------------------------\n\n";
//for better import with mysql client
$dbdumpheader .= "/*!40101 SET @OLD_CHARACTER_SET_CLIENT=@@CHARACTER_SET_CLIENT */;\n";
$dbdumpheader .= "/*!40101 SET @OLD_CHARACTER_SET_RESULTS=@@CHARACTER_SET_RESULTS */;\n";
$dbdumpheader .= "/*!40101 SET @OLD_COLLATION_CONNECTION=@@COLLATION_CONNECTION */;\n";
$dbdumpheader .= "/*!40101 SET NAMES " . $this->mysqli->character_set_name() . " */;\n";
$dbdumpheader .= "/*!40103 SET @OLD_TIME_ZONE=@@TIME_ZONE */;\n";
$dbdumpheader .= "/*!40103 SET TIME_ZONE='" . $mysqltimezone . "' */;\n";
$dbdumpheader .= "/*!40014 SET @OLD_UNIQUE_CHECKS=@@UNIQUE_CHECKS, UNIQUE_CHECKS=0 */;\n";
$dbdumpheader .= "/*!40014 SET @OLD_FOREIGN_KEY_CHECKS=@@FOREIGN_KEY_CHECKS, FOREIGN_KEY_CHECKS=0 */;\n";
$dbdumpheader .= "/*!40101 SET @OLD_SQL_MODE=@@SQL_MODE, SQL_MODE='NO_AUTO_VALUE_ON_ZERO' */;\n";
$dbdumpheader .= "/*!40111 SET @OLD_SQL_NOTES=@@SQL_NOTES, SQL_NOTES=0 */;\n\n";
$this->write( $dbdumpheader );
}
/**
* Write Dump Footer with dump of functions and procedures
*/
public function dump_footer() {
//dump Views
foreach( $this->views_to_dump as $view ) {
$this->dump_view_table_head( $view );
}
//dump procedures and functions
$this->write("\n--\n-- Backup routines for database '" . $this->dbname . "'\n--\n");
// Temporarily set mysqli to throw exceptions
$driver = new \mysqli_driver();
$mode = $driver->report_mode;
$driver->report_mode = MYSQLI_REPORT_ERROR | MYSQLI_REPORT_STRICT;
// Dump Functions
$this->dump_functions();
// Dump Procedures
$this->dump_procedures();
// Dump Triggers
$this->dump_triggers();
// Restore report mode for other methods that do not support exceptions yet
// This should be changed ASAP to support SQL exceptions globally
$driver->report_mode = $mode;
//for better import with mysql client
$dbdumpfooter = "\n/*!40103 SET TIME_ZONE=@OLD_TIME_ZONE */;\n";
$dbdumpfooter .= "/*!40101 SET SQL_MODE=@OLD_SQL_MODE */;\n";
$dbdumpfooter .= "/*!40014 SET FOREIGN_KEY_CHECKS=@OLD_FOREIGN_KEY_CHECKS */;\n";
$dbdumpfooter .= "/*!40014 SET UNIQUE_CHECKS=@OLD_UNIQUE_CHECKS */;\n";
$dbdumpfooter .= "/*!40101 SET CHARACTER_SET_CLIENT=@OLD_CHARACTER_SET_CLIENT */;\n";
$dbdumpfooter .= "/*!40101 SET CHARACTER_SET_RESULTS=@OLD_CHARACTER_SET_RESULTS */;\n";
$dbdumpfooter .= "/*!40101 SET COLLATION_CONNECTION=@OLD_COLLATION_CONNECTION */;\n";
$dbdumpfooter .= "/*!40111 SET SQL_NOTES=@OLD_SQL_NOTES */;\n";
$dbdumpfooter .= "\n-- Backup completed on " . date( 'Y-m-d H:i:s', current_time( 'timestamp' ) ). "\n";
$this->write( $dbdumpfooter );
}
/**
* Dump table structure
*
* @param string $table name of Table to dump
* @throws BackWPup_MySQLDump_Exception
* @return int Size of table
*/
public function dump_table_head( $table ) {
//dump View
if ( $this->table_types[ $table ] === 'VIEW' ) {
//Dump the view table structure
$fields = array();
$res = $this->mysqli->query( "SELECT * FROM `" . $table . "` LIMIT 1" );
$GLOBALS[ 'wpdb' ]->num_queries ++;
if ( $this->mysqli->error ) {
trigger_error( sprintf( __( 'Database error %1$s for query %2$s', 'backwpup' ), $this->mysqli->error, "SELECT * FROM `" . $table . "` LIMIT 1" ), E_USER_WARNING );
} else {
$fields = $res->fetch_fields();
$res->close();
}
if ( $res ) {
$tablecreate = "\n--\n-- Temporary table structure for view `" . $table . "`\n--\n\n";
$tablecreate .= "DROP TABLE IF EXISTS `" . $table . "`;\n";
$tablecreate .= "/*!50001 DROP VIEW IF EXISTS `" . $table . "`*/;\n";
$tablecreate .= "/*!40101 SET @saved_cs_client = @@character_set_client */;\n";
$tablecreate .= "/*!40101 SET character_set_client = '" . $this->mysqli->character_set_name() . "' */;\n";
$tablecreate .= "CREATE TABLE `" . $table . "` (\n";
foreach( $fields as $field ) {
$tablecreate .= " `". $field->orgname . "` tinyint NOT NULL,\n";
}
$tablecreate = substr( $tablecreate, 0, -2 ) ."\n";
$tablecreate .= ");\n";
$tablecreate .= "/*!40101 SET character_set_client = @saved_cs_client */;\n";
$this->write( $tablecreate );
}
return 0;
}
//dump normal Table
$tablecreate = "\n--\n-- Table structure for `" . $table . "`\n--\n\n";
$tablecreate .= "DROP TABLE IF EXISTS `" . $table . "`;\n";
$tablecreate .= "/*!40101 SET @saved_cs_client = @@character_set_client */;\n";
$tablecreate .= "/*!40101 SET character_set_client = '" . $this->mysqli->character_set_name() . "' */;\n";
//Dump the table structure
$res = $this->mysqli->query( "SHOW CREATE TABLE `" . $table . "`" );
$GLOBALS[ 'wpdb' ]->num_queries ++;
if ( $this->mysqli->error ) {
trigger_error( sprintf( __( 'Database error %1$s for query %2$s', 'backwpup' ), $this->mysqli->error, "SHOW CREATE TABLE `" . $table . "`" ), E_USER_WARNING );
} else {
$createtable = $res->fetch_assoc();
$res->close();
$tablecreate .= $createtable[ 'Create Table' ] . ";\n";
$tablecreate .= "/*!40101 SET character_set_client = @saved_cs_client */;\n";
$this->write( $tablecreate );
if ( $this->table_status[ $table ][ 'Engine' ] !== 'MyISAM' ) {
$this->table_status[ $table ][ 'Rows' ] = '~' . $this->table_status[ $table ][ 'Rows' ];
}
if ( $this->table_status[ $table ][ 'Rows' ] !== 0 ) {
//Dump Table data
$this->write( "\n--\n-- Backup data for table `" . $table . "`\n--\n\nLOCK TABLES `" . $table . "` WRITE;\n/*!40000 ALTER TABLE `" . $table . "` DISABLE KEYS */;\n" );
}
return $this->table_status[ $table ][ 'Rows' ];
}
return 0;
}
/**
* Dump view structure
*
* @param string $view name of Table to dump
* @throws BackWPup_MySQLDump_Exception
* @return int Size of table
*/
public function dump_view_table_head( $view ) {
//Dump the view structure
$res = $this->mysqli->query( "SHOW CREATE VIEW `" . $view . "`" );
$GLOBALS[ 'wpdb' ]->num_queries ++;
if ( $this->mysqli->error ) {
trigger_error( sprintf( __( 'Database error %1$s for query %2$s', 'backwpup' ), $this->mysqli->error, "SHOW CREATE VIEW `" . $view . "`" ), E_USER_WARNING );
} else {
$createview = $res->fetch_assoc();
$res->close();
$tablecreate = "\n--\n-- View structure for `" . $view . "`\n--\n\n";
$tablecreate .= "DROP TABLE IF EXISTS `" . $view . "`;\n";
$tablecreate .= "DROP VIEW IF EXISTS `" . $view . "`;\n";
$tablecreate .= "/*!40101 SET @saved_cs_client = @@character_set_client */;\n";
$tablecreate .= "/*!40101 SET character_set_client = '" . $this->mysqli->character_set_name() . "' */;\n";
$tablecreate .= $createview[ 'Create View' ] . ";\n";
$tablecreate .= "/*!40101 SET character_set_client = @saved_cs_client */;\n";
$this->write( $tablecreate );
}
}
/**
* Dump table footer
*
* @param string $table name of Table to dump
* @return int Size of table
*/
public function dump_table_footer( $table ) {
if ( $this->table_status[ $table ][ 'Rows' ] !== 0 ) {
$this->write( "/*!40000 ALTER TABLE `" . $table . "` ENABLE KEYS */;\nUNLOCK TABLES;\n" );
}
}
/**
* Dump table Data
*
* @param string $table name of Table to dump
* @param int $start Start of lengh paramter
* @param int $length how many
* @return int done records in this backup
* @throws BackWPup_MySQLDump_Exception
*/
public function dump_table( $table, $start = 0, $length = 0 ) {
if ( ! is_numeric( $start ) || $start < 0 ) {
throw new BackWPup_MySQLDump_Exception( sprintf( __( 'Start for table backup is not correctly set: %1$s', 'backwpup' ), $start ) );
}
if ( ! is_numeric( $length ) || $length < 0 ) {
throw new BackWPup_MySQLDump_Exception( sprintf( __( 'Length for table backup is not correctly set: %1$s', 'backwpup' ), $length ) );
}
$done_records = 0;
if ( $this->get_table_type_for( $table ) === 'VIEW' ) {
return $done_records;
}
//get data from table
try {
$res = $this->do_table_query( $table, $start, $length );
} catch ( BackWPup_MySQLDump_Exception $e ) {
trigger_error( sprintf( __( 'Database error %1$s for query %2$s', 'backwpup' ), $e->getMessage(), "SELECT * FROM `" . $table . "`" ), E_USER_WARNING );
return 0;
}
$fieldsarray = array();
$fieldinfo = array();
$fields = $res->fetch_fields();
$i = 0;
foreach ( $fields as $field ) {
$fieldsarray[ $i ] = $field->orgname;
$fieldinfo[ $fieldsarray[ $i ] ] = $field;
$i ++;
}
$dump = '';
while ( $data = $res->fetch_assoc() ) {
$values = array();
foreach ( $data as $key => $value ) {
if ( is_null( $value ) || ! isset( $value ) ) { // Make Value NULL to string NULL
$value = "NULL";
} elseif ( in_array( (int) $fieldinfo[ $key ]->type, array( MYSQLI_TYPE_DECIMAL, MYSQLI_TYPE_NEWDECIMAL, MYSQLI_TYPE_BIT, MYSQLI_TYPE_TINY, MYSQLI_TYPE_SHORT, MYSQLI_TYPE_LONG, MYSQLI_TYPE_FLOAT, MYSQLI_TYPE_DOUBLE, MYSQLI_TYPE_LONGLONG, MYSQLI_TYPE_INT24, MYSQLI_TYPE_YEAR ), true ) ) {//is value numeric no esc
$value = empty( $value ) ? 0 : $value;
} elseif ( in_array( (int) $fieldinfo[ $key ]->type, array( MYSQLI_TYPE_TIMESTAMP, MYSQLI_TYPE_DATE, MYSQLI_TYPE_TIME, MYSQLI_TYPE_DATETIME, MYSQLI_TYPE_NEWDATE ), true ) ) {//date/time types
$value = "'$value'";
} elseif ( $fieldinfo[ $key ]->flags & MYSQLI_BINARY_FLAG ) {//is value binary
$hex = unpack( 'H*', $value );
$value = empty( $value ) ? "''" : "0x$hex[1]";
} else {
$value = "'" . $this->escapeString( $value ) . "'";
}
$values[ ] = $value;
}
//new query in dump on more than 50000 chars.
if ( empty( $dump ) )
$dump = "INSERT INTO `" . $table . "` (`" . implode( "`, `", $fieldsarray ) . "`) VALUES \n";
if ( strlen( $dump ) <= 50000 ) {
$dump .= "(" . implode( ", ", $values ) . "),\n";
} else {
$dump .= "(" . implode( ", ", $values ) . ");\n";
$this->write( $dump );
$dump = '';
}
$done_records ++;
}
if ( ! empty( $dump ) ) {
// Remove trailing , and newline.
$dump = substr( $dump, 0, -2 ) . ";\n" ;
$this->write( $dump );
}
$res->close();
return $done_records;
}
/**
* Dump functions
*
* Dumps all functions found in the database.
*/
protected function dump_functions()
{
try {
$statusResult = $this->query("SHOW FUNCTION STATUS");
} catch (\mysqli_sql_exception $e) {
$this->logQueryError($e, 'SHOW FUNCTION STATUS');
return;
}
while ($function = $statusResult->fetch_assoc()) {
if ($this->getDbName() !== $function['Db']) {
continue;
}
$query = sprintf(
'SHOW CREATE FUNCTION `%1$s`.`%2$s`',
$function['Db'],
$function['Name']
);
try {
$createResult = $this->query($query);
$createFunction = $createResult->fetch_assoc();
$createResult->close();
if ($createFunction === null) {
continue;
}
$sql = sprintf(
"\n--\n" .
"-- Function structure for %1\$s\n" .
"--\n\n" .
"/*!50003 DROP FUNCTION IF EXISTS `%1\$s` */;\n" .
"/*!50003 SET @saved_cs_client = @@character_set_client */ ;\n" .
"/*!50003 SET @saved_cs_results = @@character_set_results */ ;\n" .
"/*!50003 SET @saved_col_connection = @@collation_connection */ ;\n" .
"/*!50003 SET character_set_client = %2\$s */ ;\n" .
"/*!50003 SET character_set_results = %2\$s */ ;\n" .
"/*!50003 SET collation_connection = %3\$s */ ;\n" .
"/*!50003 SET @saved_sql_mode = @@sql_mode */ ;\n" .
"/*!50003 SET sql_mode = '%4\$s' */ ;\n" .
"DELIMITER ;;\n" .
"%5\$s ;;\n" .
"DELIMITER ;\n" .
"/*!50003 SET sql_mode = @saved_sql_mode */ ;\n" .
"/*!50003 SET character_set_client = @saved_cs_client */ ;\n" .
"/*!50003 SET character_set_results = @saved_cs_results */ ;\n" .
"/*!50003 SET collation_connection = @saved_col_connection */ ;\n",
$createFunction['Function'],
$createFunction['character_set_client'],
$createFunction['collation_connection'],
$createFunction['sql_mode'],
$createFunction['Create Function']
);
$this->write($sql);
} catch (\mysqli_sql_exception $e) {
$this->logQueryError($e, $query);
}
}
$statusResult->close();
}
/**
* Dump procedures
*
* Dumps all stored procedures found in the database.
*/
protected function dump_procedures()
{
try {
$statusResult = $this->query('SHOW PROCEDURE STATUS');
} catch (mysqli_sql_exception $e) {
$this->logQueryError($e, 'SHOW PROCEDURE STATUS');
return;
}
while ($procedure = $statusResult->fetch_assoc()) {
if ($this->getDbName() !== $procedure['Db']) {
continue;
}
$query = sprintf(
'SHOW CREATE PROCEDURE `%1$s`.`%2$s`',
$procedure['Db'],
$procedure['Name']
);
try {
$createResult = $this->query($query);
$createProcedure = $createResult->fetch_assoc();
$createResult->close();
if ($createProcedure === null) {
continue;
}
$sql = sprintf(
"\n--\n" .
"-- Procedure structure for %1\$s\n" .
"--\n\n" .
"/*!50003 DROP PROCEDURE IF EXISTS `%1\$s` */;\n" .
"/*!50003 SET @saved_cs_client = @@character_set_client */ ;\n" .
"/*!50003 SET @saved_cs_results = @@character_set_results */ ;\n" .
"/*!50003 SET @saved_col_connection = @@collation_connection */ ;\n" .
"/*!50003 SET character_set_client = %2\$s */ ;\n" .
"/*!50003 SET character_set_results = %2\$s */ ;\n" .
"/*!50003 SET collation_connection = %3\$s */ ;\n" .
"/*!50003 SET @saved_sql_mode = @@sql_mode */ ;\n" .
"/*!50003 SET sql_mode = '%4\$s' */ ;\n" .
"DELIMITER ;;\n" .
"%5\$s ;;\n" .
"DELIMITER ;\n" .
"/*!50003 SET sql_mode = @saved_sql_mode */ ;\n" .
"/*!50003 SET character_set_client = @saved_cs_client */ ;\n" .
"/*!50003 SET character_set_results = @saved_cs_results */ ;\n" .
"/*!50003 SET collation_connection = @saved_col_connection */ ;\n",
$createProcedure['Procedure'],
$createProcedure['character_set_client'],
$createProcedure['collation_connection'],
$createProcedure['sql_mode'],
$createProcedure['Create Procedure']
);
$this->write($sql);
} catch (mysqli_sql_exception $e) {
$this->logQueryError($e, $query);
}
}
$statusResult->close();
}
/**
* Dump triggers
*
* Dumps all triggers found in the database.
*/
protected function dump_triggers()
{
$query = sprintf('SHOW TRIGGERS FROM `%1$s`', $this->getDbName());
try {
$statusResult = $this->query($query);
} catch (\mysqli_sql_exception $e) {
$this->logQueryError($e, $query);
return;
}
while ($trigger = $statusResult->fetch_assoc()) {
$query = sprintf(
'SHOW CREATE TRIGGER `%1$s`.`%2$s`',
$this->getDbName(),
$trigger['Trigger']
);
try {
$createResult = $this->query($query);
$createTrigger = $createResult->fetch_assoc();
$createResult->close();
if ($createTrigger === null) {
continue;
}
$sql = sprintf(
"\n--\n" .
"-- Trigger structure for %1\$s\n" .
"--\n\n" .
"/*!50032 DROP TRIGGER IF EXISTS `%1\$s` */;\n" .
"/*!50003 SET @saved_cs_client = @@character_set_client */ ;\n" .
"/*!50003 SET @saved_cs_results = @@character_set_results */ ;\n" .
"/*!50003 SET @saved_col_connection = @@collation_connection */ ;\n" .
"/*!50003 SET character_set_client = %2\$s */ ;\n" .
"/*!50003 SET character_set_results = %2\$s */ ;\n" .
"/*!50003 SET collation_connection = %3\$s */ ;\n" .
"/*!50003 SET @saved_sql_mode = @@sql_mode */ ;\n" .
"/*!50003 SET sql_mode = '%4\$s' */ ;\n" .
"DELIMITER ;;\n" .
"/*!50003 %5\$s */;;\n" .
"DELIMITER ;\n" .
"/*!50003 SET sql_mode = @saved_sql_mode */ ;\n" .
"/*!50003 SET character_set_client = @saved_cs_client */ ;\n" .
"/*!50003 SET character_set_results = @saved_cs_results */ ;\n" .
"/*!50003 SET collation_connection = @saved_col_connection */ ;\n",
$createTrigger['Trigger'],
$createTrigger['character_set_client'],
$createTrigger['collation_connection'],
$createTrigger['sql_mode'],
$createTrigger['SQL Original Statement']
);
$this->write($sql);
} catch (\mysqli_sql_exception $e) {
$this->logQueryError($e, $query);
}
}
$statusResult->close();
}
/**
* Writes data to handle and compress
*
* @param $data string to write
* @throws BackWPup_MySQLDump_Exception
*/
protected function write( $data ) {
$written = fwrite( $this->handle, $data );
if ( ! $written )
throw new BackWPup_MySQLDump_Exception( __( 'Error while writing file!', 'backwpup' ) );
}
/**
* Closes all confections on shutdown.
*/
public function __destruct() {
//close MySQL connection
if ($this->mysqli !== null) {
$this->mysqli->close();
}
//close file handle
if ( is_resource( $this->handle ) )
fclose( $this->handle );
}
/**
* Get table type for given table
*
* @param string $table The table to look up the type for.
*
* @return string The table type if found
*/
protected function get_table_type_for( $table ) {
if ( isset( $this->table_types[ $table ] ) ) {
return $this->table_types[ $table ];
}
return null;
}
/**
* Perform query to fetch table rows
*
* @param string $table The table on which to perform the query
* @param int $start The record to start at
@param int $length How many records to fetch
*
* @return \mysqli_result The resulting query
* @throws \BackWPup_MySQLDump_Exception In case of mysql error
*/
protected function do_table_query( $table, $start, $length ) {
if ( $length == 0 && $start == 0 ) {
$res = $this->mysqli->query( "SELECT * FROM `" . $table . "` ", MYSQLI_USE_RESULT );
} else {
$res = $this->mysqli->query( "SELECT * FROM `" . $table . "` LIMIT " . $start . ", " . $length, MYSQLI_USE_RESULT );
}
$GLOBALS[ 'wpdb' ]->num_queries ++;
if ( $this->mysqli->error ) {
throw new BackWPup_MySQLDump_Exception( $this->mysqli->error );
}
return $res;
}
/**
* Escapes a string for MySQL
*
* @param string $value The value to escape
*
* @return string The escaped string
*/
protected function escapeString( $value ) {
return $this->mysqli->real_escape_string( $value );
}
}
/**
* Exception Handler
*/
class BackWPup_MySQLDump_Exception extends Exception { }