mirror of
https://github.com/YunoHost-Apps/piwigo_ynh.git
synced 2024-09-03 20:06:03 +02:00
421 lines
11 KiB
PHP
421 lines
11 KiB
PHP
|
<?php
|
|||
|
|
/**
|
|||
|
|
* Dump MySQL database
|
|||
|
|
*
|
|||
|
|
* Here is an inline example:
|
|||
|
|
* <code>
|
|||
|
|
* $connection = @mysql_connect($dbhost,$dbuser,$dbpsw);
|
|||
|
|
* $dumper = new MySQLDump($dbname,'filename.sql',false,false);
|
|||
|
|
* $dumper->doDump();
|
|||
|
|
* </code>
|
|||
|
|
*
|
|||
|
|
* Special thanks to:
|
|||
|
|
* - Andrea Ingaglio <andrea@coders4fun.com> helping in development of all class code
|
|||
|
|
* - Dylan Pugh for precious advices halfing the size of the output file and for helping in debug
|
|||
|
|
*
|
|||
|
|
* @name MySQLDump
|
|||
|
|
* @author Daniele Vigan<EFBFBD> - CreativeFactory.it <daniele.vigano@creativefactory.it>
|
|||
|
|
* @version 2.20 - 02/11/2007
|
|||
|
|
* @license http://opensource.org/licenses/gpl-license.php GNU Public License
|
|||
|
|
*/
|
|||
|
|
|
|||
|
|
class MySQLDump {
|
|||
|
|
/**
|
|||
|
|
* @access private
|
|||
|
|
*/
|
|||
|
|
var $database = null;
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* @access private
|
|||
|
|
*/
|
|||
|
|
var $compress = false;
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* @access private
|
|||
|
|
*/
|
|||
|
|
var $hexValue = false;
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* The output filename
|
|||
|
|
* @access private
|
|||
|
|
*/
|
|||
|
|
var $filename = null;
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* The pointer of the output file
|
|||
|
|
* @access private
|
|||
|
|
*/
|
|||
|
|
var $file = null;
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* @access private
|
|||
|
|
*/
|
|||
|
|
var $isWritten = false;
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Class constructor
|
|||
|
|
* @param string $db The database name
|
|||
|
|
* @param string $filepath The file where the dump will be written
|
|||
|
|
* @param boolean $compress It defines if the output file is compress (gzip) or not
|
|||
|
|
* @param boolean $hexValue It defines if the outup values are base-16 or not
|
|||
|
|
*/
|
|||
|
|
function MYSQLDump($db = null, $filepath = 'dump.sql', $compress = false, $hexValue = false){
|
|||
|
|
$this->compress = $compress;
|
|||
|
|
if ( !$this->setOutputFile($filepath) )
|
|||
|
|
return false;
|
|||
|
|
return $this->setDatabase($db);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Sets the database to work on
|
|||
|
|
* @param string $db The database name
|
|||
|
|
*/
|
|||
|
|
function setDatabase($db){
|
|||
|
|
$this->database = $db;
|
|||
|
|
if ( !@mysql_select_db($this->database) )
|
|||
|
|
return false;
|
|||
|
|
return true;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Returns the database where the class is working on
|
|||
|
|
* @return string
|
|||
|
|
*/
|
|||
|
|
function getDatabase(){
|
|||
|
|
return $this->database;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Sets the output file type (It can be made only if the file hasn't been already written)
|
|||
|
|
* @param boolean $compress If it's true, the output file will be compressed
|
|||
|
|
*/
|
|||
|
|
function setCompress($compress){
|
|||
|
|
if ( $this->isWritten )
|
|||
|
|
return false;
|
|||
|
|
$this->compress = $compress;
|
|||
|
|
$this->openFile($this->filename);
|
|||
|
|
return true;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Returns if the output file is or not compressed
|
|||
|
|
* @return boolean
|
|||
|
|
*/
|
|||
|
|
function getCompress(){
|
|||
|
|
return $this->compress;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Sets the output file
|
|||
|
|
* @param string $filepath The file where the dump will be written
|
|||
|
|
*/
|
|||
|
|
function setOutputFile($filepath){
|
|||
|
|
if ( $this->isWritten )
|
|||
|
|
return false;
|
|||
|
|
$this->filename = $filepath;
|
|||
|
|
$this->file = $this->openFile($this->filename);
|
|||
|
|
return $this->file;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Returns the output filename
|
|||
|
|
* @return string
|
|||
|
|
*/
|
|||
|
|
function getOutputFile(){
|
|||
|
|
return $this->filename;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Writes to file the $table's structure
|
|||
|
|
* @param string $table The table name
|
|||
|
|
*/
|
|||
|
|
function getTableStructure($table){
|
|||
|
|
if ( !$this->setDatabase($this->database) )
|
|||
|
|
return false;
|
|||
|
|
// Structure Header
|
|||
|
|
$structure = "-- \n";
|
|||
|
|
$structure .= "-- Table structure for table `{$table}` \n";
|
|||
|
|
$structure .= "-- \n\n";
|
|||
|
|
// Dump Structure
|
|||
|
|
$structure .= 'DROP TABLE IF EXISTS `'.$table.'`;'."\n";
|
|||
|
|
$structure .= "CREATE TABLE `".$table."` (\n";
|
|||
|
|
$records = @mysql_query('SHOW FIELDS FROM `'.$table.'`');
|
|||
|
|
if ( @mysql_num_rows($records) == 0 )
|
|||
|
|
return false;
|
|||
|
|
while ( $record = mysql_fetch_assoc($records) ) {
|
|||
|
|
$structure .= '`'.$record['Field'].'` '.$record['Type'];
|
|||
|
|
if ( isset($record['Default']) )
|
|||
|
|
$structure .= ' DEFAULT \''.$record['Default'].'\'';
|
|||
|
|
if ( @strcmp($record['Null'],'YES') != 0 )
|
|||
|
|
$structure .= ' NOT NULL';
|
|||
|
|
elseif ( is_null($record['Default']) )
|
|||
|
|
$structure .= ' DEFAULT NULL';
|
|||
|
|
if ( !empty($record['Extra']) )
|
|||
|
|
$structure .= ' '.$record['Extra'];
|
|||
|
|
$structure .= ",\n";
|
|||
|
|
}
|
|||
|
|
$structure = @ereg_replace(",\n$", null, $structure);
|
|||
|
|
|
|||
|
|
// Save all Column Indexes
|
|||
|
|
$structure .= $this->getSqlKeysTable($table);
|
|||
|
|
$structure .= "\n)";
|
|||
|
|
|
|||
|
|
//Save table engine
|
|||
|
|
$records = @mysql_query("SHOW TABLE STATUS LIKE '".$table."'");
|
|||
|
|
|
|||
|
|
if ( $record = @mysql_fetch_assoc($records) ) {
|
|||
|
|
if ( !empty($record['Engine']) )
|
|||
|
|
$structure .= ' ENGINE='.$record['Engine'];
|
|||
|
|
if ( !empty($record['Auto_increment']) )
|
|||
|
|
$structure .= ' AUTO_INCREMENT='.$record['Auto_increment'];
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
$structure .= ";\n\n-- --------------------------------------------------------\n\n";
|
|||
|
|
$this->saveToFile($this->file,$structure);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Writes to file the $table's data
|
|||
|
|
* @param string $table The table name
|
|||
|
|
* @param boolean $hexValue It defines if the output is base 16 or not
|
|||
|
|
*/
|
|||
|
|
function getTableData($table,$hexValue = true) {
|
|||
|
|
if ( !$this->setDatabase($this->database) )
|
|||
|
|
return false;
|
|||
|
|
// Header
|
|||
|
|
$data = "-- \n";
|
|||
|
|
$data .= "-- Dumping data for table `$table` \n";
|
|||
|
|
$data .= "-- \n\n";
|
|||
|
|
|
|||
|
|
$records = mysql_query('SHOW FIELDS FROM `'.$table.'`');
|
|||
|
|
$num_fields = @mysql_num_rows($records);
|
|||
|
|
if ( $num_fields == 0 )
|
|||
|
|
return false;
|
|||
|
|
// Field names
|
|||
|
|
$selectStatement = "SELECT ";
|
|||
|
|
$insertStatement = "INSERT INTO `$table` (";
|
|||
|
|
$hexField = array();
|
|||
|
|
for ($x = 0; $x < $num_fields; $x++) {
|
|||
|
|
$record = @mysql_fetch_assoc($records);
|
|||
|
|
if ( ($hexValue) && ($this->isTextValue($record['Type'])) ) {
|
|||
|
|
$selectStatement .= 'HEX(`'.$record['Field'].'`)';
|
|||
|
|
$hexField [$x] = true;
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
$selectStatement .= '`'.$record['Field'].'`';
|
|||
|
|
$insertStatement .= '`'.$record['Field'].'`';
|
|||
|
|
$insertStatement .= ", ";
|
|||
|
|
$selectStatement .= ", ";
|
|||
|
|
}
|
|||
|
|
$insertStatement = @substr($insertStatement,0,-2).') VALUES'."\n";
|
|||
|
|
$selectStatement = @substr($selectStatement,0,-2).' FROM `'.$table.'`';
|
|||
|
|
|
|||
|
|
$records = @mysql_query($selectStatement);
|
|||
|
|
$num_rows = @mysql_num_rows($records);
|
|||
|
|
$num_fields = @mysql_num_fields($records);
|
|||
|
|
// Dump data
|
|||
|
|
if ( $num_rows > 0 ) {
|
|||
|
|
$data .= $insertStatement;
|
|||
|
|
for ($i = 0; $i < $num_rows; $i++) {
|
|||
|
|
$record = @mysql_fetch_assoc($records);
|
|||
|
|
$data .= ' (';
|
|||
|
|
for ($j = 0; $j < $num_fields; $j++) {
|
|||
|
|
$field_name = @mysql_field_name($records, $j);
|
|||
|
|
if ( @$hexField[$j] && (@strlen($record[$field_name]) > 0) )
|
|||
|
|
$data .= "0x".$record[$field_name];
|
|||
|
|
elseif (is_null($record[$field_name]))
|
|||
|
|
$data .= "NULL";
|
|||
|
|
else
|
|||
|
|
$data .= "'".@str_replace('\"','"',@mysql_real_escape_string($record[$field_name]))."'";
|
|||
|
|
$data .= ',';
|
|||
|
|
}
|
|||
|
|
$data = @substr($data,0,-1).")";
|
|||
|
|
$data .= ( $i < ($num_rows-1) ) ? ',' : ';';
|
|||
|
|
$data .= "\n";
|
|||
|
|
//if data in greather than 1MB save
|
|||
|
|
if (strlen($data) > 1048576) {
|
|||
|
|
$this->saveToFile($this->file,$data);
|
|||
|
|
$data = '';
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
$data .= "\n-- --------------------------------------------------------\n\n";
|
|||
|
|
$this->saveToFile($this->file,$data);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Writes to file all the selected database tables structure
|
|||
|
|
* @return boolean
|
|||
|
|
*/
|
|||
|
|
function getDatabaseStructure(){
|
|||
|
|
$records = @mysql_query('SHOW TABLES');
|
|||
|
|
if ( @mysql_num_rows($records) == 0 )
|
|||
|
|
return false;
|
|||
|
|
$structure = '';
|
|||
|
|
while ( $record = @mysql_fetch_row($records) ) {
|
|||
|
|
$structure .= $this->getTableStructure($record[0]);
|
|||
|
|
}
|
|||
|
|
return true;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Writes to file all the selected database tables data
|
|||
|
|
* @param boolean $hexValue It defines if the output is base-16 or not
|
|||
|
|
*/
|
|||
|
|
function getDatabaseData($hexValue = true){
|
|||
|
|
$records = @mysql_query('SHOW TABLES');
|
|||
|
|
if ( @mysql_num_rows($records) == 0 )
|
|||
|
|
return false;
|
|||
|
|
while ( $record = @mysql_fetch_row($records) ) {
|
|||
|
|
$this->getTableData($record[0],$hexValue);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Writes to file the selected database dump
|
|||
|
|
*/
|
|||
|
|
function doDump() {
|
|||
|
|
$this->saveToFile($this->file,"SET FOREIGN_KEY_CHECKS = 0;\n\n");
|
|||
|
|
$this->getDatabaseStructure();
|
|||
|
|
$this->getDatabaseData($this->hexValue);
|
|||
|
|
$this->saveToFile($this->file,"SET FOREIGN_KEY_CHECKS = 1;\n\n");
|
|||
|
|
$this->closeFile($this->file);
|
|||
|
|
return true;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* @deprecated Look at the doDump() method
|
|||
|
|
*/
|
|||
|
|
function writeDump($filename) {
|
|||
|
|
if ( !$this->setOutputFile($filename) )
|
|||
|
|
return false;
|
|||
|
|
$this->doDump();
|
|||
|
|
$this->closeFile($this->file);
|
|||
|
|
return true;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* @access private
|
|||
|
|
*/
|
|||
|
|
function getSqlKeysTable ($table) {
|
|||
|
|
$primary = "";
|
|||
|
|
$unique = array();
|
|||
|
|
$index = array();
|
|||
|
|
$fulltext = array();
|
|||
|
|
$results = mysql_query("SHOW KEYS FROM `{$table}`");
|
|||
|
|
if ( @mysql_num_rows($results) == 0 )
|
|||
|
|
return false;
|
|||
|
|
while($row = mysql_fetch_object($results)) {
|
|||
|
|
if (($row->Key_name == 'PRIMARY') AND ($row->Index_type == 'BTREE')) {
|
|||
|
|
if ( $primary == "" )
|
|||
|
|
$primary = " PRIMARY KEY (`{$row->Column_name}`";
|
|||
|
|
else
|
|||
|
|
$primary .= ", `{$row->Column_name}`";
|
|||
|
|
}
|
|||
|
|
if (($row->Key_name != 'PRIMARY') AND ($row->Non_unique == '0') AND ($row->Index_type == 'BTREE')) {
|
|||
|
|
if ( (empty($unique)) OR (empty($unique[$row->Key_name])) )
|
|||
|
|
$unique[$row->Key_name] = " UNIQUE KEY `{$row->Key_name}` (`{$row->Column_name}`";
|
|||
|
|
else
|
|||
|
|
$unique[$row->Key_name] .= ", `{$row->Column_name}`";
|
|||
|
|
}
|
|||
|
|
if (($row->Key_name != 'PRIMARY') AND ($row->Non_unique == '1') AND ($row->Index_type == 'BTREE')) {
|
|||
|
|
if ( (empty($index)) OR (empty($index[$row->Key_name])) )
|
|||
|
|
$index[$row->Key_name] = " KEY `{$row->Key_name}` (`{$row->Column_name}`";
|
|||
|
|
else
|
|||
|
|
$index[$row->Key_name] .= ", `{$row->Column_name}`";
|
|||
|
|
}
|
|||
|
|
if (($row->Key_name != 'PRIMARY') AND ($row->Non_unique == '1') AND ($row->Index_type == 'FULLTEXT')) {
|
|||
|
|
if ( (empty($fulltext)) OR (empty($fulltext[$row->Key_name])) )
|
|||
|
|
$fulltext[$row->Key_name] = " FULLTEXT `{$row->Key_name}` (`{$row->Column_name}`";
|
|||
|
|
else
|
|||
|
|
$fulltext[$row->Key_name] .= ", `{$row->Column_name}`";
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
$sqlKeyStatement = '';
|
|||
|
|
// generate primary, unique, key and fulltext
|
|||
|
|
if ( $primary != "" ) {
|
|||
|
|
$sqlKeyStatement .= ",\n";
|
|||
|
|
$primary .= ")";
|
|||
|
|
$sqlKeyStatement .= $primary;
|
|||
|
|
}
|
|||
|
|
if (!empty($unique)) {
|
|||
|
|
foreach ($unique as $keyName => $keyDef) {
|
|||
|
|
$sqlKeyStatement .= ",\n";
|
|||
|
|
$keyDef .= ")";
|
|||
|
|
$sqlKeyStatement .= $keyDef;
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
if (!empty($index)) {
|
|||
|
|
foreach ($index as $keyName => $keyDef) {
|
|||
|
|
$sqlKeyStatement .= ",\n";
|
|||
|
|
$keyDef .= ")";
|
|||
|
|
$sqlKeyStatement .= $keyDef;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
if (!empty($fulltext)) {
|
|||
|
|
foreach ($fulltext as $keyName => $keyDef) {
|
|||
|
|
$sqlKeyStatement .= ",\n";
|
|||
|
|
$keyDef .= ")";
|
|||
|
|
$sqlKeyStatement .= $keyDef;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
return $sqlKeyStatement;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* @access private
|
|||
|
|
*/
|
|||
|
|
function isTextValue($field_type) {
|
|||
|
|
switch ($field_type) {
|
|||
|
|
case "tinytext":
|
|||
|
|
case "text":
|
|||
|
|
case "mediumtext":
|
|||
|
|
case "longtext":
|
|||
|
|
case "binary":
|
|||
|
|
case "varbinary":
|
|||
|
|
case "tinyblob":
|
|||
|
|
case "blob":
|
|||
|
|
case "mediumblob":
|
|||
|
|
case "longblob":
|
|||
|
|
return True;
|
|||
|
|
break;
|
|||
|
|
default:
|
|||
|
|
return False;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* @access private
|
|||
|
|
*/
|
|||
|
|
function openFile($filename) {
|
|||
|
|
$file = false;
|
|||
|
|
if ( $this->compress )
|
|||
|
|
$file = @gzopen($filename, "w9");
|
|||
|
|
else
|
|||
|
|
$file = @fopen($filename, "w");
|
|||
|
|
return $file;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* @access private
|
|||
|
|
*/
|
|||
|
|
function saveToFile($file, $data) {
|
|||
|
|
if ( $this->compress )
|
|||
|
|
@gzwrite($file, $data);
|
|||
|
|
else
|
|||
|
|
@fwrite($file, $data);
|
|||
|
|
$this->isWritten = true;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* @access private
|
|||
|
|
*/
|
|||
|
|
function closeFile($file) {
|
|||
|
|
if ( $this->compress )
|
|||
|
|
@gzclose($file);
|
|||
|
|
else
|
|||
|
|
@fclose($file);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
?>
|