php实现数据库导出或导出成sql文件代码

2024-05-04 22:00:17

字体：大中小

来源：转载

供稿：网友

本文章小编是整理了两段不同的代码可以实现数据库导出或导出成sql文件了,下面一起来看看,大家复制保存在指定文件即可.

php实现数据库备份导出成sql

1.首先要得到该数据库中有哪些表,所用函数 mysql_list_tables(),然后可以将获取的所有表名存到一个数组.

2.show create table 表名可以获取表结构.

3.select * from 表名取出所有记录,用循环拼接成 insert into... 语句.

php导出sql,导出成的sql语句效果,具体代码:

<?php

header("Content-type:text/html;charset=utf-8");

//配置信息

$cfg_dbhost = 'localhost';

$cfg_dbname = 'ftdm';

$cfg_dbuser = 'root';

$cfg_dbpwd = 'root';

$cfg_db_language = 'utf8';

$to_file_name = "ftdm.sql";

// END 配置

//链接数据库

$link = mysql_connect($cfg_dbhost,$cfg_dbuser,$cfg_dbpwd);

mysql_select_db($cfg_dbname);

//选择编码

mysql_query("set names ".$cfg_db_language);

//数据库中有哪些表

$tables = mysql_list_tables($cfg_dbname);

//将这些表记录到一个数组

$tabList = array();

while($row = mysql_fetch_row($tables)){

 $tabList[] = $row[0];

}

echo "运行中，请耐心等待... ";

$info = "-- ----------------------------＼r＼n";

$info .= "-- 日期：".date("Y-m-d H:i:s",time())."＼r＼n";

$info .= "-- 仅用于测试和学习,本程序不适合处理超大量数据＼r＼n";

$info .= "-- ----------------------------＼r＼n＼r＼n";

file_put_contents($to_file_name,$info,FILE_APPEND);

//将每个表的表结构导出到文件

foreach($tabList as $val){

 $sql = "show create table ".$val;

 $res = mysql_query($sql,$link);

 $row = mysql_fetch_array($res);

 $info = "-- ----------------------------＼r＼n";

 $info .= "-- Table structure for `".$val."`＼r＼n";

 $info .= "-- ----------------------------＼r＼n";

 $info .= "DROP TABLE IF EXISTS `".$val."`;＼r＼n";

 $sqlStr = $info.$row[1].";＼r＼n＼r＼n";

 //追加到文件

 file_put_contents($to_file_name,$sqlStr,FILE_APPEND);

 //释放资源

 mysql_free_result($res);

} //开源软件:Vevb.com

//将每个表的数据导出到文件

foreach($tabList as $val){

 $sql = "select * from ".$val;

 $res = mysql_query($sql,$link);

 //如果表中没有数据，则继续下一张表

 if(mysql_num_rows($res)<1) continue;

 //

 $info = "-- ----------------------------＼r＼n";

 $info .= "-- Records for `".$val."`＼r＼n";

 $info .= "-- ----------------------------＼r＼n";

 file_put_contents($to_file_name,$info,FILE_APPEND);

 //读取数据

 while($row = mysql_fetch_row($res)){

 $sqlStr = "INSERT INTO `".$val."` VALUES (";

 foreach($row as $zd){

 $sqlStr .= "'".$zd."', ";

 }

 //去掉最后一个逗号和空格

 $sqlStr = substr($sqlStr,0,strlen($sqlStr)-2);

 $sqlStr .= ");＼r＼n";

 file_put_contents($to_file_name,$sqlStr,FILE_APPEND);

 }

 //释放资源

 mysql_free_result($res);

 file_put_contents($to_file_name,"＼r＼n",FILE_APPEND);

}

echo "OK!";

?>

导入.sql文件到mysql数据库:

<?php

/**

*

* ------1. 数据库备份（导出）------------------------------------------------------------

//分别是主机，用户名，密码，数据库名，数据库编码

$db = new DBManage ( 'localhost', 'root', 'root', 'test', 'utf8' );

// 参数：备份哪个表(可选),备份目录(可选，默认为backup),分卷大小(可选,默认2000，即2M)

$db->backup ();

* ------2. 数据库恢复（导入）------------------------------------------------------------

//分别是主机，用户名，密码，数据库名，数据库编码

$db = new DBManage ( 'localhost', 'root', 'root', 'test', 'utf8' );

//参数：sql文件

$db->restore ( './backup/2014072125.sql');

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

*/

class DBManage

