代码如下：
创新互联公司坚持“要么做到，要么别承诺”的工作理念，服务领域包括：成都网站制作、网站设计、企业官网、英文网站、手机端网站、网站推广等服务，满足客户于互联网时代的天津网站设计、移动媒体设计的需求，帮助企业找到有效的互联网解决方案。努力成为您成熟可靠的网络建设合作伙伴！
?php
class DBManager
{
var $dbHost = '';
var $dbUser = '';
var $dbPassword = '';
var $dbSchema = '';
var $conn;
function __construct($host,$user,$password,$schema)
{
$this-dbHost = $host;
$this-dbUser = $user;
$this-dbPassword = $password;
$this-dbSchema = $schema;
}
public function executeFromString($sql,$delimiter = '(;\n)|((;\r\n))|(;\r)',$prefix = '',$commenter = array('#','--'))
{
return $this-execute($sql,$delimiter,$prefix ,$commenter);
}
public function executeFromFile($sqlPath,$delimiter = '(;\n)|((;\r\n))|(;\r)',$prefix = '',$commenter = array('#','--'))
{
//判断文件是否存在
if(!file_exists($sqlPath))return false;
$handle = fopen($sqlPath,'rb');
$sqlStr = fread($handle,filesize($sqlPath));
fclose($handle);
return $this-execute($sqlStr,$delimiter,$prefix ,$commenter);
}
protected function execute($sqlStr,$delimiter = '(;\n)|((;\r\n))|(;\r)',$prefix = '',$commenter = array('#','--'))
{
//通过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;
endif;
endforeach;
//如果不是注释，则认为是sql语句
if(!$isComment)
$newStatement[] = $subSentence;
endif;
endforeach;
$statement = $newStatement;
endforeach;
//对表名加前缀
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(emptyempty($tableName['leftWall'])):
$newTableName = $prefix.$tableName['name'];
else:
$newTableName = $tableName['leftWall'].$prefix.substr($tableName['name'],1);
endif;
$statement[0] = str_replace($tableName['name'],$newTableName,$statement[0]);
endforeach;
endif;
//组合sql语句
foreach($segment as $statement):
$newStmt = '';
foreach($statement as $sentence):
$newStmt = $newStmt.trim($sentence)."\n";
endforeach;
$statement = $newStmt;
endforeach;
self::saveByQuery($segment);
return true;
}
private function saveByQuery($sqlArray)
{
$this-conn = mysql_connect($this-dbHost,$this-dbUser,$this-dbPassword);
mysql_select_db($this-dbSchema,$this-conn);
foreach($sqlArray as $sql):
mysql_query($sql,$this-conn);
endforeach;
}
public function close()
{
mysql_close($this-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};
endif;
return true;
else:
return self::findTableName($v,$tokens,$tokensKey+1,$tableName);
endif;
endif;
endforeach;
endif;
return false;
}
}
这样写就不会错了，看看能否帮到你
form id="form1" name="form1" method="post" action="" enctype="multipart/form-data"
input type="file" name="textfield" id="textfield" /
input type="submit" name="button" id="button" value="提交" /
/form
?
if($_POST['button']!=""){
$url=$_FILES['textfield']['tmp_name'];//获取上传来的文件地址
$sql=file_get_contents($url);//打开文件
sql($sql);//执行读取函数
}
function sql($sql){
$conn=mysql_pconnect("localhost","root","123456");
mysql_select_db("shop",$conn);
mysql_query("set names utf8");
$R=mysql_query($sql);
while($v=mysql_fetch_array($R)){
echo $v['ai_id'];
echo "hr";
}
}
//sql($sql);
?
?php
$file_name = "d:test.sql";
$dbhost = "localhost";
$dbuser = "root";
$dbpass = "123456";
$dbname = "test";
set_time_limit(0);
$fp = @fopen($file_name,"r") or die("sql文件打不开");//打开文件
$pdo = new PDO("mysql:host=localhost;dbname=test","root","123456");//连接数据库
$pdo-query('set names utf8');//设置编码
echo "正在执行导入操作";
while($SQL = GetNextSQL()){
if(!$pdo-query($SQL)){
echo "执行出错";
echo "SQL语句为".$SQL;
}
}
echo "导入完成";
fclose($fp) or die("can't close file");//关闭文件
mysql_close();
//从文件中逐条取sql
function GetNextSQL(){
global $fp;
$sql="";
while($line = @fgets($fp,40960)){
$line = trim($line);
$line = str_replace("////", "//", $line);
$line = str_replace("/","'",$line);
$line = str_replace("//r//n","chr(13).chr(10)",$line);
$line = stripcslashes($line);
if(strlen($line)1){
if($line[0]=='-' $line[1]=="-"){
continue;
}
}
$sql .= $line.chr(13).chr(10);
if(strlen($line)0){
if($line[strlen($line)-1]==";"){
break;
}
}
}
return $sql;
}
亲测有效。。
代码比较长，看了后，提几点建议：
既然是要查代码为什么没有达到预期的效果，那么可以将代码各步骤进行分解开。
从代码的功能来看，应该是个建库的代码，那么，要完成一个建库的功能，可能的步骤错误发生之处：
1. 数据库连接不对（用户名、密码错误，没有建库权限等）。
2. 既然是用读取 SQL 文件的形式载入，那么：
a. SQL语句没有编写正确。
b. 文本的编码格式不符（比如ANSI / UTF-8）。
c. 读取SQL后，进行语句处理不正确。
可能还有其他存在错误之处，比如，PHP环境没有设置好、Mysql没有安装配置好等等。
建议你设定断点，然后逐句跟踪调试，这个代码都在一个文件里，跟踪调试比较方便 。
重庆分公司
重庆分公司
