admin/db/maintenance_db.inc

   1 <?php
   2
   3 function write_config_db($new = false)
   4 {
   5         global $path_to_root, $def_coy, $db_connections, $tb_pref_counter;
   6         include_once($path_to_root . "/config_db.php");
   7
   8         if ($new)
   9                 $tb_pref_counter++;
  10         $n = count($db_connections);
  11         $msg = "<?php\n\n";
  12         $msg .= "/*Connection Information for the database\n";
  13         $msg .= "- \$def_coy is the default company that is pre-selected on login\n\n";
  14         $msg .= "- host is the computer ip address or name where the database is the default is localhost assuming that the web server is also the sql server\n\n";
  15         $msg .= "- user is the user name under which the database should be accessed - need to change to the mysql (or other DB) user set up for purpose\n";
  16         $msg .= "  NB it is not secure to use root as the user with no password - a user with appropriate privileges must be set up\n\n";
  17         $msg .= "- password is the password the user of the database requires to be sent to authorise the above database user\n\n";
  18         $msg .= "- DatabaseName is the name of the database as defined in the RDMS being used. Typically RDMS allow many databases to be maintained under the same server.\n";
  19         $msg .= "  The scripts for MySQL provided use the name logicworks */\n\n\n";
  20
  21         $msg .= "\$def_coy = " . $def_coy . ";\n\n";
  22         $msg .= "\$tb_pref_counter = " . $tb_pref_counter . ";\n\n";
  23         $msg .= "\$db_connections = array (\n";
  24         $msg .= "\t0 => ";
  25         for ($i = 0; $i < $n; $i++)
  26         {
  27                 if ($i > 0)
  28                         $msg .= "\tarray ";
  29                 else
  30                         $msg .= "array ";
  31                 $msg .= "('name' => '" . $db_connections[$i]['name'] . "',\n";
  32                 $msg .= "\t\t'host' => '" . $db_connections[$i]['host'] . "',\n";
  33                 $msg .= "\t\t'dbuser' => '" . $db_connections[$i]['dbuser'] . "',\n";
  34                 $msg .= "\t\t'dbpassword' => '" . $db_connections[$i]['dbpassword'] . "',\n";
  35                 $msg .= "\t\t'dbname' => '" . $db_connections[$i]['dbname'] . "',\n";
  36                 $msg .= "\t\t'tbpref' => '" . $db_connections[$i]['tbpref'] . "')";
  37                 if ($i != $n - 1)
  38                         $msg .= ",";
  39                 $msg .= "\n\n";
  40         }
  41         $msg .= "\t);\n?>";
  42
  43         $filename = $path_to_root . "/config_db.php";
  44         // Check if the file exists and is writable first.
  45         if (file_exists($filename) && is_writable($filename))
  46         {
  47                 if (!$zp = fopen($filename, 'w'))
  48                 {
  49                         return -1;
  50                 }
  51                 else
  52                 {
  53                         if (!fwrite($zp, $msg))
  54                         {
  55                                 fclose($zp);
  56                                 return -2;
  57                         }
  58                         // Close file
  59                         fclose($zp);
  60                 }
  61         }
  62         else
  63         {
  64                 return -3;
  65         }
  66         return 0;
  67 }
  68
  69 function db_create_db($connection)
  70 {
  71         $db = mysql_connect($connection["host"] ,
  72                 $connection["dbuser"], $connection["dbpassword"]);
  73         if (!mysql_select_db($connection["dbname"], $db))
  74         {
  75                 $sql = "CREATE DATABASE " . $connection["dbname"] . "";
  76                 if (!mysql_query($sql))
  77                         return 0;
  78                 mysql_select_db($connection["dbname"], $db);
  79         }
  80         return $db;
  81 }
  82
  83 function db_drop_db($connection)
  84 {
  85         if ($connection["tbpref"] == "")
  86         {
  87                 $sql = "DROP DATABASE " . $connection["dbname"] . "";
  88                 return mysql_query($sql);
  89         }
  90         else
  91         {
  92         $res = db_query("show table status");
  93         $all_tables = array();
  94         while($row = db_fetch($res))
  95                 $all_tables[] = $row;
  96         // get table structures
  97                 foreach ($all_tables as $table)
  98                 {
  99                         if (strpos($table['Name'], $connection["tbpref"]) === 0)
 100                                 db_query("DROP TABLE `".$table['Name'] . "`");
 101                 }
 102                 //deleting the tables, how??
 103                 return true;
 104         }
 105 }
 106
 107 function db_import($filename, $connection)
 108 {
 109         $data_queries = array();
 110         $drop_queries = array();
 111         $table_queries = array();
 112
 113         // uncrompress gziped backup files
 114         if (strpos($filename, ".gzip") || strpos($filename, ".GZIP"))
 115                 $lines = db_ungzip("lines", $filename);
 116         elseif (strpos($filename, ".zip") || strpos($filename, ".ZIP"))
 117                 $lines = db_unzip("lines", $filename);
 118         else
 119                 $lines = file("". $filename);
 120
 121         // divide insert and create sql queries
 122         // $table is set to TRUE if the next line belongs to a create sql query
 123         $table = false;
 124         foreach($lines as $line)
 125         {
 126                 $line = trim($line);
 127
 128                 $line = str_replace("0_", $connection["tbpref"], $line);
 129                 // $line = str_replace("Y_", "0_", $line);
 130                 // the last line did not belong to a 'create' sql query
 131                 if (!$table)
 132                 {
 133
 134                         // this line does not, too
 135                         if (strtolower(substr($line,0,6)) == "insert")
 136                         {
 137                                 $data_queries[] = substr($line, 0, strlen($line) - 1);
 138
 139                         // this line does not, too
 140                         }
 141                         elseif (strtolower(substr($line,0,6)) == "update")
 142                         {
 143                                 $data_queries[] = substr($line, 0, strlen($line) - 1);
 144
 145                         // this line does not, too
 146                         }
 147                         elseif (strtolower(substr($line, 0, 20)) == "drop table if exists")
 148                         {
 149                                 $drop_queries[] = substr($line, 0, strlen($line) - 1);
 150
 151                         // this line does!
 152                         }
 153                         elseif (strtolower(substr($line, 0, 6)) == "create")
 154                         {
 155                                 $table = true;
 156                                 $table_queries[] = $line . "\n";
 157                         }
 158                         elseif (strtolower(substr($line, 0, 11)) == "alter table")
 159                         {
 160                                 $data_queries[] = substr($line, 0, strlen($line) - 1);
 161                         }
 162
 163                 // the current line belongs to a create sql query
 164                 }
 165                 else
 166                 {
 167
 168                         // create sql query ending in this line
 169                         if (strtolower(substr($line, 0, 1)) == ")") {
 170                                 $table = false;
 171                                 $line = substr($line,0,strlen($line)-1);
 172                   }
 173                         $table_queries[count($table_queries) - 1] .= $line . "\n";
 174                 }
 175         }
 176
 177         $sql_error = false;
 178
 179         // execute drop tables if exists queries
 180         if (is_array($drop_queries))
 181         {
 182                 foreach($drop_queries as $drop_query)
 183                 {
 184                         $sql_error = false;
 185                         if (!db_query($drop_query))
 186                         {
 187                                 $sql_error = true;
 188                                 //if ($CONF['import_error']) echo nl2br($drop_query)."\n<div class=\"bold_left\">".mysql_error()."</div><br>\n";
 189                         }
 190                 }
 191         }
 192
 193         // execute create tables queries
 194         if (is_array($table_queries))
 195         {
 196                 foreach($table_queries as $table_query)
 197                 {
 198                         $sql_error = false;
 199                         if (!db_query($table_query))
 200                         {
 201                                 $sql_error = true;
 202                                 //if ($CONF['import_error']) echo nl2br($table_query)."\n<div class=\"bold_left\">".mysql_error()."</div><br>\n";
 203                         }
 204                 }
 205         }
 206
 207         // execute insert data queries
 208         if (is_array($data_queries))
 209         {
 210                 foreach($data_queries as $data_query)
 211                 {
 212                         $sql_error = false;
 213                         if (!db_query($data_query))
 214                         {
 215                                 //if ($CONF['import_error']) echo $data_query."\n<div class=\"bold_left\">".mysql_error()."</div><br>\n";
 216                                 $sql_error = true;
 217                                 return false;
 218                         }
 219                 }
 220         }
 221
 222         // show number successful executed querys or if an error did occur
 223         if ($sql_error == 1)
 224                 return false;
 225                 //echo "<div class=\"red\">".IM_ERROR.".</div>\n";
 226         else
 227                 return true;
 228                 //echo "<div class=\"green\">".IM_SUCCESS." ".count($table_queries)." ".IM_TABLES." ".count($data_queries)." ".IM_ROWS." (".$import_file.")</div>\n";
 229         //$shell_command = C_MYSQL_PATH . " -h $host -u $user -p{$password} $dbname < $filename";
 230         //shell_exec($shell_command);
 231 }
 232
 233 // returns the content of the gziped $path backup file. use of $mode see below
 234 function db_ungzip($mode, $path)
 235 {
 236     $file_data = gzfile($path);
 237     // returns one string or an array of lines
 238     if ($mode != "lines")
 239         return implode("",$file_data);
 240     else
 241         return $file_data;
 242 }
 243
 244 // returns the content of the ziped $path backup file. use of $mode see below
 245 function db_unzip($mode, $path)
 246 {
 247     $all = false;
 248     $all = implode("", file($path));
 249
 250     // convert path to name of ziped file
 251     $filename = ereg_replace(".*/", "", $path);
 252     $filename = substr($filename, 0, strlen($filename) - 4);
 253
 254     // compare filname in zip and filename from $_GET
 255     if (substr($all, 30, strlen($filename)) != $filename)
 256     {
 257                 return '';
 258         // exit if names differ
 259         //echo F_WRONG_FILE.".";
 260         //exit;
 261     }
 262     else
 263     {
 264         // get the suffix of the filename in hex
 265         $crc_bugfix = substr(substr($filename, 0, strlen($filename) - 4), strlen($filename) - 12 - 4);
 266         $suffix = false;
 267
 268         // convert hex to ascii
 269         for ($i=0; $i < 12; )
 270                 $suffix .= chr($crc_bugfix[$i++] . $crc_bugfix[$i++] . $crc_bugfix[$i++]);
 271
 272         // remove central directory information (we have always just one ziped file)
 273         $comp = substr($all, -(strlen($all) - 30 - strlen($filename)));
 274         $comp = substr($comp, 0, (strlen($comp) - 80 - strlen($filename)));
 275
 276         // fix the crc bugfix (see function save_to_file)
 277         $comp = "x\9c" . $comp . $suffix;
 278         $file_data = gzuncompress($comp);
 279     }
 280
 281     // returns one string or an array of lines
 282     if ($mode != "lines")
 283         return $file_data;
 284     else
 285         return explode("\n", $file_data);
 286 }
 287
 288 // generates a dump of $db database
 289 // $drop and $zip tell if to include the drop table statement or dry to pack
 290 function db_export($conn, $filename, $zip='no', $comment='')
 291 {
 292
 293         global $app_title, $version, $power_url, $path_to_root;
 294
 295     $error = false;
 296
 297     // set max string size before writing to file
 298     $max_size = 1048576 * 2; // 2 MB
 299     // changes max size if value can be retrieved
 300     if (ini_get("memory_limit"))
 301         $max_size = 900000 * ini_get("memory_limit");
 302
 303     // set backupfile name
 304     if ($zip == "gzip")
 305         $backupfile = $filename . ".gz";
 306     elseif ($zip == "zip")
 307         $backupfile = $filename . ".zip";
 308     else
 309         $backupfile = $filename;
 310     $company = get_company_pref('coy_name');
 311     //create comment
 312     $out="# MySQL dump of database '".$conn["dbname"]."' on host '".$conn["host"]."'\n";
 313     $out.="# Backup Date and Time: ".date("Y-m-d H:i")."\n";
 314     $out.="# Built by " . $app_title . " " . $version ."\n";
 315     $out.="# ".$power_url."\n";
 316     $out.="# Company: ".$company."\n";
 317     $out.="# User: ".$_SESSION["wa_current_user"]->name."\n\n";
 318
 319         // write users comment
 320         if ($comment)
 321         {
 322                 $out .= "# Comment:\n";
 323                 $comment=preg_replace("'\n'","\n# ","# ".$comment);
 324                 //$comment=str_replace("\n", "\n# ", $comment);
 325                 foreach(explode("\n",$comment) as $line)
 326                         $out .= $line."\n";
 327                 $out.="\n";
 328         }
 329
 330     //$out.="use ".$db.";\n"; we don't use this option.
 331
 332     // get auto_increment values and names of all tables
 333     $res = db_query("show table status");
 334     $all_tables = array();
 335     while($row = db_fetch($res))
 336     {
 337                 //if ($conn["tbpref"] == "" || strpos($row['Name'], $conn["tbpref"]) !== false) replaced
 338                 if (($conn["tbpref"] == "" && !preg_match('/[0-9]+_/', $row['Name'])) ||
 339                         ($conn["tbpref"] != "" && strpos($row['Name'], $conn["tbpref"]) !== false))
 340                 $all_tables[] = $row;
 341     }
 342         // get table structures
 343         foreach ($all_tables as $table)
 344         {
 345                 $res1 = db_query("SHOW CREATE TABLE `" . $table['Name'] . "`");
 346                 $tmp = db_fetch($res1);
 347                 $table_sql[$table['Name']] = $tmp["Create Table"];
 348         }
 349
 350         // find foreign keys
 351         $fks = array();
 352         if (isset($table_sql))
 353         {
 354                 foreach($table_sql as $tablenme=>$table)
 355                 {
 356                         $tmp_table=$table;
 357                         // save all tables, needed for creating this table in $fks
 358                         while (($ref_pos = strpos($tmp_table, " REFERENCES ")) > 0)
 359                         {
 360                                 $tmp_table = substr($tmp_table, $ref_pos + 12);
 361                                 $ref_pos = strpos($tmp_table, "(");
 362                                 $fks[$tablenme][] = substr($tmp_table, 0, $ref_pos);
 363                         }
 364                 }
 365         }
 366         // order $all_tables
 367         $all_tables = order_sql_tables($all_tables, $fks);
 368
 369         // as long as no error occurred
 370         if (!$error)
 371         {
 372                 //while($row=@mysql_fetch_array($res))
 373                 foreach ($all_tables as $row)
 374                 {
 375                         $tablename = $row['Name'];
 376                         $auto_incr[$tablename] = $row['Auto_increment'];
 377
 378                         $out.="\n\n";
 379                         // export tables
 380                         $out.="### Structure of table `".$tablename."` ###\n\n";
 381
 382                         $out.="DROP TABLE IF EXISTS `".$tablename."`;\n\n";
 383                         $out.=$table_sql[$tablename];
 384
 385                         // add auto_increment value
 386                         if ($auto_incr[$tablename])
 387                                 $out.=" AUTO_INCREMENT=".$auto_incr[$tablename];
 388                         $out.=" ;";
 389                         $out.="\n\n\n";
 390
 391                         // export data
 392                         if (!$error)
 393                         {
 394                                 $out.="### Data of table `".$tablename."` ###\n\n";
 395
 396                                 // check if field types are NULL or NOT NULL
 397                                 $res3 = db_query("SHOW COLUMNS FROM `" . $tablename . "`");
 398
 399                                 $field_type = array();
 400                                 for ($j = 0; $j < db_num_rows($res3); $j++)
 401                                 {
 402                                         $row3 = db_fetch($res3);
 403                                         $field_type[] = $row3[2];
 404                                 }
 405
 406                                 $res2 = db_query("SELECT * FROM `" . $tablename . "`");
 407                                 for ($j = 0; $j < db_num_rows($res2); $j++)
 408                                 {
 409                                         $out .= "INSERT INTO `" . $tablename . "` VALUES (";
 410                                         $row2 = db_fetch_row($res2);
 411                                         // run through each field
 412                                         for ($k = 0; $k < $nf = db_num_fields($res2); $k++)
 413                                         {
 414                                                 // identify null values and save them as null instead of ''
 415                                                 if ($field_type[$k] != "" && $field_type[$k] != "NO" && $row2[$k] == "")
 416                                                         $out .= "NULL";
 417                                                 else
 418                                                         $out .= "'" . db_escape($row2[$k]) . "'";
 419                                                 if ($k < ($nf - 1))
 420                                                         $out .= ", ";
 421                                         }
 422                                         $out .= ");\n";
 423
 424                                         // if saving is successful, then empty $out, else set error flag
 425                                         if (strlen($out) > $max_size && $zip != "zip")
 426                                         {
 427                                                 if (save_to_file($backupfile, $zip, $out))
 428                                                         $out = "";
 429                                                 else
 430                                                         $error = true;
 431                                         }
 432                                 }
 433
 434                         // an error occurred! Try to delete file and return error status
 435                         }
 436                         elseif ($error)
 437                         {
 438                                 @unlink(BACKUP_PATH . $backupfile);
 439                                 return false;
 440                         }
 441
 442                         // if saving is successful, then empty $out, else set error flag
 443                         if (strlen($out) > $max_size && $zip != "zip")
 444                         {
 445                                 if (save_to_file($backupfile, $zip, $out))
 446                                         $out= "";
 447                                 else
 448                                         $error = true;
 449                         }
 450                 }
 451
 452         // an error occurred! Try to delete file and return error status
 453         }
 454         else
 455         {
 456                 @unlink(BACKUP_PATH . $backupfile);
 457                 return false;
 458         }
 459
 460         // if (mysql_error()) return "DB_ERROR";
 461         //@mysql_close($con);
 462
 463         //if ($zip == "zip")
 464         //      $zip = $time;
 465         if (save_to_file($backupfile, $zip, $out))
 466         {
 467                 $out = "";
 468         }
 469         else
 470         {
 471                 @unlink(BACKUP_PATH . $backupfile);
 472                 return false;
 473         }
 474     return $backupfile;
 475 }
 476
 477 // orders the tables in $tables according to the constraints in $fks
 478 // $fks musst be filled like this: $fks[tablename][0]=needed_table1; $fks[tablename][1]=needed_table2; ...
 479 function order_sql_tables($tables, $fks)
 480 {
 481         // do not order if no contraints exist
 482         if (!count($fks))
 483                 return $tables;
 484
 485         // order
 486         $new_tables = array();
 487         $existing = array();
 488         $modified = true;
 489         while (count($tables) && $modified == true)
 490         {
 491                 $modified = false;
 492             foreach ($tables as $key=>$row)
 493             {
 494                 // delete from $tables and add to $new_tables
 495                 if (isset($fks[$row['Name']]))
 496                 {
 497                         foreach($fks[$row['Name']] as $needed)
 498                         {
 499                         // go to next table if not all needed tables exist in $existing
 500                         if (!in_array($needed,$existing))
 501                                 continue 2;
 502                     }
 503                 }
 504             // delete from $tables and add to $new_tables
 505                 $existing[] = $row['Name'];
 506                         $new_tables[] = $row;
 507             prev($tables);
 508             unset($tables[$key]);
 509             $modified = true;
 510
 511             }
 512         }
 513
 514         if (count($tables))
 515         {
 516             // probably there are 'circles' in the constraints, bacause of that no proper backups can be created yet
 517             // TODO: this will be fixed sometime later through using 'alter table' commands to add the constraints after generating the tables
 518             // until now, just add the lasting tables to $new_tables, return them and print a warning
 519             foreach($tables as $row)
 520                 $new_tables[] = $row;
 521             echo "<div class=\"red_left\">THIS DATABASE SEEMS TO CONTAIN 'RING CONSTRAINTS'. WA DOES NOT SUPPORT THEM. PROBABLY THE FOLOWING BACKUP IS DEFECT!</div>";
 522         }
 523         return $new_tables;
 524 }
 525
 526 // saves the string in $fileData to the file $backupfile as gz file or not ($zip)
 527 // returns backup file name if name has changed (zip), else TRUE. If saving failed, return value is FALSE
 528 function save_to_file($backupfile, $zip, $fileData)
 529 {
 530         global $path_to_root;
 531
 532     if ($zip == "gzip")
 533     {
 534         if ($zp = @gzopen(BACKUP_PATH . $backupfile, "a9"))
 535         {
 536                         @gzwrite($zp, $fileData);
 537                         @gzclose($zp);
 538                         return true;
 539         }
 540         else
 541         {
 542                 return false;
 543         }
 544
 545     // $zip contains the timestamp
 546     }
 547     elseif ($zip == "zip")
 548     {
 549         // based on zip.lib.php 2.2 from phpMyBackupAdmin
 550         // offical zip format: http://www.pkware.com/appnote.txt
 551
 552         // End of central directory record
 553         $eof_ctrl_dir = "\x50\x4b\x05\x06\x00\x00\x00\x00";
 554
 555         // "local file header" segment
 556         $unc_len = strlen($fileData);
 557         $crc = crc32($fileData);
 558         $zdata = gzcompress($fileData);
 559
 560         // string needed for decoding (because of crc bug)
 561         //$name_suffix = substr($zdata, -4, 4);
 562         //$name_suffix2 = "_";
 563         //for ($i = 0; $i < 4; $i++)
 564         //      $name_suffix2 .= sprintf("%03d", ord($name_suffix[$i]));
 565         //$backupfile = substr($backupfile, 0, strlen($backupfile) - 8) . $name_suffix2 . ".sql.zip";
 566         $name = substr($backupfile, 0, strlen($backupfile) -4);
 567
 568         // fix crc bug
 569         $zdata = substr(substr($zdata, 0, strlen($zdata) - 4), 2);
 570         $c_len = strlen($zdata);
 571
 572         // dos time
 573         $timearray = getdate($zip);
 574         $dostime = (($timearray['year'] - 1980) << 25) | ($timearray['mon'] << 21) | ($timearray['mday'] << 16) |
 575             ($timearray['hours'] << 11) | ($timearray['minutes'] << 5) | ($timearray['seconds'] >> 1);
 576         $dtime = dechex($dostime);
 577         $hexdtime = "\x" . $dtime[6] . $dtime[7] . "\x" . $dtime[4].$dtime[5] . "\x" . $dtime[2] . $dtime[3] . "\x" . $dtime[0] . $dtime[1];
 578         eval('$hexdtime="' . $hexdtime . '";');
 579
 580         // ver needed to extract, gen purpose bit flag, compression method, last mod time and date
 581         $sub1 = "\x14\x00" . "\x00\x00" . "\x08\x00" . $hexdtime;
 582
 583         // crc32, compressed filesize, uncompressed filesize
 584         $sub2 = pack('V', $crc) . pack('V', $c_len) . pack('V', $unc_len);
 585
 586         $fr = "\x50\x4b\x03\x04" . $sub1. $sub2;
 587
 588         // length of filename, extra field length
 589         $fr .= pack('v', strlen($name)) . pack('v', 0);
 590         $fr .= $name;
 591
 592         // "file data" segment and "data descriptor" segment (optional but necessary if archive is not served as file)
 593         $fr .= $zdata . $sub2;
 594
 595         // now add to central directory record
 596         $cdrec = "\x50\x4b\x01\x02";
 597         $cdrec .= "\x00\x00";                // version made by
 598         $cdrec .= $sub1 . $sub2;
 599
 600          // length of filename, extra field length, file comment length, disk number start, internal file attributes, external file attributes - 'archive' bit set, offset
 601         $cdrec .= pack('v', strlen($name)) . pack('v', 0) . pack('v', 0) . pack('v', 0) . pack('v', 0) . pack('V', 32) . pack('V',0);
 602         $cdrec .= $name;
 603
 604         // combine data
 605         $fileData = $fr . $cdrec . $eof_ctrl_dir;
 606
 607         // total # of entries "on this disk", total # of entries overall, size of central dir, offset to start of central dir, .zip file comment length
 608         $fileData .= pack('v', 1) . pack('v', 1) . pack('V', strlen($cdrec)) . pack('V', strlen($fr)) . "\x00\x00";
 609
 610         if ($zp = @fopen(BACKUP_PATH . $backupfile, "a"))
 611         {
 612                         @fwrite($zp, $fileData);
 613                         @fclose($zp);
 614                         return true;
 615         }
 616         else
 617         {
 618                 return false;
 619         }
 620
 621         // uncompressed
 622     }
 623     else
 624     {
 625         if ($zp = @fopen(BACKUP_PATH . $backupfile, "a"))
 626         {
 627                         @fwrite($zp, $fileData);
 628                         @fclose($zp);
 629                         return true;
 630         }
 631         else
 632         {
 633                 return false;
 634         }
 635     }
 636 }
 637
 638
 639 ?>