/**
* 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;
}
}
 jpa 使用sql语句...)