{

var $db; // 数据库连接

var $database; // 所用数据库

var $sqldir; // 数据库备份文件夹

var $record;

// 换行符

private $ds = "＼n";

// 存储SQL的变量

public $sqlContent = "";

// 每条sql语句的结尾符

public $sqlEnd = ";";

/**

 * 初始化

 *

 * @param string $host

 * @param string $username

 * @param string $password

 * @param string $thisatabase

 * @param string $charset

 */

function __construct($host = 'localhost', $username = 'root', $password = '', $thisatabase = 'test', $charset = 'utf8')

{

 $this->host = $host;

 $this->username = $username;

 $this->password = $password;

 $this->database = $thisatabase;

 $this->charset = $charset;

 // 连接数据库

 $this->db = mysql_connect ( $this->host, $this->username, $this->password ) or die ( "数据库连接失败." );

 // 选择使用哪个数据库

 mysql_select_db ( $this->database, $this->db ) or die ( "无法打开数据库" );

 // 数据库编码方式

 mysql_query ( 'SET NAMES ' . $this->charset, $this->db );

}

/*

 * ------------------------------------------数据库备份start----------------------------------------------------------

 */

/**

 * 数据库备份

 * 参数：备份哪个表(可选),备份目录(可选，默认为backup),分卷大小(可选,默认2000，即2M)

 *

 * @param $string $dir

 * @param int $size

 * @param $string $tablename

 */

function backup($tablename = '', $dir, $size)

{

 $dir = $dir ? $dir : 'backup/';

 $size = $size ? $size : 2000;

 $sql = '';

 // 只备份某个表

 if (! emptyempty ( $tablename ))

 {

 echo '正在备份表' . $tablename . ' ';

 // 插入dump信息

 $sql = $this->_retrieve();

 // 插入表结构信息

 $sql .= $this->_insert_table_structure ( $tablename );

 // 插入数据

 $data = mysql_query ( "select * from " . $tablename );

 // 文件名前面部分

 $filename = date ( 'YmdHis' ) . "_" . $tablename;

 // 字段数量

 $num_fields = mysql_num_fields ( $data );

 // 第几分卷

 $p = 1;

 // 循环每条记录

 while ( $record = mysql_fetch_array ( $data ) )

 {

 // 单条记录

 $sql .= $this->_insert_record ( $tablename, $num_fields, $record );

 // 如果大于分卷大小，则写入文件

 if (strlen ( $sql ) >= $size * 1000)

 { //开源软件:Vevb.com

 $file = $filename . "_v" . $p . ".sql";

 if ($this->_write_file ( $sql, $file, $dir ))

 {

 echo "表-" . $tablename . "-卷-" . $p . "-数据备份完成,生成备份文件 $dir$filename ";

 }

 else

 {

 echo "备份表-" . $tablename . "-失败 ";

 }

 // 下一个分卷

 $p ++;

 // 重置$sql变量为空，重新计算该变量大小

 $sql = "";

 }

 }

 // sql大小不够分卷大小

 if ($sql != "")

 {

 $filename .= "_v" . $p . ".sql";

 if ($this->_write_file ( $sql, $filename, $dir ))

 {

 echo "表-" . $tablename . "-卷-" . $p . "-数据备份完成,生成备份文件 $dir$filename ";

 }

 else

 {

 echo "备份卷-" . $p . "-失败 ";

 }

 }

 }

 else

 { // 备份全部表

 if ($tables = mysql_query ( "show table status from " . $this->database ))

 {

 echo "读取数据库结构成功！ ";

 }

 else

 {

 exit ( "读取数据库结构成功！ " );

 }

 // 插入dump信息

 $sql .= $this->_retrieve();

 // 文件名前面部分

 $filename = date ( 'YmdHis' ) . "_all";

 // 查出所有表

 $tables = mysql_query ( 'SHOW TABLES' );

 // 第几分卷

 $p = 1;

 // 循环所有表

 while ( $table = mysql_fetch_array ( $tables ) )

 {

 // 获取表名

 $tablename = $table [0];

 // 获取表结构

 $sql .= $this->_insert_table_structure ( $tablename );

 $data = mysql_query ( "select * from " . $tablename );

 $num_fields = mysql_num_fields ( $data );

 // 循环每条记录

 while ( $record = mysql_fetch_array ( $data ) )

 {

 // 单条记录

 $sql .= $this->_insert_record ( $tablename, $num_fields, $record );

 // 如果大于分卷大小，则写入文件

 if (strlen ( $sql ) >= $size * 1000)

 {

 $file = $filename . "_v" . $p . ".sql";

 // 写入文件

 if ($this->_write_file ( $sql, $file, $dir ))

 {

 echo "-卷-" . $p . "-数据备份完成,生成备份文件$dir$file ";

 }

 else

 {

 echo "备份卷-" . $p . "-失败 ";

 }

 // 下一个分卷

 $p ++;

 // 重置$sql变量为空，重新计算该变量大小

 $sql = "";

 }

 }

 }

 // sql大小不够分卷大小

 if ($sql != "")

 {

 $filename .= "_v" . $p . ".sql";

 if ($this->_write_file ( $sql, $filename, $dir ))

 {

 echo "-卷-" . $p . "-数据备份完成,生成备份文件 $dir$filename ";

 }

 else

 {

 echo "备份卷-" . $p . "-失败 ";

 }

 }

 }

}

/**

 * 插入数据库备份基础信息

 *

 * @return string

 */

private function _retrieve() {

 $value = '';

 $value .= '--' . $this->ds;

 $value .= '-- MySQL database dump' . $this->ds;

 $value .= '-- Created by DBManage class. ' . $this->ds;

 $value .= '-- http://www.111cn.net ' . $this->ds;

 $value .= '--' . $this->ds;

 $value .= '-- 主机: ' . $this->host . $this->ds;

 $value .= '-- 生成日期: ' . date ( 'Y' ) . ' 年 ' . date ( 'm' ) . ' 月 ' . date ( 'd' ) . ' 日 ' . date ( 'H:i' ) . $this->ds;

 $value .= '-- MySQL版本: ' . mysql_get_server_info () . $this->ds;

 $value .= '-- PHP 版本: ' . phpversion () . $this->ds;

 $value .= $this->ds;

 $value .= '--' . $this->ds;

 $value .= '-- 数据库: `' . $this->database . '`' . $this->ds;

 $value .= '--' . $this->ds . $this->ds;

 $value .= '-- -------------------------------------------------------';

 $value .= $this->ds . $this->ds;

 return $value;

}

/**

 * 插入表结构

 *

 * @param unknown_type $table

 * @return string

 */

private function _insert_table_structure($table) {

 $sql = '';

 $sql .= "--" . $this->ds;

 $sql .= "-- 表的结构" . $table . $this->ds;

 $sql .= "--" . $this->ds . $this->ds;

 // 如果存在则删除表

 $sql .= "DROP TABLE IF EXISTS `" . $table . '`' . $this->sqlEnd . $this->ds;

 // 获取详细表信息

 $res = mysql_query ( 'SHOW CREATE TABLE `' . $table . '`' );

 $row = mysql_fetch_array ( $res );

 $sql .= $row [1];

 $sql .= $this->sqlEnd . $this->ds;

 // 加上

 $sql .= $this->ds;

 $sql .= "--" . $this->ds;

 $sql .= "-- 转存表中的数据 " . $table . $this->ds;

 $sql .= "--" . $this->ds;

 $sql .= $this->ds;

 return $sql;

}

/**

 * 插入单条记录

 *

 * @param string $table

 * @param int $num_fields

 * @param array $record

 * @return string

 */

private function _insert_record($table, $num_fields, $record) {

 // sql字段逗号分割

 $comma = "";

 $insert .= "INSERT INTO `" . $table . "` VALUES(";

 // 循环每个子段下面的内容

 for($i = 0; $i < $num_fields; $i ++) {

 $insert .= ($comma . "'" . mysql_escape_string ( $record [$i] ) . "'");

 $comma = ",";

 }

 $insert .= ");" . $this->ds;

 return $insert;

}

/**

 * 写入文件

 *

 * @param string $sql

 * @param string $filename

 * @param string $dir

 * @return boolean

 */

private function _write_file($sql, $filename, $dir) {

 $dir = $dir ? $dir : './backup/';

 // 不存在文件夹则创建

 if (! file_exists ( $dir )) {

 mkdir ( $dir );

 }

 $re = true;

 if (! @$fp = fopen ( $dir . $filename, "w+" )) {

 $re = false;

 echo "打开文件失败！";

 }

 if (! @fwrite ( $fp, $sql )) {

 $re = false;

 echo "写入文件失败，请文件是否可写";

 }

 if (! @fclose ( $fp )) {

 $re = false;

 echo "关闭文件失败！";

 }

 return $re;

}

/*

 *

 * -------------------------------上：数据库导出-----------分割线----------下：数据库导入--------------------------------

 */

/**

 * 导入备份数据

 * 说明：分卷文件格式2014072125.sql

 * 参数：文件路径(必填)

 *

 * @param string $sqlfile

 */

function restore($sqlfile)

{

 // 检测文件是否存在

 if (! file_exists ( $sqlfile ))

 {

 exit ( "文件不存在！请检查" );

 }

 $this->lock ( $this->database );

 // 获取数据库存储位置

 $sqlpath = pathinfo ( $sqlfile );

 $this->sqldir = $sqlpath ['dirname'];

 // 检测是否包含分卷，将类似2014072125.sql从_v分开,有则说明有分卷

 $volume = explode ( "_v", $sqlfile );

 $volume_path = $volume [0];

 echo "请勿刷新及关闭浏览器以防止程序被中止，如有不慎！将导致数据库结构受损 ";

 echo "正在导入备份数据，请稍等！ ";

 if (emptyempty ( $volume [1] ))

 {

 echo "正在导入sql：" . $sqlfile . ' ';

 // 没有分卷

 if ($this->_import ( $sqlfile )) {

 echo "数据库导入成功！";

 }

 else

 {

 exit ( '数据库导入失败！' );

 }

 }

 else

 {

 //$volume_id = array();

 // 存在分卷，则获取当前是第几分卷，循环执行余下分卷

 $volume_id = explode ( ".sq", $volume [1] );

 // 当前分卷为$volume_id

 $volume_id = intval ( $volume_id [0] );

 while ( $volume_id )

 {

 $tmpfile = $volume_path . "_v" . $volume_id . ".sql";

 // 存在其他分卷，继续执行

 if (file_exists ( $tmpfile )) {

 // 执行导入方法

 echo "正在导入分卷$volume_id：" . $tmpfile . ' ';

 if ($this->_import ( $tmpfile ))

 {

 }

 else

 {

 exit ( "导入分卷$volume_id：" . $tmpfile . '失败！可能是数据库结构已损坏！请尝试从分卷1开始导入' );

 }

 }

 else

 {

 echo "此分卷备份全部导入成功！ ";

 return;

 }

 $volume_id++;

 }

 }

}

/**

 * 将sql导入到数据库（普通导入）

 *

 * @param string $sqlfile

 * @return boolean

 */

private function _import($sqlfile) {

 // sql文件包含的sql语句数组

 $sqls = array ();

 $f = fopen ( $sqlfile, "rb" );

 // 创建表缓冲变量

 $create = '';

 while ( ! feof ( $f ) ) {

 // 读取每一行sql

 $line = fgets ( $f );

 // 如果包含'-- '等注释，或为空白行，则跳过

 if (trim ( $line ) == '' || preg_match ( '/--*?/', $line, $match )) {

 continue;

 }

 // 如果结尾包含';'(即为一个完整的sql语句，这里是插入语句)，并且不包含'ENGINE='(即创建表的最后一句)，

 if (! preg_match ( '/;/', $line, $match ) || preg_match ( '/ENGINE=/', $line, $match )) {

 // 将本次sql语句与创建表sql连接存起来

 $create .= $line;

 // 如果包含了创建表的最后一句

 if (preg_match ( '/ENGINE=/', $create, $match )) {

 // 则将其合并到sql数组

 $sqls [] = $create;

 // 清空当前，准备下一个表的创建

 $create = '';

 }

 // 跳过本次

 continue;

 }

 $sqls [] = $line;

 }

 fclose ( $f );

 // 循环sql语句数组，分别执行

 foreach ( $sqls as $sql ) {

 str_replace ( "＼n", "", $sql );

 if (! mysql_query ( trim ( $sql ) )) {

 echo mysql_error ();

 return false;

 }

 }

 return true;

}

/*

 * -------------------------------数据库导入end---------------------------------

 */

// 关闭数据库连接

private function close() {

 mysql_close ( $this->db );

}

// 锁定数据库，以免备份或导入时出错

private function lock($tablename, $op = "WRITE") {

 if (mysql_query ( "lock tables " . $tablename . " " . $op ))

 return true;

 else

 return false;

}

// 解锁

private function unlock() {

 if (mysql_query ( "unlock tables" ))

 return true;

 else

 return false;

}

// 析构

function __destruct() {

 mysql_query ( "unlock tables", $this->db );

 mysql_close ( $this->db );

}

}

?>