/**

* mysql备份*/

classMysqlBackup {function __construct($filename, $config) {$this->setFile($filename);$this->con($config);

}/**

* 输出信息*/

private function info($code, $msg) {$json = json_encode(array('code' => $code, 'msg' => $msg),JSON_UNESCAPED_UNICODE);exit($json);

}/**

* --------------------------------------------------

* 数据库

* --------------------------------------------------*/

private $dbHandle;private $database;/**

* 连接

* @param $config array(host,user,password,database);*/

private function con($config) {$this->dbHandle = mysqli_connect($config['host'], $config['user'], $config['password'], $config['database']);if ($this->dbHandle->connect_errno) {$this->info(-1, 'MySQL连接错误：' . $this->dbHandle->connect_error);

}$this->dbHandle->set_charset('utf8');$this->database = $config['database'];

}/**

* 自定义SQL

* @param $sql 条件语句

* @param $bind 条件绑定

* @param $resType 1：select，2：insert，3：delete/update*/

private function sql($sql, $resType = 1) {//执行

$result = $this->dbHandle->query($sql);//返回

if ($resType == 1) {return $result->fetch_all(MYSQLI_ASSOC);

}elseif ($resType == 2) {return $this->dbHandle->insert_id;

}elseif ($resType == 3) {return $this->dbHandle->affected_rows;

}

}/**

* 多语句SQL*/

private function sql_multi($sql) {$result = $this->dbHandle->multi_query($sql);if ($result) {while ($this->dbHandle->more_results() && $this->dbHandle->next_result()) {

}return true;

}else{return false;

}

}/**

* --------------------------------------------------

* 文件操作

* --------------------------------------------------*/

private $filename;/**

* 设置文件*/

private function setFile($filename) {$this->filename = $filename;

}/**

* 写入*/

private function write($string) {//句柄

static $handle = null;if (!$handle) {$handle = fopen($this->filename, 'w+');

}//写入

$res = fwrite($handle, $string);//返回

if ($res === false) {return false;

}return true;

}/**

* 读取*/

private functionread() {//句柄

static $handle = null;if (!$handle) {$handle = fopen($this->filename, 'r');

}//读取

$res = fgets($handle);return substr($res, 0, -strlen($this->split));

}/**

* --------------------------------------------------

* 备份

* --------------------------------------------------*/

//SQL分隔符，不可更改

private $split = ";\r\n";/**

* 表列表*/

private functiongetTable() {//查询

$sql = "SHOW TABLES";$res = $this->sql($sql);//错误

if (!$res) {$this->info(-2, '查询表列表失败！');

}//格式化

$data = array();foreach ($res as $v) {$v = array_values($v);$data[] = $v[0];

}return $data;

}/**

* 表结构*/

private function tableCreate($table) {$res = $this->sql("SHOW CREATE TABLE `$table`");//错误

if (!$res) {$this->info(-2, "查询`$table`表结构失败！");

}//格式化

$res = array_values($res[0]);$res = str_replace(array("\r", "\n"), array('', ''), $res[1]) . $this->split;$drop_sql = "DROP TABLE IF EXISTS `$table`" . $this->split;$res = $drop_sql . $res;//写入

$res = $this->write($res);if (!$res) {$this->info(-3, "导出`$table`表结构失败！");

}return true;

}/**

* 表数据

* 主键模式，表必须设置主键*/

private function tableDataP($table, $start = 0, $len = 200) {//主键名

static $pkey = array();if (empty($pkey[$table])) {$sql = "SELECT k.column_name FROM information_schema.table_constraints t JOIN information_schema.key_column_usage k USING( CONSTRAINT_NAME, table_schema, TABLE_NAME )

WHERE t.constraint_type = 'PRIMARY KEY' AND t.table_schema = '" . $this->database . "' AND t.table_name = '$table' LIMIT 1";$res = $this->sql($sql);if (!$res) {$this->info(-2, '不支持[主键模式]导出数据！');

}$pkey[$table] = $res[0]['column_name'];

}//查询数据

$sql = "SELECT * FROM `$table` WHERE `{$pkey[$table]}` > $start LIMIT $len";$data = $this->sql($sql);//写入

if ($data) {$sql = '';foreach ($data as $row) {$key = '';$value = '';foreach ($row as $k => $v) {$v = $this->dbHandle->real_escape_string($v);$key .= "`$k`,";$value .= "'$v',";

}$sql .= "INSERT INTO `$table`(" . substr($key, 0, -1) . ") VALUES (" . substr($value, 0, -1) . ")" . $this->split;

}$res = $this->write($sql);if (!$res) {$this->info(-3, "导出`$table`表数据失败！");

}//返回

if (count($data) >= $len) {$start = $data[$len - 1][$pkey[$table]];return $start;

}

}//返回

return false;

}/**

* 表数据

* limit模式*/

private function tableDataL($table, $offset = 0, $len = 200) {//查询数据

$sql = "SELECT * FROM `$table` LIMIT $len OFFSET $offset";$data = $this->sql($sql);//写入

if ($data) {$sql = '';foreach ($data as $row) {$key = '';$value = '';foreach ($row as $k => $v) {$v = $this->dbHandle->real_escape_string($v);$key .= "`$k`,";$value .= "'$v',";

}$sql .= "INSERT INTO `$table`(" . substr($key, 0, -1) . ") VALUES (" . substr($value, 0, -1) . ")" . $this->split;

}$res = $this->write($sql);if (!$res) {$this->info(-3, "导出`$table`表数据失败！");

}//返回

if (count($data) >= $len) {$offset += $len;return $offset;

}

}//返回

return false;

}/**

* 导出*/

functionexport() {$tables = $this->getTable();//表结构

foreach ($tables as $v) {$this->tableCreate($v);

}//表数据

foreach ($tables as $v) {$res = 0;for ($i = 0; $i > -1; $i++) {$res = $this->tableDataP($v, $res);if (!$res) {break;

}

}

}return true;

}/**

* --------------------------------------------------

* 导入

* --------------------------------------------------*/

functionimport() {for ($i = 0; $i > -1; $i++) {//批量读取

$sql = '';for ($i = 0; $i < 50; $i++) {$res = $this->read();if (!$res) {break;

}$sql .= $res . ';';

}//批量执行

if ($sql) {$res = $this->sql_multi($sql);if (!$res) {echo $sql;$this->info(-3, '导入失败');

}

}else{break;

}

}return true;

}

}