1. <?php 
    2.  
         
  2. header("Content-Type:text/html;charset=utf-8"); 
    3.  
         
  3. /* 
    4.  
         
  4. * 数据库导出调用 
    5.  
         
  5. */ 
    6.  
         
  6. $host = '';//主机名 
    7.  
         
  7. $dbname = '';//数据库名 
    8.  
         
  8. $user = '';//用户名 
    9.  
         
  9. $password = '';//密码 
    10.  
         
  10. $flag = 1;//1为导出数据苦结构和数据 0为仅导出数据库结构 
    11.  
         
  11. //outputSql($host, $dbname, $user, $password, $flag); 
    12.  
         
  12. /* 
    13.  
         
  13. * 数据库导入调用 
    14.  
         
  14. */ 
    15.  
         
  15. //$filename="";//sql文件 
    16.  
         
  16. //inputSql($host, $dbname, $user, $password, $filename); 
    17.  
         
  17. /* 
    18.  
         
  18. * 数据库导出函数outputSql 
    19.  
         
  19. * 用PDO方式导出数据库数据 
    20.  
         
  20. * $host 主机名 如localhost 
    21.  
         
  21. * $dbname 数据库名 
    22.  
         
  22. * $user 用户名 
    23.  
         
  23. * $password 密码 
    24.  
         
  24. * $flag 标志位0或1 0为仅导出数据库结构 1为导出数据库结构和数据 默认为1 
    25.  
         
  25. */ 
    26.  
         
  26. function outputSql($host, $dbname, $user, $password, $flag=1) { 
    27.  
         
  27.     try { 
    28.  
         
  28.         $pdo = new PDO("mysql:host=$host;dbname=$dbname", $user, $password);//连接数据库 
    29.  
         
  29.         $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);//设置调优参数，遇到错误抛出异常 
    30.  
         
  30.     } catch (PDOException $e) { 
    31.  
         
  31.         echo $e->getMessage();//如果连接异常则抛出错误信息 
    32.  
         
  32.         exit; 
    33.  
         
  33.     } 
    34.  
         
  34.     $mysql = '';//准备字符串装载导出来的sql语句 
    35.  
         
  35.     $statments = $pdo->query("show tables");//返回结果集，show tables检视所有表名 
    36.  
         
  36.     foreach ($statments as $value) { 
          //遍历此结果集，导出每个表名对应的信息 
    37.  
         
  37.         $table_name = $value[0];//获取该表名 
    38.  
         
  38.         $mysql.="DROP TABLE IF EXISTS `$table_name`;\n";//每个表前都准备Drop语句 
    39.  
         
  39.         $table_query = $pdo->query("show create table `$table_name`");//取出该表建表信息的结果集 
    40.  
         
  40.         $create_sql = $table_query->fetch();//利用fetch方法取出该结果集对应的数组 
    41.  
         
  41.         $mysql.=$create_sql['Create Table'] . ";\r\n\r\n";//写入建表信息 
    42.  
         
  42.         if ($flag != 0) { 
          //如果标志位不是0则继续取出该表内容生成insert语句 
    43.  
         
  43.             $iteams_query = $pdo->query("select * from `$table_name`");//取出该表所有字段结果集 
    44.  
         
  44.             $values = "";//准备空字符串装载insert value值 
    45.  
         
  45.             $items = "";//准备空字符串装载该表字段名 
    46.  
         
  46.             while ($item_query = $iteams_query->fetch(PDO::FETCH_ASSOC)) { //用关联查询方式返回表中字段名和值的数组 
    47.  
         
  47.                 $item_names = array_keys($item_query);//取出该数组键值 即字段名 
    48.  
         
  48.                 $item_names = array_map("addslashes", $item_names);//将特殊字符转译加\ 
    49.  
         
  49.                 $items = join('`,`', $item_names); //联合字段名 如：items1`,`item2 `符号为反引号 键盘1旁边 字段名用反引号括起 
    50.  
         
  50.                 $item_values = array_values($item_query);//取出该数组值 即字段对应的值 
    51.  
         
  51.                 $item_values = array_map("addslashes", $item_values);//将特殊字符转译加\ 
    52.  
         
  52.                 $value_string = join("','", $item_values);//联合值 如：value1','value2 值用单引号括起 
    53.  
         
  53.                 $value_string = "('" . $value_string . "'),";//值两边加括号 
    54.  
         
  54.                 $values.="\n" . $value_string;//最后返回给$value 
    55.  
         
  55.             } 
    56.  
         
  56.             if ($values != "") { 
          //如果$values不为空，即该表有内容 
    57.  
         
  57.                 //写入insert语句 
    58.  
         
  58.                 $insert_sql = "INSERT INTO `$table_name` (`$items`) VALUES" . rtrim($values, ",") . ";\n\r"; 
    59.  
         
  59.                 //将该语句写入$mysql 
    60.  
         
  60.                 $mysql.=$insert_sql; 
    61.  
         
  61.             } 
    62.  
         
  62.         } 
    63.  
         
  63.         //表间的分割线 
    64.  
         
  64.         //$mysql.="-- ---------------------------------------------------\n\r"; 
    65.  
         
  65.     } 
    66.  
         
  66.     $filename = $dbname . "_" . date('Ymd') . ".sql"; //导出的文件名 
    67.  
         
  67.     file_put_contents($filename, $mysql);//导出sql文件 
    68.  
         
  68.     echo "数据备份成功,生成备份文件" . $filename; 
    69.  
         
  69. } 
    70.  
         
  70. /* 
    71.  
         
  71. * 数据库导入函数inputSql 
    72.  
         
  72. * 用PDO方式导入数据库数据 
    73.  
         
  73. * $host 主机名 如localhost 
    74.  
         
  74. * $dbname 数据库名 
    75.  
         
  75. * $user 用户名 
    76.  
         
  76. * $password 密码 
    77.  
         
  77. * $filename为导入的文件名 
    78.  
         
  78. * 
    79.  
         
  79. * 注：用PDO->exec方法一次性导入整个sql文件是可以导入数据库的，但如果某条语句中有错误是无法抛出异常的 
    80.  
         
  80. * 所以这里对整个sql文件进行了一次切割，以；作为切割位，切割成单条sql语句（sql文件中注释等部分不影响PDO->exec的执行），逐条调用PDO->exec方法导入，可以方便查错 
    81.  
         
  81. */ 
    82.  
         
  82. function inputSql($host, $dbname, $user, $password, $filename) { 
    83.  
         
  83.     try { 
    84.  
         
  84.         $pdo = new PDO("mysql:host=$host;dbname=$dbname", $user, $password);//连接数据库 
    85.  
         
  85.         $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);//允许抛出异常 
    86.  
         
  86.     } catch (PDOException $e) { 
    87.  
         
  87.         echo $e->getMessage();//数据库连接不成功抛出异常 
    88.  
         
  88.         exit; 
    89.  
         
  89.     } 
    90.  
         
  90.     try { 
    91.  
         
  91.         if (file_exists($filename)) { 
          //如果文件存在 
    92.  
         
  92.             $sql_stream = file_get_contents($filename);//读取整个文件内容 
    93.  
         
  93.             $sql_stream = rtrim($sql_stream);//去掉末尾空格 
    94.  
         
  94.             //利用正则替换函数，将导入的内容部分,即insert value里的；换成特殊符号' $$$ '为进一步按；切割单条sql语句做准备 
    95.  
         
  95.             $new_stream = preg_replace_callback("/\((.*)\)/", create_function('$matches', 'return str_replace(";"," $$$ ",$matches[0]);'), $sql_stream); 
    96.  
         
  96.             //切割单条sql语句生成数组 
    97.  
         
  97.             $sql_array = explode(";", $new_stream); 
    98.  
         
  98.              //遍历该数组 
    99.  
         
  99.             foreach ($sql_array as $value) { 
    100.  
         
  100.                 if (!emptyempty($value)){ //数组最后一个是空数组，所以需要判断一下 
    101.  
         
  101.                     $sql = str_replace(" $$$ ", ";", $value) . ";"; //将该条sql语句中' $$$ '转换回； 
    102.  
         
  102.                 $pdo->exec($sql); //执行该语句 
    103.  
         
  103.                 echo "成功插入数据：<br/><per>".$sql.";<per/><br/><br/>"; 
    104.  
         
  104.                 } 
    105.  
         
  105.                  
    106.  
         
  106.             } 
    107.  
         
  107.             echo "导入数据库成功"; 
    108.  
         
  108.         } 
    109.  
         
  109.     } catch (PDOException $e) { 
    110.  
         
  110.         echo $e->getMessage(); //执行异常则抛出异常 
    111.  
         
  111.         exit; 
    112.  
         
  112.     } 
    113.  
         
  113. } 
    114.  
         
  114. ?> 
    115.