thinkphp备份数据库的方法分享
程序员文章站
2022-06-05 20:53:42
貌似thinkphp没有备份数据库的方法,所以我自己写了一个,数据库连接和事务处理用的是pdo,如果有需要的可以联系我,写个mysql或者mysqli的
复制代码 代码如...
貌似thinkphp没有备份数据库的方法,所以我自己写了一个,数据库连接和事务处理用的是pdo,如果有需要的可以联系我,写个mysql或者mysqli的
复制代码 代码如下:
<?php
class sqlaction extends action{
function outsql(){
header(“content-type:text/html;charset=utf-8″);
/*用c方法读取数据库配置*/
$host=c(‘db_host');
$db_name=c(‘db_name');
$user=c(‘db_user');
$password=c(‘db_pwd');
/*调用导出数据库的私有方法*/
$outstream=$this->outputsql($host, $dbname, $user, $password);
/*下载导出数据库*/
header(“content-disposition: attachment; filename=$dbname.sql”);
echo $outstream;
}
/*
* 数据库导出函数outputsql
* 用pdo方式导出数据库数据
* $host 主机名 如localhost
* $dbname 数据库名
* $user 用户名
* $password 密码
* $flag 标志位0或1 0为仅导出数据库结构 1为导出数据库结构和数据 默认为1
*/
private function outputsql($host, $dbname, $user, $password, $flag=1) {
try {
$pdo = new pdo(“mysql:host=$host;dbname=$dbname”, $user, $password); //连接数据库
$pdo->setattribute(pdo::attr_errmode, pdo::errmode_exception); //设置调优参数,遇到错误抛出异常
} catch (pdoexception $e) {
echo $e->getmessage(); //如果连接异常则抛出错误信息
exit;
}
$mysql = “drop database if exists `$dbname`;\n”; //$mysql装载sql语句,这里如果存在数据库则drop该数据库
$creat_db=$pdo->query(“show create database $dbname”)->fetch();//用show create database查看sql语句
preg_match(‘/default character set(.*)\*/', $creat_db[‘create database'],$matches);//正则取出default character set 后面的字符集
$mysql.=”create database `$dbname` default character set $matches[1]”;//该语句如create database `test_db` default character set utf8
/*查找该数据库的字符整序如collate utf8_general_ci*/
$db_collate=$pdo->query(“select default_collation_name from information_schema.schemata where schema_name ='$dbname' limit 1″)->fetch();
$mysql.=”collate “.$db_collate[‘default_collation_name'].”;\nuse `$dbname`;\n\n”;
$statments = $pdo->query(“show tables”); //返回结果集,show tables检视所有表名
foreach ($statments as $value) {//遍历此结果集,导出每个表名对应的信息
$table_name = $value[0]; //获取该表名
$mysql.=”drop table if exists `$table_name`;\n”; //每个表前都准备drop语句
$table_query = $pdo->query(“show create table `$table_name`”); //取出该表建表信息的结果集
$create_sql = $table_query->fetch(); //利用fetch方法取出该结果集对应的数组
$mysql.=$create_sql[‘create table'] . “;\r\n\r\n”; //写入建表信息
if ($flag != 0) {//如果标志位不是0则继续取出该表内容生成insert语句
$iteams_query = $pdo->query(“select * from `$table_name`”); //取出该表所有字段结果集
$values = “”; //准备空字符串装载insert value值
$items = “”; //准备空字符串装载该表字段名
while ($item_query = $iteams_query->fetch(pdo::fetch_assoc)) { //用关联查询方式返回表中字段名和值的数组
$item_names = array_keys($item_query); //取出该数组键值 即字段名
$item_names = array_map(“addslashes”, $item_names); //将特殊字符转译加\
$items = join(‘`,`', $item_names); //联合字段名 如:items1`,`item2 `符号为反引号 键盘1旁边 字段名用反引号括起
$item_values = array_values($item_query); //取出该数组值 即字段对应的值
$item_values = array_map(“addslashes”, $item_values); //将特殊字符转译加\
$value_string = join(“‘,'”, $item_values); //联合值 如:value1′,'value2 值用单引号括起
$value_string = “(‘” . $value_string . “‘),”; //值两边加括号
$values.=”\n” . $value_string; //最后返回给$value
}
if ($values != “”) {//如果$values不为空,即该表有内容
//写入insert语句
$insert_sql = “insert into `$table_name` (`$items`) values” . rtrim($values, “,”) . “;\n\r”;
//将该语句写入$mysql
$mysql.=$insert_sql;
}
}
}
return $mysql;
}
}
?>
是不是很实用的功能呢,小伙伴们可以直接移植到自己的项目中去的。