www.gusucode.com > ShopEx481 & PHPWind 整合版码程序 > core/lib/mysqldumper.class.php
<?php
/**
* MySQLdumper is a small PHP class that lets you generate a dump of a MySQL database
* with just 2 lines of code. The dump can be used as a database backup. The dump
* is a valid MySQL-query in plain text. It doesn't depend on the 'mysqldump' command
* line utility, so you won't encounter a problem if this isn't available on the server.
*
* Example 1: Create a database drump.
* <code>
* $dumper = new MysqlDumper("localhost", "user", "password", "databasename");
* $dumpstring = $dumper->createDump();
* </code>
*
* Example 2: Create a database drump with a 'DROP TABLE IF EXISTS'-statement for each table.
* <code>
* $dumper = new MysqlDumper("localhost", "user", "password", "databasename");
* $dumper->setDroptables(true);
* $dumpstring = $dumper->createDump();
* </code>
*
* Example 3: Create dumps of different databases.
* <code>
* $dumper = new MysqlDumper("localhost", "user", "password", "database1");
* $dumpstring1 = $dumper->createDump();
* $dumper->setDBname"("database2");
* $dumpstring2 = $dumper->createDump();
* </code>
*
* @package MySQLdumper
* @version 1.0
* @author Dennis Mozes <opensource@mosix.nl>
* @url http://www.mosix.nl/mysqldumper
* @since PHP 4.0
* @copyright Dennis Mozes
* @license GNU/LGPL License: http://www.gnu.org/copyleft/lgpl.html
**/
define('MYSQL_CHARSET_NAME','utf8');
class Mysqldumper {
var $_host;
var $_dbuser;
var $_dbpassword;
var $_dbname;
var $_isDroptables;
var $tableid; //数据表ID
var $startid;
function Mysqldumper($host = "localhost", $dbuser = "", $dbpassword = "", $dbname = "") {
$this->setHost($host);
$this->setDBuser($dbuser);
$this->setDBpassword($dbpassword);
$this->setDBname($dbname);
// Don't drop tables by default.
$this->setDroptables(false);
}
function setHost($host) {
$this->_host = $host;
}
function getHost() {
return $this->_host;
}
function setDBname($dbname) {
$this->_dbname = $dbname;
}
function getDBname() {
return $this->_dbname;
}
function getDBuser() {
return $this->_dbuser;
}
function setDBpassword($dbpassword) {
$this->_dbpassword = $dbpassword;
}
function getDBpassword() {
return $this->_dbpassword;
}
function setDBuser($dbuser) {
$this->_dbuser = $dbuser;
}
// If set to true, it will generate 'DROP TABLE IF EXISTS'-statements for each table.
function setDroptables($state) {
$this->_isDroptables = $state;
}
function isDroptables() {
return $this->_isDroptables;
}
function multiDump($filename,$fileid,$sizelimit,$backdir,$ignoreList=null) {
// Set line feed
$ret = true;
$lf = "\r\n";
$lencount = 0;
$bakfile = $backdir."/multibak_".$filename."_".($fileid+1).".sql";
if($ignoreList){
$ignoreList = array_flip($ignoreList);
}
$fw = @fopen($bakfile, "wb");
if(!$fw) exit("备份目录{$backdir}不可写");
$resource = mysql_connect($this->getHost(), $this->getDBuser(), $this->getDBpassword(),true);
mysql_select_db($this->getDbname(), $resource);
if(!defined("DB_OLDVERSION")||!DB_OLDVERSION)
mysql_query("SET NAMES '".MYSQL_CHARSET_NAME."'",$resource);
$result = mysql_query("SHOW TABLES");
$tables = $this->result2Array(0, $result);
foreach ($tables as $tblval) {
if(substr($tblval,0,strlen(DB_PREFIX))==DB_PREFIX)
$tablearr[] = $tblval;
}
// Set header
fwrite($fw, "#". $lf);
fwrite($fw, "# SHOPEX SQL MultiVolumn Dump ID:".($fileid+1) . $lf);
fwrite($fw, "# Version ". $GLOBALS['SHOPEX_THIS_VERSION']. $lf);
fwrite($fw, "# ". $lf);
fwrite($fw, "# Host: " . $this->getHost() . $lf);
fwrite($fw, "# Server version: ". mysql_get_server_info() . $lf);
fwrite($fw, "# PHP Version: " . phpversion() . $lf);
fwrite($fw, "# Database : `" . $this->getDBname() . "`" . $lf);
fwrite($fw, "#");
// Generate dumptext for the tables.
$i=0;
for($j=$this->tableid;$j<count($tablearr);$j++){
$tblval = $tablearr[$j];
$table_prefix = (defined('DB_PREFIX'))?DB_PREFIX:'';
$subname = substr($tblval,strlen($table_prefix));
$written_tbname = '{shopexdump_table_prefix}'.$subname;
if($this->startid ==-1)
{
fwrite($fw, $lf . $lf . "# --------------------------------------------------------" . $lf . $lf);
$lencount += strlen($lf . $lf . "# --------------------------------------------------------" . $lf . $lf);
fwrite($fw, "#". $lf . "# Table structure for table `$tblval`" . $lf);
$lencount += strlen("#". $lf . "# Table structure for table `$tblval`" . $lf);
fwrite($fw, "#" . $lf . $lf);
$lencount += strlen("#". $lf . "# Table structure for table `$tblval`" . $lf);
// Generate DROP TABLE statement when client wants it to.
mysql_query("ALTER TABLE `$tblval` comment ''");
if($this->isDroptables()) {
fwrite($fw, "DROP TABLE IF EXISTS `$written_tbname`;" . $lf);
$lencount += strlen("DROP TABLE IF EXISTS `$written_tbname`;" . $lf);
}
$result = mysql_query("SHOW CREATE TABLE `$tblval`");
$createtable = $this->result2Array(1, $result);
$tmp_value = str_replace("\n", '', $this->formatcreate($createtable[0]));
$pos = strpos($tmp_value,$tblval);
$tmp_value = substr($tmp_value,0,$pos).$written_tbname.substr($tmp_value,$pos+strlen($tblval));
fwrite($fw, $tmp_value. $lf.$lf);
$lencount += strlen($tmp_value. $lf.$lf);
$this->startid = 0;
}
if($lencount>$sizelimit*1000)
{
$this->tableid = $j;
$this->startid = 0;
$ret = false;
break;
}
if(isset($ignoreList['sdb_'.$subname])){
$this->startid = -1;
continue;
}
fwrite($fw, "#". $lf . "# Dumping data for table `$tblval`". $lf . "#" . $lf);
$lencount += strlen("#". $lf . "# Dumping data for table `$tblval`". $lf . "#" . $lf);
$result = mysql_query("SELECT * FROM `$tblval`");
if(!@mysql_data_seek($result,$this->startid))
{
$this->startid = -1;
continue;
}
while ($row = mysql_fetch_object($result)) {
$insertdump = $lf;
$insertdump .= "INSERT INTO `$written_tbname` VALUES (";
$arr = $this->object2Array($row);
foreach($arr as $key => $value) {
if(!is_null($value))
{
$value = $this->utftrim(mysql_escape_string($value));
$insertdump .= "'$value',";
}
else
$insertdump .= "NULL,";
}
$insertline = rtrim($insertdump,',') . ");";
fwrite($fw, $insertline);
$lencount += strlen($insertline);
$this->startid++;
if($lencount>$sizelimit*1000)
{
$ret = false;
$this->tableid = $j;
break 2;
}
}
$this->startid = -1;
$i++;
// if ($i== 5) break;
}
mysql_close($resource);
fclose($fw);
chmod($bakfile, 0666);
return $ret;
}
// Private function object2Array.
function object2Array($obj) {
$array = null;
if(is_object($obj)) {
$array = array();
foreach (get_object_vars($obj) as $key => $value) {
if(is_object($value))
$array[$key] = $this->object2Array($value);
else
$array[$key] = $value;
}
}
return $array;
}
// Private function loadObjectList.
function loadObjectList($key='', $resource) {
$array = array();
while ($row = mysql_fetch_object($resource)) {
if ($key)
$array[$row->$key] = $row;
else
$array[] = $row;
}
mysql_free_result($resource);
return $array;
}
// Private function result2Array.
function result2Array($numinarray = 0, $resource) {
$array = array();
while ($row = mysql_fetch_row($resource)) {
$array[] = $row[$numinarray];
}
mysql_free_result($resource);
return $array;
}
function formatcreate($str)
{
$body = substr($str,0,strrpos($str,")")+1);
$tail = strtolower(substr($str,strrpos($str,")")-strlen($str)));
if(strstr($tail,'memory')||strstr($tail,'heap')){
return $body." TYPE=HEAP{shopexdump_create_specification};";
}else{
return $body." TYPE=MyISAM{shopexdump_create_specification};";
}
}
//截最后一个是否是半个UTF-8中文
function utftrim($str)
{
$found = false;
for($i=0;$i<4&&$i<strlen($str);$i++)
{
$ord = ord(substr($str,strlen($str)-$i-1,1));
//UTF-8中文分{四/三/二字节码},第一位分别为11110xxx(>192),1110xxxx(>192),110xxxxx(>192);接下去的位数都是10xxxxxx(<192)
//其他ASCII码都是0xxxxxxx
if($ord> 192)
{
$found = true;
break;
}
if ($i==0 && $ord < 128){
break;
}
}
if($found)
{
if($ord>240)
{
if($i==3) return $str;
else return substr($str,0,strlen($str)-$i-1);
}
elseif($ord>224)
{
if($i>=2) return $str;
else return substr($str,0,strlen($str)-$i-1);
}
else
{
if($i>=1) return $str;
else return substr($str,0,strlen($str)-$i-1);
}
}
else return $str;
}
}
?>