如何利用PHP执行.SQL文件

如何利用PHP执行.SQL文件

本篇文章是对使用PHP执行.SQL文件的实现代码进行了详细的分析介绍,需要的朋友参考下

demo.php:

复制代码 代码如下:

<?php

/**

* 读取 sql 文件并写入数据库

* @version 1.01 demo.php

*/

class DBManager

{

var $dbHost = '';

var $dbUser = '';

var $dbPassword = '';

var $dbSchema = '';

function __construct($host,$user,$password,$schema)

{

$this->dbHost = $host;

$this->dbUser = $user;

$this->dbPassword = $password;

$this->dbSchema = $schema;

}

function createFromFile($sqlPath,$delimiter = '(;/n)|((;/r/n))|(;/r)',$prefix = '',$commenter = array('#','--'))

{

//判断文件是否存在

if(!file_exists($sqlPath))

return false;

$handle = fopen($sqlPath,'rb');

$sqlStr = fread($handle,filesize($sqlPath));

//通过sql语法的语句分割符进行分割

$segment = explode(";",trim($sqlStr));

//var_dump($segment);

//去掉注释和多余的空行

foreach($segment as & $statement)

{

$sentence = explode("/n",$statement);

$newStatement = array();

foreach($sentence as $subSentence)

{

if('' != trim($subSentence))

{

//判断是会否是注释

$isComment = false;

foreach($commenter as $comer)

{

if(eregi("^(".$comer.")",trim($subSentence)))

{

$isComment = true;

break;

}

}

//如果不是注释,则认为是sql语句

if(!$isComment)

$newStatement[] = $subSentence;

}

}

$statement = $newStatement;

}

//对表名加前缀

if('' != $prefix)

{

//只有表名在第一行出现时才有效 例如 CREATE TABLE talbeName

$regxTable = "^[/`/'/"]{0,1}[/_a-zA-Z]+[/_a-zA-Z0-9]*[/`/'/"]{0,1}$";//处理表名的正则表达式

$regxLeftWall = "^[/`/'/"]{1}";

$sqlFlagTree = array(

"CREATE" => array(

"TABLE" => array(

"$regxTable" => 0

)

),

"INSERT" => array(

"INTO" => array(

"$regxTable" => 0

)

)

);

foreach($segment as & $statement)

{

$tokens = split(" ",$statement[0]);

$tableName = array();

$this->findTableName($sqlFlagTree,$tokens,0,$tableName);

if(empty($tableName['leftWall']))

{

$newTableName = $prefix.$tableName['name'];

}

else{

$newTableName = $tableName['leftWall'].$prefix.substr($tableName['name'],1);

}

$statement[0] = str_replace($tableName['name'],$newTableName,$statement[0]);

}

}

//组合sql语句

foreach($segment as & $statement)

{

$newStmt = '';

foreach($statement as $sentence)

{

$newStmt = $newStmt.trim($sentence)."/n";

}

$statement = $newStmt;

}

//用于测试------------------------

//var_dump($segment);

//writeArrayToFile('data.txt',$segment);

//-------------------------------

self::saveByQuery($segment);

return true;

}

private function saveByQuery($sqlArray)

{

$conn = mysql_connect($this->dbHost,$this->dbUser,$this->dbPassword);

mysql_select_db($this->dbSchema);

foreach($sqlArray as $sql)

{

mysql_query($sql);

}

mysql_close($conn);

}

private function findTableName($sqlFlagTree,$tokens,$tokensKey=0,& $tableName = array())

{

$regxLeftWall = "^[/`/'/"]{1}";

if(count($tokens)<=$tokensKey)

return false;

if('' == trim($tokens[$tokensKey]))

{

return self::findTableName($sqlFlagTree,$tokens,$tokensKey+1,$tableName);

}

else

{

foreach($sqlFlagTree as $flag => $v)

{

if(eregi($flag,$tokens[$tokensKey]))

{

if(0==$v)

{

$tableName['name'] = $tokens[$tokensKey];

if(eregi($regxLeftWall,$tableName['name']))

{

$tableName['leftWall'] = $tableName['name']{0};

}

return true;

}

else{

return self::findTableName($v,$tokens,$tokensKey+1,& $tableName);

}

}

}

}

return false;

}

}

function writeArrayToFile($fileName,$dataArray,$delimiter="/r/n")

{

$handle=fopen($fileName, "wb");

$text = '';

foreach($dataArray as $data)

{

$text = $text.$data.$delimiter;

}

fwrite($handle,$text);

}

//测试

$dbM = new DBManager('localhost','w01f','123456','test');

$dbM->createFromFile('data.sql',null,'fff_');

?>

data.sql:

-- phpMyAdmin SQL Dump

-- version 2.11.3

-- http://www.phpmyadmin.net

--

-- 主机: localhost

-- 生成日期: 2008 年 08 月 20 日 12:09

-- 服务器版本: 5.0.51

-- PHP 版本: 5.2.5

SET SQL_MODE="NO_AUTO_VALUE_ON_ZERO";

--

-- 数据库: `newysh`

--

-- --------------------------------------------------------

--

-- 表的结构 `allowed`

--

CREATE TABLE `allowed` (

`bhash` blob NOT NULL,

`bname` varchar(255) character set utf8 NOT NULL,

PRIMARY KEY (`bhash`(20))

) ENGINE=MyISAM DEFAULT CHARSET=gb2312 ROW_FORMAT=DYNAMIC;

--

-- 导出表中的数据 `allowed`

--

-- --------------------------------------------------------

--

-- 表的结构 `allowed_ex`

--

CREATE TABLE `allowed_ex` (

`bhash` blob NOT NULL,

`badded` datetime NOT NULL,

`bsize` bigint(20) unsigned NOT NULL,

`bfiles` int(10) unsigned NOT NULL,

PRIMARY KEY (`bhash`(20))

) ENGINE=MyISAM DEFAULT CHARSET=gb2312 ROW_FORMAT=DYNAMIC;

--

-- 导出表中的数据 `allowed_ex`

--

-- --------------------------------------------------------

--

-- 表的结构 `category`

--

CREATE TABLE `category` (

`cid` int(10) unsigned NOT NULL auto_increment COMMENT '种子分类id',

`name` varchar(255) NOT NULL COMMENT '分类名称,支持html格式',

`sequence` int(10) unsigned NOT NULL COMMENT '显示排序,需要小的排在前面',

PRIMARY KEY (`cid`)

) ENGINE=MyISAM DEFAULT CHARSET=utf8 AUTO_INCREMENT=26 ;

--

-- 导出表中的数据 `category`

--

INSERT INTO `category` (`cid`, `name`, `sequence`) VALUES

(25, '音乐', 23),

(24, '学习资料', 24),

(23, '电影', 25);

-----------------------------------------------------------

注:对于phpmyadmin 生成的sql文件均适用