php導入sql文件
sql php
php導入sql文件
基本思路
1.打開sql文件，放入一個變量（字符串類型）其中
2.使用正則替換掉其中的凝視（“--”與“/**/”）
3.使用explode切割成為一個數組並去除每行的空格
4.鏈接數據庫之后使用my_query()運行sql
代碼
<?php// +------------------------------------------------------------------------------------------// | Author: longDD <longdd_love@163.com>// +------------------------------------------------------------------------------------------// | There is no true,no evil,no light,there is only power.// +------------------------------------------------------------------------------------------// | Description: import sql Dates: 2014-08-07// +------------------------------------------------------------------------------------------class ImportSql { /** @var $content 數據庫連接 */ protected $connect = null; /** @var $db 數據庫對象 */ protected $db = null; /** @var $sqlFile sql文件 */ public $sqlFile = ""; /** @array @sqlArr sql語句數組 */ public $sqlArr = array(); /** * 構造函數 * * @param string $host 主機地址 * @param string $user username * @param string $pw password * @param $db_name 數據庫名稱 * @return void */ public function __construct($host, $user, $pw, $db_name) { /** 連接數據庫 */ $this->connect = mysql_connect($host, $user, $pw) or die("Could not connect: " . mysql_error()); /** 選中數據庫 */ $this->db = mysql_select_db($db_name, $this->connect) or die("Yon can not select the table:" . mysql_error()); } /** * 導入sql文件 * * @param string $url 文件路徑 * @return true 導入成返回true */ public function Import($url) { if(!file_exists($url)) { exit("文件不存在！");
} $this->sqlFile = file_get_contents($url); if (!$this->sqlFile) { exit("打開文件錯誤！");
} else { $this->GetSqlArr(); if ($this->Runsql()) { return true; } } } /** * 獲取sql語句數組 * * @return void */ public function GetSqlArr() { /** 去除凝視 */ $str = $this->sqlFile; $str = preg_replace('/--.*/i', '', $str); $str = preg_replace('/\/\*.*\*\/(\;)?/i', '', $str); /** 去除空格 創建數組 */ $str = explode(";\n", $str); foreach ($str as $v) { $v = trim($v); if (empty($v)) { continue; } else { $this->sqlArr[] = $v; } } } /** * 運行sql文件 * * @return true 運行成功返回true */ public function RunSql() { /** 開啟事務 */ if (mysql_query('BEGIN')) { foreach ($this->sqlArr as $k => $v) { if (!mysql_query($v)) { /** 回滾 */ mysql_query('ROLLBACK'); exit("sql語句錯誤：第" . $k . "行" . mysql_error()); } } /** 提交事務 */ mysql_query('COMMIT'); return true; } else { exit('無法開啟事務！');
} }}// +------------------------------------------------------------------------------------------// | End of ImportSql class// +------------------------------------------------------------------------------------------/*** This is a example.*/header("Content-type:text/html;charset=utf-8");$sql = new ReadSql("localhost", "root", "", "log_db");$rst = $sql->Import("./log_db.sql");if ($rst) { echo "Success。";}// +------------------------------------------------------------------------------------------// | End of file ImportSql.php// +------------------------------------------------------------------------------------------// | Location: ./ImportSql.php// +------------------------------------------------------------------------------------------