blocks|key|1736635|text|mysql_query("LOAD+DATA+LOCAL+INFILE+'/path/to/file'+INTO+TABLE+mytable");|type|code-block|depth|inlineStyleRanges|entityRanges|data|syntax|javascript|1736636|unstyled|entityMap^0|0^^$0|@$1|2|3|4|5|6|7|G|8|@]|9|@]|A|$B|C]]|$1|D|3|-4|5|E|7|H|8|@]|9|@]|A|$]]]|F|$]]

<pre><code>mysql_query("LOAD DATA LOCAL INFILE '/path/to/file' INTO TABLE mytable");
</code></pre>

blocks|key|1736687|text|您确定不是每行一个查询吗？您的文本编辑器可能会换行，但实际上每个查询可能在一行上。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1736688|无论如何，奥勒的方法似乎是最好的。如果您有理由一次运行一个查询，您应该能够逐行读取文件，然后在每个查询的末尾使用分号进行分隔。您最好逐行读取文件，而不是试图拆分一个巨大的字符串，因为这将更有利于服务器的内存。示例：|1736689|$query++=+'';
$handle+=+@fopen("/sqlfile.sql",+"r");

if+($handle)+{
++++while+(!feof($handle))+{
++++++++$query.=+fgets($handle,+4096);

++++++++if+(substr(rtrim($query),+-1)+===+';')+{
++++++++++++//+...run+your+query,+then+unset+the+string
++++++++++++$query+=+'';
++++++++}
++++}

++++fclose($handle);
}|code-block|syntax|javascript|1736690|显然，如果您在批处理中运行大量查询，则需要考虑事务和其他事务，但对于新安装脚本来说，这可能不是什么大问题。|1736691|entityMap^0|0|0|0|0^^$0|@$1|2|3|4|5|6|7|M|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|N|8|@]|9|@]|A|$]]|$1|D|3|E|5|F|7|O|8|@]|9|@]|A|$G|H]]|$1|I|3|J|5|6|7|P|8|@]|9|@]|A|$]]|$1|K|3|-4|5|6|7|Q|8|@]|9|@]|A|$]]]|L|$]]

Are you sure that its not one query per line? Your text editor may be wrapping lines, but in reality each query may be on a single line.

At any rate, olle's method seems best. If you have reasons to run queries one at time, you should be able to read in your file line by line, then use the semicolon at the end of each query to delimit. You're much better off reading in a file line by line than trying to split an enormous string, as it will be much kinder to your server's memory. Example:

<pre><code>$query = '';
$handle = @fopen("/sqlfile.sql", "r");

if ($handle) {
 while (!feof($handle)) {
 $query.= fgets($handle, 4096);

 if (substr(rtrim($query), -1) === ';') {
 // ...run your query, then unset the string
 $query = '';
 }
 }

 fclose($handle);
}
</code></pre>

Obviously, you'll need to consider transactions and the rest if you're running a whole lot of queries in a batch, but it's probably not a big deal for a new-install script.

blocks|key|1521749|text|我的建议是看看PHPMyBackup的源代码。它是一个自动化的PHP+SQL加载器。您会发现mysql_query一次只加载一个查询，而且像PHPMyAdmin和PHPMyBackup这样的项目已经为您完成了以正确的方式解析SQL的艰苦工作。请不要重新发明那个轮子:P|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1521750|entityMap^0|0^^$0|@$1|2|3|4|5|6|7|D|8|@]|9|@]|A|$]]|$1|B|3|-4|5|6|7|E|8|@]|9|@]|A|$]]]|C|$]]

My suggestion would be to look at the sourcecode of PHPMyBackup. It's an automated PHP SQL loader. You will find that mysql_query only loads one query at a time, and projects like PHPMyAdmin and PHPMyBackup have already done the hard work for you of parsing the SQL the correct way. Please don't re-invent that wheel :P

blocks|key|1521845|text|mysqli可以运行由;分隔的多个查询|type|unstyled|depth|inlineStyleRanges|offset|length|style|CODE|entityRanges|data|1521846|您可以读取整个文件，并使用mysqli_multi_query()一次性运行所有文件|1521847|但是，我首先要说的是，这不是最优雅的解决方案。|1521848|entityMap|0|LINK|mutability|MUTABLE|url|http://us3.php.net/manual/en/mysqli.multi-query.php^0|0|6|B|1|0|D|K|D|K|0|0|0^^$0|@$1|2|3|4|5|6|7|R|8|@$9|S|A|T|B|C]|$9|U|A|V|B|C]]|D|@]|E|$]]|$1|F|3|G|5|6|7|W|8|@$9|X|A|Y|B|C]]|D|@$9|Z|A|10|1|11]]|E|$]]|$1|H|3|I|5|6|7|12|8|@]|D|@]|E|$]]|$1|J|3|-4|5|6|7|13|8|@]|D|@]|E|$]]]|K|$L|$5|M|N|O|E|$P|Q]]]]

<code>mysqli</code> can run multiple queries separated by a <code>;</code> 

you could read in the whole file and run it all at once using <a href="http://us3.php.net/manual/en/mysqli.multi-query.php" rel="noreferrer"><code>mysqli_multi_query()</code></a>

But, I'll be the first to say that this isn't the most elegant solution.

blocks|key|1736910|text|我有一种感觉，这里每个回答了这个问题的人都不知道作为一个允许人们在自己的服务器上安装应用程序的web应用程序开发人员是什么感觉。尤其是，共享主机不允许您像前面提到的“加载数据”查询那样使用SQL。大多数共享主机也不允许您使用shell_exec。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1736911|现在，为了回答这个问题，最好的办法就是构建一个PHP文件，该文件在一个变量中包含您的查询，并且可以直接运行它们。如果您决定解析.sql文件，那么您应该研究一下phpMyAdmin，并获得一些从.sql文件中获取数据的方法。看看其他有安装程序的web应用程序，你会发现，他们不是使用.sql文件进行查询，而是将它们打包成PHP文件，然后通过mysql_query或任何他们需要做的事情来运行每个字符串。|1736912|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|F|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|G|8|@]|9|@]|A|$]]|$1|D|3|-4|5|6|7|H|8|@]|9|@]|A|$]]]|E|$]]

I'm getting the feeling that everyone here who's answered this question doesn't know what it's like to be a web application developer who allows people to install the application on their own servers. Shared hosting, especially, doesn't allow you to use SQL like the "LOAD DATA" query mentioned previously. Most shared hosts also don't allow you to use shell_exec.

Now, to answer the OP, your best bet is to just build out a PHP file that contains your queries in a variable and can just run them. If you're determined to parse .sql files, you should look into phpMyAdmin and get some ideas for getting data out of .sql files that way. Look around at other web applications that have installers and you'll see that, rather than use .sql files for their queries, they just package them up in PHP files and just run each string through mysql_query or whatever it is that they need to do.

blocks|key|1736994|text|我在这里看到的解决方案都不能处理在服务器上创建存储过程时需要更改分隔符的问题，在服务器上，我不能指望能够访问LOAD+DATA+INFILE。我希望发现有人已经解决了这个问题，而不需要搜索phpMyAdmin代码来找出答案。像其他人一样，我也在寻找别人的GPL方式，因为我自己也在写GPL代码。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1736995|entityMap^0|0^^$0|@$1|2|3|4|5|6|7|D|8|@]|9|@]|A|$]]|$1|B|3|-4|5|6|7|E|8|@]|9|@]|A|$]]]|C|$]]

None of the solutions I have seen here deal with needing to change the delimiter while creating a stored procedure on a server where I can't count on having access to LOAD DATA INFILE. I was hoping to find that someone had already solved this without having to scour the phpMyAdmin code to figure it out. Like others, I too was in the process of looking for someone else's GPL'ed way of doing it since I am writing GPL code myself.

blocks|key|1737056|text|一些PHP库可以解析由多个SQL语句组成的SQL文件，正确地分解它(自然地不使用简单的";“分解)，然后执行它们。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1737057|例如，查看Phing的PDOSQLExecTask|offset|length|1737058|entityMap|0|LINK|mutability|MUTABLE|url|http://www.phing.info/trac/|1|http://phing.info/docs/guide/stable/chapters/appendixes/AppendixC-OptionalTasks.html#PDOSQLExecTask^0|0|5|5|0|B|E|1|0^^$0|@$1|2|3|4|5|6|7|P|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|Q|8|@]|9|@$D|R|E|S|1|T]|$D|U|E|V|1|W]]|A|$]]|$1|F|3|-4|5|6|7|X|8|@]|9|@]|A|$]]]|G|$H|$5|I|J|K|A|$L|M]]|N|$5|I|J|K|A|$L|O]]]]

Some PHP libraries can parse a SQL file made of multiple SQL statements, explode it properly (not using a simple ";" explode, naturally), and the execute them. 

For instance, check <a href="http://www.phing.info/trac/" rel="nofollow noreferrer">Phing</a>'s <a href="http://phing.info/docs/guide/stable/chapters/appendixes/AppendixC-OptionalTasks.html#PDOSQLExecTask" rel="nofollow noreferrer">PDOSQLExecTask</a>

blocks|key|1737090|text|我一直在用这个：|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1737091|$sql+=+explode(";",file_get_contents('[your+dump+file].sql'));//+

foreach($sql+as+$query)
+mysql_query($query);|code-block|syntax|javascript|1737092|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

I use this all the time:

<pre><code>$sql = explode(";",file_get_contents('[your dump file].sql'));// 

foreach($sql as $query)
 mysql_query($query);
</code></pre>

blocks|key|1522101|text|适用于Navicat转储。可能需要转储navicat放入的第一个/*+*/注释。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1522102|$file_content+=+file('myfile.sql');
$query+=+"";
foreach($file_content+as+$sql_line){
++if(trim($sql_line)+!=+""+&&+strpos($sql_line,+"--")+===+false){
++++$query+.=+$sql_line;
++++if+(substr(rtrim($query),+-1)+==+';'){
++++++echo+$query;
++++++$result+=+mysql_query($query)or+die(mysql_error());
++++++$query+=+"";
++++}
++}
+}|code-block|syntax|javascript|1522103|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

Works on Navicat dumps. Might need to dump the first /* */ comment navicat puts in.

<pre><code>$file_content = file('myfile.sql');
$query = "";
foreach($file_content as $sql_line){
 if(trim($sql_line) != "" &amp;&amp; strpos($sql_line, "--") === false){
 $query .= $sql_line;
 if (substr(rtrim($query), -1) == ';'){
 echo $query;
 $result = mysql_query($query)or die(mysql_error());
 $query = "";
 }
 }
 }
</code></pre>

blocks|key|1522140|text|phpBB使用一些函数来解析他们的文件。它们得到了相当好的评价(真是个例外！)所以你可以很容易地知道它们是做什么的(我从http://www.frihost.com/forums/vt-8194.html那里得到了这个解决方案)。下面是我经常使用的解决方案：|type|unstyled|depth|inlineStyleRanges|entityRanges|offset|length|data|1522141|<php
ini_set('memory_limit',+'5120M');
set_time_limit+(+0+);
/***************************************************************************
*+++++++++++++++++++++++++++++sql_parse.php
*++++++++++++++++++++++++++++++-------------------
*+++++begin++++++++++++++++:+Thu+May+31,+2001
*+++++copyright++++++++++++:+(C)+2001+The+phpBB+Group
*+++++email++++++++++++++++:+support@phpbb.com
*
*+++++$Id:+sql_parse.php,v+1.8+2002/03/18+23:53:12+psotfx+Exp+$
*
****************************************************************************/

/***************************************************************************
+*
+*+++This+program+is+free+software;+you+can+redistribute+it+and/or+modify
+*+++it+under+the+terms+of+the+GNU+General+Public+License+as+published+by
+*+++the+Free+Software+Foundation;+either+version+2+of+the+License,+or
+*+++(at+your+option)+any+later+version.
+*
+***************************************************************************/

/***************************************************************************
*
*+++These+functions+are+mainly+for+use+in+the+db_utilities+under+the+admin
*+++however+in+order+to+make+these+functions+available+elsewhere,+specifically
*+++in+the+installation+phase+of+phpBB+I+have+seperated+out+a+couple+of
*+++functions+into+this+file.++JLH
*
\***************************************************************************/

//
//+remove_comments+will+strip+the+sql+comment+lines+out+of+an+uploaded+sql+file
//+specifically+for+mssql+and+postgres+type+files+in+the+install....
//
function+remove_comments(&$output)
{
+++$lines+=+explode("\n",+$output);
+++$output+=+"";

+++//+try+to+keep+mem.+use+down
+++$linecount+=+count($lines);

+++$in_comment+=+false;
+++for($i+=+0;+$i+&lt;+$linecount;+$i%2B%2B)
+++{
++++++if(+preg_match("/%5E\/\*/",+preg_quote($lines[$i]))+)
++++++{
+++++++++$in_comment+=+true;
++++++}

++++++if(+!$in_comment+)
++++++{
+++++++++$output+.=+$lines[$i]+.+"\n";
++++++}

++++++if(+preg_match("/\*\/$/",+preg_quote($lines[$i]))+)
++++++{
+++++++++$in_comment+=+false;
++++++}
+++}

+++unset($lines);
+++return+$output;
}

//
//+remove_remarks+will+strip+the+sql+comment+lines+out+of+an+uploaded+sql+file
//
function+remove_remarks($sql)
{
+++$lines+=+explode("\n",+$sql);

+++//+try+to+keep+mem.+use+down
+++$sql+=+"";

+++$linecount+=+count($lines);
+++$output+=+"";

+++for+($i+=+0;+$i+&lt;+$linecount;+$i%2B%2B)
+++{
++++++if+(($i+!=+($linecount+-+1))+%7C%7C+(strlen($lines[$i])+>+0))
++++++{
+++++++++if+(isset($lines[$i][0])+&&+$lines[$i][0]+!=+"#")
+++++++++{
++++++++++++$output+.=+$lines[$i]+.+"\n";
+++++++++}
+++++++++else
+++++++++{
++++++++++++$output+.=+"\n";
+++++++++}
+++++++++//+Trading+a+bit+of+speed+for+lower+mem.+use+here.
+++++++++$lines[$i]+=+"";
++++++}
+++}

+++return+$output;

}

//
//+split_sql_file+will+split+an+uploaded+sql+file+into+single+sql+statements.
//+Note:+expects+trim()+to+have+already+been+run+on+$sql.
//
function+split_sql_file($sql,+$delimiter)
{
+++//+Split+up+our+string+into+"possible"+SQL+statements.
+++$tokens+=+explode($delimiter,+$sql);

+++//+try+to+save+mem.
+++$sql+=+"";
+++$output+=+array();

+++//+we+don't+actually+care+about+the+matches+preg+gives+us.
+++$matches+=+array();

+++//+this+is+faster+than+calling+count($oktens)+every+time+thru+the+loop.
+++$token_count+=+count($tokens);
+++for+($i+=+0;+$i+&lt;+$token_count;+$i%2B%2B)
+++{
++++++//+Don't+wanna+add+an+empty+string+as+the+last+thing+in+the+array.
++++++if+(($i+!=+($token_count+-+1))+%7C%7C+(strlen($tokens[$i]+>+0)))
++++++{
+++++++++//+This+is+the+total+number+of+single+quotes+in+the+token.
+++++++++$total_quotes+=+preg_match_all("/'/",+$tokens[$i],+$matches);
+++++++++//+Counts+single+quotes+that+are+preceded+by+an+odd+number+of+backslashes,
+++++++++//+which+means+they're+escaped+quotes.
+++++++++$escaped_quotes+=+preg_match_all("/(?&lt;!\\\\)(\\\\\\\\)*\\\\'/",+$tokens[$i],+$matches);

+++++++++$unescaped_quotes+=+$total_quotes+-+$escaped_quotes;

+++++++++//+If+the+number+of+unescaped+quotes+is+even,+then+the+delimiter+did+NOT+occur+inside+a+string+literal.
+++++++++if+(($unescaped_quotes+%25+2)+==+0)
+++++++++{
++++++++++++//+It's+a+complete+sql+statement.
++++++++++++$output[]+=+$tokens[$i];
++++++++++++//+save+memory.
++++++++++++$tokens[$i]+=+"";
+++++++++}
+++++++++else
+++++++++{
++++++++++++//+incomplete+sql+statement.+keep+adding+tokens+until+we+have+a+complete+one.
++++++++++++//+$temp+will+hold+what+we+have+so+far.
++++++++++++$temp+=+$tokens[$i]+.+$delimiter;
++++++++++++//+save+memory..
++++++++++++$tokens[$i]+=+"";

++++++++++++//+Do+we+have+a+complete+statement+yet?
++++++++++++$complete_stmt+=+false;

++++++++++++for+($j+=+$i+%2B+1;+(!$complete_stmt+&&+($j+&lt;+$token_count));+$j%2B%2B)
++++++++++++{
+++++++++++++++//+This+is+the+total+number+of+single+quotes+in+the+token.
+++++++++++++++$total_quotes+=+preg_match_all("/'/",+$tokens[$j],+$matches);
+++++++++++++++//+Counts+single+quotes+that+are+preceded+by+an+odd+number+of+backslashes,
+++++++++++++++//+which+means+they're+escaped+quotes.
+++++++++++++++$escaped_quotes+=+preg_match_all("/(?&lt;!\\\\)(\\\\\\\\)*\\\\'/",+$tokens[$j],+$matches);

+++++++++++++++$unescaped_quotes+=+$total_quotes+-+$escaped_quotes;

+++++++++++++++if+(($unescaped_quotes+%25+2)+==+1)
+++++++++++++++{
++++++++++++++++++//+odd+number+of+unescaped+quotes.+In+combination+with+the+previous+incomplete
++++++++++++++++++//+statement(s),+we+now+have+a+complete+statement.+(2+odds+always+make+an+even)
++++++++++++++++++$output[]+=+$temp+.+$tokens[$j];

++++++++++++++++++//+save+memory.
++++++++++++++++++$tokens[$j]+=+"";
++++++++++++++++++$temp+=+"";

++++++++++++++++++//+exit+the+loop.
++++++++++++++++++$complete_stmt+=+true;
++++++++++++++++++//+make+sure+the+outer+loop+continues+at+the+right+point.
++++++++++++++++++$i+=+$j;
+++++++++++++++}
+++++++++++++++else
+++++++++++++++{
++++++++++++++++++//+even+number+of+unescaped+quotes.+We+still+don't+have+a+complete+statement.
++++++++++++++++++//+(1+odd+and+1+even+always+make+an+odd)
++++++++++++++++++$temp+.=+$tokens[$j]+.+$delimiter;
++++++++++++++++++//+save+memory.
++++++++++++++++++$tokens[$j]+=+"";
+++++++++++++++}

++++++++++++}+//+for..
+++++++++}+//+else
++++++}
+++}

+++return+$output;
}

$dbms_schema+=+'yourfile.sql';

$sql_query+=+@fread(@fopen($dbms_schema,+'r'),+@filesize($dbms_schema))+or+die('problem+');
$sql_query+=+remove_remarks($sql_query);
$sql_query+=+split_sql_file($sql_query,+';');

$host+=+'localhost';
$user+=+'user';
$pass+=+'pass';
$db+=+'database_name';

//In+case+mysql+is+deprecated+use+mysqli+functions.+
mysqli_connect($host,$user,$pass)+or+die('error+connection');
mysqli_select_db($db)+or+die('error+database+selection');

$i=1;
foreach($sql_query+as+$sql){
echo+$i%2B%2B;
echo+"<br+/>";
mysql_query($sql)+or+die('error+in+query');
}

?>|code-block|syntax|javascript|1522142|entityMap|0|LINK|mutability|MUTABLE|url|http://www.frihost.com/forums/vt-8194.html^0|1O|16|0|0|0^^$0|@$1|2|3|4|5|6|7|Q|8|@]|9|@$A|R|B|S|1|T]]|C|$]]|$1|D|3|E|5|F|7|U|8|@]|9|@]|C|$G|H]]|$1|I|3|-4|5|6|7|V|8|@]|9|@]|C|$]]]|J|$K|$5|L|M|N|C|$O|P]]]]

phpBB uses a few functions to parse their files. They are rather well-commented (what an exception!) so you can easily know what they do (I got this solution from <a href="http://www.frihost.com/forums/vt-8194.html" rel="nofollow noreferrer">http://www.frihost.com/forums/vt-8194.html</a>). here is the solution an I've used it a lot:

<pre><code>&lt;php
ini_set('memory_limit', '5120M');
set_time_limit ( 0 );
/***************************************************************************
* sql_parse.php
* -------------------
* begin : Thu May 31, 2001
* copyright : (C) 2001 The phpBB Group
* email : support@phpbb.com
*
* $Id: sql_parse.php,v 1.8 2002/03/18 23:53:12 psotfx Exp $
*
****************************************************************************/

/***************************************************************************
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
 *
 ***************************************************************************/

/***************************************************************************
*
* These functions are mainly for use in the db_utilities under the admin
* however in order to make these functions available elsewhere, specifically
* in the installation phase of phpBB I have seperated out a couple of
* functions into this file. JLH
*
\***************************************************************************/

//
// remove_comments will strip the sql comment lines out of an uploaded sql file
// specifically for mssql and postgres type files in the install....
//
function remove_comments(&amp;$output)
{
 $lines = explode("\n", $output);
 $output = "";

 // try to keep mem. use down
 $linecount = count($lines);

 $in_comment = false;
 for($i = 0; $i &amp;lt; $linecount; $i++)
 {
 if( preg_match("/^\/\*/", preg_quote($lines[$i])) )
 {
 $in_comment = true;
 }

 if( !$in_comment )
 {
 $output .= $lines[$i] . "\n";
 }

 if( preg_match("/\*\/$/", preg_quote($lines[$i])) )
 {
 $in_comment = false;
 }
 }

 unset($lines);
 return $output;
}

//
// remove_remarks will strip the sql comment lines out of an uploaded sql file
//
function remove_remarks($sql)
{
 $lines = explode("\n", $sql);

 // try to keep mem. use down
 $sql = "";

 $linecount = count($lines);
 $output = "";

 for ($i = 0; $i &amp;lt; $linecount; $i++)
 {
 if (($i != ($linecount - 1)) || (strlen($lines[$i]) &gt; 0))
 {
 if (isset($lines[$i][0]) &amp;&amp; $lines[$i][0] != "#")
 {
 $output .= $lines[$i] . "\n";
 }
 else
 {
 $output .= "\n";
 }
 // Trading a bit of speed for lower mem. use here.
 $lines[$i] = "";
 }
 }

 return $output;

}

//
// split_sql_file will split an uploaded sql file into single sql statements.
// Note: expects trim() to have already been run on $sql.
//
function split_sql_file($sql, $delimiter)
{
 // Split up our string into "possible" SQL statements.
 $tokens = explode($delimiter, $sql);

 // try to save mem.
 $sql = "";
 $output = array();

 // we don't actually care about the matches preg gives us.
 $matches = array();

 // this is faster than calling count($oktens) every time thru the loop.
 $token_count = count($tokens);
 for ($i = 0; $i &amp;lt; $token_count; $i++)
 {
 // Don't wanna add an empty string as the last thing in the array.
 if (($i != ($token_count - 1)) || (strlen($tokens[$i] &gt; 0)))
 {
 // This is the total number of single quotes in the token.
 $total_quotes = preg_match_all("/'/", $tokens[$i], $matches);
 // Counts single quotes that are preceded by an odd number of backslashes,
 // which means they're escaped quotes.
 $escaped_quotes = preg_match_all("/(?&amp;lt;!\\\\)(\\\\\\\\)*\\\\'/", $tokens[$i], $matches);

 $unescaped_quotes = $total_quotes - $escaped_quotes;

 // If the number of unescaped quotes is even, then the delimiter did NOT occur inside a string literal.
 if (($unescaped_quotes % 2) == 0)
 {
 // It's a complete sql statement.
 $output[] = $tokens[$i];
 // save memory.
 $tokens[$i] = "";
 }
 else
 {
 // incomplete sql statement. keep adding tokens until we have a complete one.
 // $temp will hold what we have so far.
 $temp = $tokens[$i] . $delimiter;
 // save memory..
 $tokens[$i] = "";

 // Do we have a complete statement yet?
 $complete_stmt = false;

 for ($j = $i + 1; (!$complete_stmt &amp;&amp; ($j &amp;lt; $token_count)); $j++)
 {
 // This is the total number of single quotes in the token.
 $total_quotes = preg_match_all("/'/", $tokens[$j], $matches);
 // Counts single quotes that are preceded by an odd number of backslashes,
 // which means they're escaped quotes.
 $escaped_quotes = preg_match_all("/(?&amp;lt;!\\\\)(\\\\\\\\)*\\\\'/", $tokens[$j], $matches);

 $unescaped_quotes = $total_quotes - $escaped_quotes;

 if (($unescaped_quotes % 2) == 1)
 {
 // odd number of unescaped quotes. In combination with the previous incomplete
 // statement(s), we now have a complete statement. (2 odds always make an even)
 $output[] = $temp . $tokens[$j];

 // save memory.
 $tokens[$j] = "";
 $temp = "";

 // exit the loop.
 $complete_stmt = true;
 // make sure the outer loop continues at the right point.
 $i = $j;
 }
 else
 {
 // even number of unescaped quotes. We still don't have a complete statement.
 // (1 odd and 1 even always make an odd)
 $temp .= $tokens[$j] . $delimiter;
 // save memory.
 $tokens[$j] = "";
 }

 } // for..
 } // else
 }
 }

 return $output;
}

$dbms_schema = 'yourfile.sql';

$sql_query = @fread(@fopen($dbms_schema, 'r'), @filesize($dbms_schema)) or die('problem ');
$sql_query = remove_remarks($sql_query);
$sql_query = split_sql_file($sql_query, ';');

$host = 'localhost';
$user = 'user';
$pass = 'pass';
$db = 'database_name';

//In case mysql is deprecated use mysqli functions. 
mysqli_connect($host,$user,$pass) or die('error connection');
mysqli_select_db($db) or die('error database selection');

$i=1;
foreach($sql_query as $sql){
echo $i++;
echo "&lt;br /&gt;";
mysql_query($sql) or die('error in query');
}

?&gt;
</code></pre>

blocks|key|1737181|text|$db+=+new+PDO($dsn,+$user,+$password);

$sql+=+file_get_contents('file.sql');

$qr+=+$db->exec($sql);|type|code-block|depth|inlineStyleRanges|entityRanges|data|syntax|javascript|1737182|unstyled|entityMap^0|0^^$0|@$1|2|3|4|5|6|7|G|8|@]|9|@]|A|$B|C]]|$1|D|3|-4|5|E|7|H|8|@]|9|@]|A|$]]]|F|$]]

<pre><code>$db = new PDO($dsn, $user, $password);

$sql = file_get_contents('file.sql');

$qr = $db-&gt;exec($sql);
</code></pre>

blocks|key|1522204|text|这是用php还原sql的最佳代码，可以使用100%25的好东西！非常感谢|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1522205|$file_content+=+file('myfile.sql');
$query+=+"";
foreach($file_content+as+$sql_line){
if(trim($sql_line)+!=+""+&&+strpos($sql_line,+"--")+===+false){
+$query+.=+$sql_line;
+if+(substr(rtrim($query),+-1)+==+';'){
+++echo+$query;
+++$result+=+mysql_query($query)or+die(mysql_error());
+++$query+=+"";
++}
+}
}|code-block|syntax|javascript|1522206|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

This The Best Code For restore sql by php can use 100% Goooood!
 Thank A lot 

<pre><code>$file_content = file('myfile.sql');
$query = "";
foreach($file_content as $sql_line){
if(trim($sql_line) != "" &amp;&amp; strpos($sql_line, "--") === false){
 $query .= $sql_line;
 if (substr(rtrim($query), -1) == ';'){
 echo $query;
 $result = mysql_query($query)or die(mysql_error());
 $query = "";
 }
 }
}
</code></pre>

blocks|key|1522228|text|试试这个：|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1522229|//+SQL+File
$SQLFile+=+'YourSQLFile.sql';

//+Server+Name
$hostname+=+'localhost';

//+User+Name
$db_user+=+'root';

//+User+Password
$db_password+=+'';

//+DBName
$database_name+=+'YourDBName';

//+Connect+MySQL
$link+=+mysql_connect($hostname,+$db_user,+$db_password);

if+(!$link)+{
die("MySQL+Connection+error");
}

//+Select+MySQL+DB
mysql_select_db($database_name,+$link)+or+die("Wrong+MySQL+Database");

//+Function+For+Run+Multiple+Query+From+.SQL+File
function+MultiQuery($sqlfile,+$sqldelimiter+=+';')+{
set_time_limit(0);

if+(is_file($sqlfile)+===+true)+{
$sqlfile+=+fopen($sqlfile,+'r');

if+(is_resource($sqlfile)+===+true)+{
$query+=+array();
echo+"<table+cellspacing='3'+cellpadding='3'+border='0'>";

while+(feof($sqlfile)+===+false)+{
$query[]+=+fgets($sqlfile);

if+(preg_match('~'+.+preg_quote($sqldelimiter,+'~')+.+'\s*$~iS',+end($query))+===+1)+{
$query+=+trim(implode('',+$query));

if+(mysql_query($query)+===+false)+{
echo+'<tr><td>ERROR:</td><td>+'+.+$query+.+'</td></tr>';
}+else+{
echo+'<tr><td>SUCCESS:</td><td>'+.+$query+.+'</td></tr>';
}

while+(ob_get_level()+&gt;+0)+{
ob_end_flush();
}

flush();
}

if+(is_string($query)+===+true)+{
$query+=+array();
}
}
echo+"</table>";

return+fclose($sqlfile);
}
}

return+false;
}

/*+*+*+Use+Function+Like+This:+**+*/

MultiQuery($SQLFile);|code-block|syntax|javascript|1522230|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

Try This:

<pre><code>// SQL File
$SQLFile = 'YourSQLFile.sql';

// Server Name
$hostname = 'localhost';

// User Name
$db_user = 'root';

// User Password
$db_password = '';

// DBName
$database_name = 'YourDBName';

// Connect MySQL
$link = mysql_connect($hostname, $db_user, $db_password);

if (!$link) {
die("MySQL Connection error");
}

// Select MySQL DB
mysql_select_db($database_name, $link) or die("Wrong MySQL Database");

// Function For Run Multiple Query From .SQL File
function MultiQuery($sqlfile, $sqldelimiter = ';') {
set_time_limit(0);

if (is_file($sqlfile) === true) {
$sqlfile = fopen($sqlfile, 'r');

if (is_resource($sqlfile) === true) {
$query = array();
echo "&lt;table cellspacing='3' cellpadding='3' border='0'&gt;";

while (feof($sqlfile) === false) {
$query[] = fgets($sqlfile);

if (preg_match('~' . preg_quote($sqldelimiter, '~') . '\s*$~iS', end($query)) === 1) {
$query = trim(implode('', $query));

if (mysql_query($query) === false) {
echo '&lt;tr&gt;&lt;td&gt;ERROR:&lt;/td&gt;&lt;td&gt; ' . $query . '&lt;/td&gt;&lt;/tr&gt;';
} else {
echo '&lt;tr&gt;&lt;td&gt;SUCCESS:&lt;/td&gt;&lt;td&gt;' . $query . '&lt;/td&gt;&lt;/tr&gt;';
}

while (ob_get_level() &amp;gt; 0) {
ob_end_flush();
}

flush();
}

if (is_string($query) === true) {
$query = array();
}
}
echo "&lt;/table&gt;";

return fclose($sqlfile);
}
}

return false;
}

/* * * Use Function Like This: ** */

MultiQuery($SQLFile);
</code></pre>

blocks|key|1737307|text|我希望下面的代码能很好地解决你的问题。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1737308|//Empty+all+tables'+contents

$result_t+=+mysql_query("SHOW+TABLES");
while($row+=+mysql_fetch_assoc($result_t))
{
mysql_query("TRUNCATE+"+.+$row['Tables_in_'+.+$mysql_database]);
}
//+Temporary+variable,+used+to+store+current+query
$templine+=+'';
//+Read+in+entire+file
$lines+=+file($filename);
//+Loop+through+each+line
foreach+($lines+as+$line)
{
//+Skip+it+if+it's+a+comment
if+(substr($line,+0,+2)+==+'--'+%7C%7C+$line+==+'')
++++continue;

//+Add+this+line+to+the+current+segment
$templine+.=+$line;
//+If+it+has+a+semicolon+at+the+end,+it's+the+end+of+the+query
if+(substr(trim($line),+-1,+1)+==+';')
{
++++//+Perform+the+query
++++mysql_query($templine)+or+print('Error+performing+query+\''+.+$templine+.+'\':+'+.+mysql_error()+.+'<br+/><br+/>');
++++//+Reset+temp+variable+to+empty
++++$templine+=+'';
}
}

?>|code-block|syntax|javascript|1737309|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

I hope the following code will solve your problem pretty well. 
 

<pre><code>//Empty all tables' contents

$result_t = mysql_query("SHOW TABLES");
while($row = mysql_fetch_assoc($result_t))
{
mysql_query("TRUNCATE " . $row['Tables_in_' . $mysql_database]);
}
// Temporary variable, used to store current query
$templine = '';
// Read in entire file
$lines = file($filename);
// Loop through each line
foreach ($lines as $line)
{
// Skip it if it's a comment
if (substr($line, 0, 2) == '--' || $line == '')
 continue;

// Add this line to the current segment
$templine .= $line;
// If it has a semicolon at the end, it's the end of the query
if (substr(trim($line), -1, 1) == ';')
{
 // Perform the query
 mysql_query($templine) or print('Error performing query \'&lt;strong&gt;' . $templine . '\': ' . mysql_error() . '&lt;br /&gt;&lt;br /&gt;');
 // Reset temp variable to empty
 $templine = '';
}
}

?&gt;
</code></pre>

blocks|key|1737346|text|加载和解析phpmyadmin转储或mysql转储文件的最简单、最快速的方法。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1737347|$+mysql+-u+username+-p+-h+localhost+dbname+<+dumpfile.sql+|code-block|syntax|javascript|1737348|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

The easiest and fastest way to load &amp; parse phpmyadmin dump or mysql dump file..

<pre><code>$ mysql -u username -p -h localhost dbname &lt; dumpfile.sql 
</code></pre>

blocks|key|1737385|text|Plahcinski解决方案的更新解决方案。或者，对于更大的文件，您可以使用fopen和fread：|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1737386|$fp+=+file('database.sql',+FILE_IGNORE_NEW_LINES+%7C+FILE_SKIP_EMPTY_LINES);
$query+=+'';
foreach+($fp+as+$line)+{
++++if+($line+!=+''+&&+strpos($line,+'--')+===+false)+{
++++++++$query+.=+$line;
++++++++if+(substr($query,+-1)+==+';')+{
++++++++++++mysql_query($query);
++++++++++++$query+=+'';
++++++++}
++++}
}|code-block|syntax|javascript|1737387|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

An updated solution of Plahcinski solution. Alternatively you can use fopen and fread for bigger files:

<pre><code>$fp = file('database.sql', FILE_IGNORE_NEW_LINES | FILE_SKIP_EMPTY_LINES);
$query = '';
foreach ($fp as $line) {
 if ($line != '' &amp;&amp; strpos($line, '--') === false) {
 $query .= $line;
 if (substr($query, -1) == ';') {
 mysql_query($query);
 $query = '';
 }
 }
}
</code></pre>

blocks|key|1522417|text|在我的项目中，我使用了next+solution：|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1522418|<?php

/**
+*+Import+SQL+from+file
+*
+*+@param+string+path+to+sql+file
+*/
function+sqlImport($file)
{

++++$delimiter+=+';';
++++$file+=+fopen($file,+'r');
++++$isFirstRow+=+true;
++++$isMultiLineComment+=+false;
++++$sql+=+'';

++++while+(!feof($file))+{

++++++++$row+=+fgets($file);

++++++++//+remove+BOM+for+utf-8+encoded+file
++++++++if+($isFirstRow)+{
++++++++++++$row+=+preg_replace('/%5E\x{EF}\x{BB}\x{BF}/',+'',+$row);
++++++++++++$isFirstRow+=+false;
++++++++}

++++++++//+1.+ignore+empty+string+and+comment+row
++++++++if+(trim($row)+==+''+%7C%7C+preg_match('/%5E\s*(#%7C--\s)/sUi',+$row))+{
++++++++++++continue;
++++++++}

++++++++//+2.+clear+comments
++++++++$row+=+trim(clearSQL($row,+$isMultiLineComment));

++++++++//+3.+parse+delimiter+row
++++++++if+(preg_match('/%5EDELIMITER\s%2B[%5E+]%2B/sUi',+$row))+{
++++++++++++$delimiter+=+preg_replace('/%5EDELIMITER\s%2B([%5E+]%2B)$/sUi',+'$1',+$row);
++++++++++++continue;
++++++++}

++++++++//+4.+separate+sql+queries+by+delimiter
++++++++$offset+=+0;
++++++++while+(strpos($row,+$delimiter,+$offset)+!==+false)+{
++++++++++++$delimiterOffset+=+strpos($row,+$delimiter,+$offset);
++++++++++++if+(isQuoted($delimiterOffset,+$row))+{
++++++++++++++++$offset+=+$delimiterOffset+%2B+strlen($delimiter);
++++++++++++}+else+{
++++++++++++++++$sql+=+trim($sql+.+'+'+.+trim(substr($row,+0,+$delimiterOffset)));
++++++++++++++++query($sql);

++++++++++++++++$row+=+substr($row,+$delimiterOffset+%2B+strlen($delimiter));
++++++++++++++++$offset+=+0;
++++++++++++++++$sql+=+'';
++++++++++++}
++++++++}
++++++++$sql+=+trim($sql+.+'+'+.+$row);
++++}
++++if+(strlen($sql)+>+0)+{
++++++++query($row);
++++}

++++fclose($file);
}

/**
+*+Remove+comments+from+sql
+*
+*+@param+string+sql
+*+@param+boolean+is+multicomment+line
+*+@return+string
+*/
function+clearSQL($sql,+&$isMultiComment)
{
++++if+($isMultiComment)+{
++++++++if+(preg_match('#\*/#sUi',+$sql))+{
++++++++++++$sql+=+preg_replace('#%5E.*\*/\s*#sUi',+'',+$sql);
++++++++++++$isMultiComment+=+false;
++++++++}+else+{
++++++++++++$sql+=+'';
++++++++}
++++++++if(trim($sql)+==+''){
++++++++++++return+$sql;
++++++++}
++++}

++++$offset+=+0;
++++while+(preg_match('{--\s%7C#%7C/\*[%5E!]}sUi',+$sql,+$matched,+PREG_OFFSET_CAPTURE,+$offset))+{
++++++++list($comment,+$foundOn)+=+$matched[0];
++++++++if+(isQuoted($foundOn,+$sql))+{
++++++++++++$offset+=+$foundOn+%2B+strlen($comment);
++++++++}+else+{
++++++++++++if+(substr($comment,+0,+2)+==+'/*')+{
++++++++++++++++$closedOn+=+strpos($sql,+'*/',+$foundOn);
++++++++++++++++if+($closedOn+!==+false)+{
++++++++++++++++++++$sql+=+substr($sql,+0,+$foundOn)+.+substr($sql,+$closedOn+%2B+2);
++++++++++++++++}+else+{
++++++++++++++++++++$sql+=+substr($sql,+0,+$foundOn);
++++++++++++++++++++$isMultiComment+=+true;
++++++++++++++++}
++++++++++++}+else+{
++++++++++++++++$sql+=+substr($sql,+0,+$foundOn);
++++++++++++++++break;
++++++++++++}
++++++++}
++++}
++++return+$sql;
}

/**
+*+Check+if+"offset"+position+is+quoted
+*
+*+@param+int+$offset
+*+@param+string+$text
+*+@return+boolean
+*/
function+isQuoted($offset,+$text)
{
++++if+($offset+>+strlen($text))
++++++++$offset+=+strlen($text);

++++$isQuoted+=+false;
++++for+($i+=+0;+$i+<+$offset;+$i%2B%2B)+{
++++++++if+($text[$i]+==+"'")
++++++++++++$isQuoted+=+!$isQuoted;
++++++++if+($text[$i]+==+"\\"+&&+$isQuoted)
++++++++++++$i%2B%2B;
++++}
++++return+$isQuoted;
}

function+query($sql)
{
++++global+$mysqli;
++++//echo+'#SQL+CODE+TO+RUN: '+.+htmlspecialchars($sql)+.+'; ';
++++if+(!$query+=+$mysqli->query($sql))+{
++++++++throw+new+Exception("Cannot+execute+request+to+the+database+{$sql}:+"+.+$mysqli->error);
++++}
}

set_time_limit(0);

$mysqli+=+new+mysqli('localhost',+'root',+'',+'test');
$mysqli->set_charset("utf8");

header('Content-Type:+text/html;charset=utf-8');
sqlImport('import.sql');

echo+"Peak+MB:+",+memory_get_peak_usage(true)/1024/1024;|code-block|syntax|javascript|1522419|在测试sql文件(41Mb)上，内存使用峰值:+3.25Mb|1522420|entityMap^0|0|0|0^^$0|@$1|2|3|4|5|6|7|K|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|L|8|@]|9|@]|A|$E|F]]|$1|G|3|H|5|6|7|M|8|@]|9|@]|A|$]]|$1|I|3|-4|5|6|7|N|8|@]|9|@]|A|$]]]|J|$]]

In my projects I've used next solution:

<pre><code>&lt;?php

/**
 * Import SQL from file
 *
 * @param string path to sql file
 */
function sqlImport($file)
{

 $delimiter = ';';
 $file = fopen($file, 'r');
 $isFirstRow = true;
 $isMultiLineComment = false;
 $sql = '';

 while (!feof($file)) {

 $row = fgets($file);

 // remove BOM for utf-8 encoded file
 if ($isFirstRow) {
 $row = preg_replace('/^\x{EF}\x{BB}\x{BF}/', '', $row);
 $isFirstRow = false;
 }

 // 1. ignore empty string and comment row
 if (trim($row) == '' || preg_match('/^\s*(#|--\s)/sUi', $row)) {
 continue;
 }

 // 2. clear comments
 $row = trim(clearSQL($row, $isMultiLineComment));

 // 3. parse delimiter row
 if (preg_match('/^DELIMITER\s+[^ ]+/sUi', $row)) {
 $delimiter = preg_replace('/^DELIMITER\s+([^ ]+)$/sUi', '$1', $row);
 continue;
 }

 // 4. separate sql queries by delimiter
 $offset = 0;
 while (strpos($row, $delimiter, $offset) !== false) {
 $delimiterOffset = strpos($row, $delimiter, $offset);
 if (isQuoted($delimiterOffset, $row)) {
 $offset = $delimiterOffset + strlen($delimiter);
 } else {
 $sql = trim($sql . ' ' . trim(substr($row, 0, $delimiterOffset)));
 query($sql);

 $row = substr($row, $delimiterOffset + strlen($delimiter));
 $offset = 0;
 $sql = '';
 }
 }
 $sql = trim($sql . ' ' . $row);
 }
 if (strlen($sql) &gt; 0) {
 query($row);
 }

 fclose($file);
}

/**
 * Remove comments from sql
 *
 * @param string sql
 * @param boolean is multicomment line
 * @return string
 */
function clearSQL($sql, &amp;$isMultiComment)
{
 if ($isMultiComment) {
 if (preg_match('#\*/#sUi', $sql)) {
 $sql = preg_replace('#^.*\*/\s*#sUi', '', $sql);
 $isMultiComment = false;
 } else {
 $sql = '';
 }
 if(trim($sql) == ''){
 return $sql;
 }
 }

 $offset = 0;
 while (preg_match('{--\s|#|/\*[^!]}sUi', $sql, $matched, PREG_OFFSET_CAPTURE, $offset)) {
 list($comment, $foundOn) = $matched[0];
 if (isQuoted($foundOn, $sql)) {
 $offset = $foundOn + strlen($comment);
 } else {
 if (substr($comment, 0, 2) == '/*') {
 $closedOn = strpos($sql, '*/', $foundOn);
 if ($closedOn !== false) {
 $sql = substr($sql, 0, $foundOn) . substr($sql, $closedOn + 2);
 } else {
 $sql = substr($sql, 0, $foundOn);
 $isMultiComment = true;
 }
 } else {
 $sql = substr($sql, 0, $foundOn);
 break;
 }
 }
 }
 return $sql;
}

/**
 * Check if "offset" position is quoted
 *
 * @param int $offset
 * @param string $text
 * @return boolean
 */
function isQuoted($offset, $text)
{
 if ($offset &gt; strlen($text))
 $offset = strlen($text);

 $isQuoted = false;
 for ($i = 0; $i &lt; $offset; $i++) {
 if ($text[$i] == "'")
 $isQuoted = !$isQuoted;
 if ($text[$i] == "\\" &amp;&amp; $isQuoted)
 $i++;
 }
 return $isQuoted;
}

function query($sql)
{
 global $mysqli;
 //echo '#&lt;strong&gt;SQL CODE TO RUN:&lt;/strong&gt;&lt;br&gt;' . htmlspecialchars($sql) . ';&lt;br&gt;&lt;br&gt;';
 if (!$query = $mysqli-&gt;query($sql)) {
 throw new Exception("Cannot execute request to the database {$sql}: " . $mysqli-&gt;error);
 }
}

set_time_limit(0);

$mysqli = new mysqli('localhost', 'root', '', 'test');
$mysqli-&gt;set_charset("utf8");

header('Content-Type: text/html;charset=utf-8');
sqlImport('import.sql');

echo "Peak MB: ", memory_get_peak_usage(true)/1024/1024;
</code></pre>

On test sql file (41Mb) memory peak usage: 3.25Mb

blocks|key|1522466|text|这对我来说真的很有效：|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1522467|/*+load+sql-commands+from+a+sql+file+*/
function+loadSQLFromFile($url)
{
++++//+ini_set+(+'memory_limit',+'512M'+);
++++//+set_time_limit+(+0+);

++++global+$settings_database_name;
++++global+$mysqli_object;+global+$worked;+$worked+=+false;

++++$sql_query+=+"";

++++//+read+line+by+line
++++$lines+=+file($url);
++++$count+=+count($lines);

++++for($i+=+0;$i<$count;$i%2B%2B)
++++{
++++++++$line+=+$lines[$i];
++++++++$cmd3+=+substr($line,+0,+3);
++++++++$cmd4+=+substr($line,+0,+4);
++++++++$cmd6+=+substr($line,+0,+6);
++++++++if($cmd3+==+"USE")
++++++++{
++++++++++++//+cut+away+USE+``;
++++++++++++$settings_database_name+=+substr($line,+5,+-3);
++++++++}
++++++++else+if($cmd4+==+"DROP")
++++++++{
++++++++++++$mysqli_object->query($line);+//+execute+this+line
++++++++}
++++++++else+if(($cmd6+==+"INSERT")+%7C%7C+($cmd6+==+"CREATE"))
++++++++{
++++++++++++//+sum+all+lines+up+until+;+is+detected
++++++++++++$multiline+=+$line;
++++++++++++while(!strstr($line,+';'))
++++++++++++{
++++++++++++++++$i%2B%2B;
++++++++++++++++$line+=+$lines[$i];
++++++++++++++++$multiline+.=+$line;
++++++++++++}
++++++++++++$multiline+=+str_replace("\n",+"",+$multiline);+//+remove+newlines/linebreaks
++++++++++++$mysqli_object->query($multiline);+//+execute+this+line
++++++++}+++++++
++++}

++++return+$worked;
}
?>|code-block|syntax|javascript|1522468|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

this actually worked for me:

<pre><code>/* load sql-commands from a sql file */
function loadSQLFromFile($url)
{
 // ini_set ( 'memory_limit', '512M' );
 // set_time_limit ( 0 );

 global $settings_database_name;
 global $mysqli_object; global $worked; $worked = false;

 $sql_query = "";

 // read line by line
 $lines = file($url);
 $count = count($lines);

 for($i = 0;$i&lt;$count;$i++)
 {
 $line = $lines[$i];
 $cmd3 = substr($line, 0, 3);
 $cmd4 = substr($line, 0, 4);
 $cmd6 = substr($line, 0, 6);
 if($cmd3 == "USE")
 {
 // cut away USE ``;
 $settings_database_name = substr($line, 5, -3);
 }
 else if($cmd4 == "DROP")
 {
 $mysqli_object-&gt;query($line); // execute this line
 }
 else if(($cmd6 == "INSERT") || ($cmd6 == "CREATE"))
 {
 // sum all lines up until ; is detected
 $multiline = $line;
 while(!strstr($line, ';'))
 {
 $i++;
 $line = $lines[$i];
 $multiline .= $line;
 }
 $multiline = str_replace("\n", "", $multiline); // remove newlines/linebreaks
 $mysqli_object-&gt;query($multiline); // execute this line
 } 
 }

 return $worked;
}
?&gt;
</code></pre>

blocks|key|1522511|text|一些人(Plahcinski)建议使用以下代码：|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1522512|$file_content+=+file('myfile.sql');
$query+=+"";
foreach($file_content+as+$sql_line){
++if(trim($sql_line)+!=+""+&&+strpos($sql_line,+"--")+===+false){
++++$query+.=+$sql_line;
++++if+(substr(rtrim($query),+-1)+==+';'){
++++++echo+$query;
++++++$result+=+mysql_query($query)or+die(mysql_error());
++++++$query+=+"";
++++}
++}
+}|code-block|syntax|javascript|1522513|但我会用适合我的版本更新它：|1522514|+//selecting+my+database
++++$database+=+'databaseTitleInFile';
++++$selectDatabase+=+mysql_select_db($database,+$con);
++++if(!+$selectDatabase+)
++++{
++++++die('Could+not+select+the+database:+'+.+mysql_error());
++++}
++++echo+"The+database+"+.+$database+.+"+selected+successfully\n";
//reading+the+file
++++$file_path='..\yourPath\to\File';
++++if(!file_exists($file_path)){
++++++++echo+"File+Not+Exists";
++++}
++++$file_content+=+file_get_contents($file_path);
++++$array+=+explode("\n",+$file_content)
//making+queries
++++$query+=+"";
++++++++foreach($array+as+$sql_line){
$sql_line=trim($sql_line);
++++++++++if($sql_line+!=+""+&&+substr($sql_line,+0,+2)+===+"--"+&&+strpos($sql_line,+"/*")+===+false){
++++++++++++$query+.=+$sql_line;
++++++++++++if+(substr(rtrim($query),+-1)+==+';'){
++++++++++++++$result+=+mysql_query($query)or+die(mysql_error());
++++++++++++++$query+=+"";
++++++++++++}
++++++++++}
+++++++++}|1522515|因为它更全面。;-)|1522516|entityMap^0|0|0|0|0|0^^$0|@$1|2|3|4|5|6|7|O|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|P|8|@]|9|@]|A|$E|F]]|$1|G|3|H|5|6|7|Q|8|@]|9|@]|A|$]]|$1|I|3|J|5|D|7|R|8|@]|9|@]|A|$E|F]]|$1|K|3|L|5|6|7|S|8|@]|9|@]|A|$]]|$1|M|3|-4|5|6|7|T|8|@]|9|@]|A|$]]]|N|$]]

Some guys (Plahcinski) suggested this code:

<pre><code>$file_content = file('myfile.sql');
$query = "";
foreach($file_content as $sql_line){
 if(trim($sql_line) != "" &amp;&amp; strpos($sql_line, "--") === false){
 $query .= $sql_line;
 if (substr(rtrim($query), -1) == ';'){
 echo $query;
 $result = mysql_query($query)or die(mysql_error());
 $query = "";
 }
 }
 }
</code></pre>

but I would update it with the one which worked for me:

<pre><code> //selecting my database
 $database = 'databaseTitleInFile';
 $selectDatabase = mysql_select_db($database, $con);
 if(! $selectDatabase )
 {
 die('Could not select the database: ' . mysql_error());
 }
 echo "The database " . $database . " selected successfully\n";
//reading the file
 $file_path='..\yourPath\to\File';
 if(!file_exists($file_path)){
 echo "File Not Exists";
 }
 $file_content = file_get_contents($file_path);
 $array = explode("\n", $file_content)
//making queries
 $query = "";
 foreach($array as $sql_line){
$sql_line=trim($sql_line);
 if($sql_line != "" &amp;&amp; substr($sql_line, 0, 2) === "--" &amp;&amp; strpos($sql_line, "/*") === false){
 $query .= $sql_line;
 if (substr(rtrim($query), -1) == ';'){
 $result = mysql_query($query)or die(mysql_error());
 $query = "";
 }
 }
 }
</code></pre>

because it is more comprehensive. ;-)

blocks|key|1737635|text|这可能会有帮助-->|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1737636|它所做的或多或少是首先获取给定给函数的字符串(file.sql的file_get_contents()值)，然后删除所有的换行符。然后，它用";“字符拆分数据。接下来，它进入while循环，查看创建的数组的每一行。如果行包含“`”字符，它将知道这是一个查询，并针对给定行数据执行myquery()函数。|1737637|代码：|1737638|function+myquery($query)+{

mysql_connect(dbhost,+dbuser,+dbpass);

mysql_select_db(dbname);

$result+=+mysql_query($query);

if+(!mysql_errno()+&&+@mysql_num_rows($result)+>+0)+{
}

else+{

$result="not";
}
mysql_close();

return+$result;

}



function+mybatchquery+($str)+{

$sql+=+str_replace("\n","",$str)

$sql+=+explode(";",$str);

$x=0;

while+(isset($str[$x]))+{

if+(preg_match("/(\w%7C\W)%2B`(\w%7C\W)%2B)+{

myquery($str[$x]);

}

$x%2B%2B

}

return+TRUE;

}




function+myrows($result)+{

$rows+=+@mysql_num_rows($result);

return+$rows;
}




function+myarray($result)+{

$array+=+mysql_fetch_array($result);

return+$array;
}




function+myescape($query)+{

$escape+=+mysql_escape_string($query);

return+$escape;
}



$str+=+file_get_contents("foo.sql");
mybatchquery($str);|code-block|syntax|javascript|1737639|entityMap^0|0|0|0|0^^$0|@$1|2|3|4|5|6|7|M|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|N|8|@]|9|@]|A|$]]|$1|D|3|E|5|6|7|O|8|@]|9|@]|A|$]]|$1|F|3|G|5|H|7|P|8|@]|9|@]|A|$I|J]]|$1|K|3|-4|5|6|7|Q|8|@]|9|@]|A|$]]]|L|$]]

This may be helpful -->

More or less what it does is to first take the string given to the function (the file_get_contents() value of your file.sql) and remove all the line breaks. Then it splits the data by the ";" character. Next it goes into a while loop, looking at each line of the array that is created. If the line contains the " ` " character, it will know it is a query and execture the myquery() function for the given line data.

Code:

<pre><code>function myquery($query) {

mysql_connect(dbhost, dbuser, dbpass);

mysql_select_db(dbname);

$result = mysql_query($query);

if (!mysql_errno() &amp;&amp; @mysql_num_rows($result) &gt; 0) {
}

else {

$result="not";
}
mysql_close();

return $result;

}



function mybatchquery ($str) {

$sql = str_replace("\n","",$str)

$sql = explode(";",$str);

$x=0;

while (isset($str[$x])) {

if (preg_match("/(\w|\W)+`(\w|\W)+) {

myquery($str[$x]);

}

$x++

}

return TRUE;

}




function myrows($result) {

$rows = @mysql_num_rows($result);

return $rows;
}




function myarray($result) {

$array = mysql_fetch_array($result);

return $array;
}




function myescape($query) {

$escape = mysql_escape_string($query);

return $escape;
}



$str = file_get_contents("foo.sql");
mybatchquery($str);
</code></pre>

blocks|key|1522692|text|我有一个环境，其中没有mysql工具或phpmyadmin，只有我的php应用程序连接到不同主机上的mysql服务器，但我需要运行mysqldump或myadmin导出的脚本。为了解决这个问题，正如我提到的here，我创建了一个脚本multi_query|type|unstyled|depth|inlineStyleRanges|offset|length|style|CODE|entityRanges|data|1522693|它可以在没有mysql命令行工具的情况下处理mysqldump输出和phpmyadmin导出。我还做了一些逻辑，根据Rails等数据库中存储的时间戳来处理多个迁移文件。我知道它需要更多的错误处理，但目前已经为我做了这项工作。|1522694|查看：https://github.com/kepes/php-migration|1522695|它是纯php的，不需要任何其他工具。如果您不使用它处理用户输入，只使用开发人员编写的脚本或导出工具，则可以安全地使用它。|1522696|entityMap|0|LINK|mutability|MUTABLE|url|https://stackoverflow.com/questions/4027769/running-mysql-sql-files-in-php/28051527#28051527|1|https://github.com/kepes/php-migration^0|38|B|2V|4|0|0|0|3|12|1|0|0^^$0|@$1|2|3|4|5|6|7|V|8|@$9|W|A|X|B|C]]|D|@$9|Y|A|Z|1|10]]|E|$]]|$1|F|3|G|5|6|7|11|8|@]|D|@]|E|$]]|$1|H|3|I|5|6|7|12|8|@]|D|@$9|13|A|14|1|15]]|E|$]]|$1|J|3|K|5|6|7|16|8|@]|D|@]|E|$]]|$1|L|3|-4|5|6|7|17|8|@]|D|@]|E|$]]]|M|$N|$5|O|P|Q|E|$R|S]]|T|$5|O|P|Q|E|$R|U]]]]

I have an environment where no mysql tool or phpmyadmin just my php application connecting to a mysql server on a different host but I need to run scripts exported by mysqldump or myadmin. To solve the problem I created a script <code>multi_query</code> as I mentioned <a href="https://stackoverflow.com/questions/4027769/running-mysql-sql-files-in-php/28051527#28051527" title="here">here</a>

It can process mysqldump output and phpmyadmin exports without mysql command line tool. I also made some logic to process multiple migration files based on timestamp stored in DB like Rails. I know it needs more error handling but currently does the work for me.

Check it out: <a href="https://github.com/kepes/php-migration" rel="nofollow noreferrer">https://github.com/kepes/php-migration</a>

It's pure php and don't need any other tools. If you don't process user input with it only scripts made by developers or export tools you can use it safely.

blocks|key|1737731|text|由于我无法对答案发表评论，请注意使用以下解决方案：|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1737732|$db+=+new+PDO($dsn,+$user,+$password);

$sql+=+file_get_contents('file.sql');

$qr+=+$db->exec($sql);|code-block|syntax|javascript|1737733|PHP+PDO+https://bugs.php.net/bug.php?id=61613中有一个错误|offset|length|1737734|db->exec('SELECT+1;+invalidstatement;+SELECT+2');|1737735|不会出错或返回false+(在PHP+5.5.14上测试过)。|1737736|entityMap|0|LINK|mutability|MUTABLE|url|https://bugs.php.net/bug.php?id=61613^0|0|0|8|11|0|0|0|0^^$0|@$1|2|3|4|5|6|7|W|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|X|8|@]|9|@]|A|$E|F]]|$1|G|3|H|5|6|7|Y|8|@]|9|@$I|Z|J|10|1|11]]|A|$]]|$1|K|3|L|5|D|7|12|8|@]|9|@]|A|$E|F]]|$1|M|3|N|5|6|7|13|8|@]|9|@]|A|$]]|$1|O|3|-4|5|6|7|14|8|@]|9|@]|A|$]]]|P|$Q|$5|R|S|T|A|$U|V]]]]

Since I can't comment on answer, beware to use following solution:

<pre><code>$db = new PDO($dsn, $user, $password);

$sql = file_get_contents('file.sql');

$qr = $db-&gt;exec($sql);
</code></pre>

There is a bug in PHP PDO <a href="https://bugs.php.net/bug.php?id=61613" rel="noreferrer">https://bugs.php.net/bug.php?id=61613</a>

<pre><code>db-&gt;exec('SELECT 1; invalidstatement; SELECT 2');
</code></pre>

won't error out or return false (tested on PHP 5.5.14).

blocks|key|1522791|text|我注意到PostgreSQL+PDO驱动程序不允许您运行以分号分隔的脚本。为了使用PDO在任何数据库上运行.sql文件，有必要自己拆分PHP代码中的语句。这里有一个似乎工作得很好的解决方案：|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1522792|https://github.com/diontruter/migrate/blob/master/src/Diontruter/Migrate/SqlScriptParser.php|offset|length|1522793|被引用的类已经以独立于数据库的方式为我完成了这项工作，如果有任何问题，请给我消息。下面是在将脚本添加到项目中后如何使用该脚本：|1522794|$pdo+=+new+PDO($connectionString,+$userName,+$password);
$pdo->setAttribute(PDO::ATTR_ERRMODE,+PDO::ERRMODE_EXCEPTION);
$parser+=+new+SqlScriptParser();
$sqlStatements+=+$parser->parse($fileName);
foreach+($sqlStatements+as+$statement)+{
++++$distilled+=+$parser->removeComments($statement);
++++if+(!empty($distilled))+{
++++++++$statement+=+$pdo->prepare($sql);
++++++++$affectedRows+=+$statement->execute();
++++}
}|code-block|syntax|javascript|1522795|entityMap|0|LINK|mutability|MUTABLE|url^0|0|0|2K|0|0|0|0^^$0|@$1|2|3|4|5|6|7|T|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|U|8|@]|9|@$D|V|E|W|1|X]]|A|$]]|$1|F|3|G|5|6|7|Y|8|@]|9|@]|A|$]]|$1|H|3|I|5|J|7|Z|8|@]|9|@]|A|$K|L]]|$1|M|3|-4|5|6|7|10|8|@]|9|@]|A|$]]]|N|$O|$5|P|Q|R|A|$S|C]]]]

I noticed that the PostgreSQL PDO driver does not allow you to run scripts separated by semicolons. In order to run a .sql file on any database using PDO it is necessary to split the statements in PHP code yourself. Here is a solution that seems to work quite well:

<a href="https://github.com/diontruter/migrate/blob/master/src/Diontruter/Migrate/SqlScriptParser.php" rel="nofollow noreferrer">https://github.com/diontruter/migrate/blob/master/src/Diontruter/Migrate/SqlScriptParser.php</a>

The referenced class has done the trick for me in a database independent way, please message me if there are any issues. Here is how you could use the script after adding it to your project:

<pre><code>$pdo = new PDO($connectionString, $userName, $password);
$pdo-&gt;setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
$parser = new SqlScriptParser();
$sqlStatements = $parser-&gt;parse($fileName);
foreach ($sqlStatements as $statement) {
 $distilled = $parser-&gt;removeComments($statement);
 if (!empty($distilled)) {
 $statement = $pdo-&gt;prepare($sql);
 $affectedRows = $statement-&gt;execute();
 }
}
</code></pre>

blocks|key|1737857|text|这是我正在做的一个项目。基本上，获取任何文本文件并提取SQL语句，而忽略注释和不必要的换行符。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1737858|<?php

++/*
+++++ingestSql(string)+:+string

+++++Read+the+contents+of+a+SQL+batch+file,+stripping+away+comments+and
+++++joining+statements+that+are+broken+over+multiple+lines+with+the+goal
+++++of+producing+lines+of+sql+statements+that+can+be+successfully+executed
+++++by+PDO+exec()+or+execute()+functions.

+++++For+example:
+++++++--+My+SQL+Batch
+++++++CREATE+TABLE+foo(
+++++++++bar+VARCHAR(80),
+++++++++baz+INT+NOT+NULL);

+++++Becomes:
+++++++CREATE+TABLE+foo(bar+VARCHAR(80),+baz+INT+NOT+NULL);
++*/

++function+ingestSql($sqlFilePath=__DIR__+.+"/create-db.sql")+{
++++$sqlFile+=+file($sqlFilePath);
++++$ingestedSql+=+"";
+++++$statement+=+"";
++++foreach($sqlFile+as+$line)+{

++++++//+Ignore+anything+between+a+double-dash+and+the+end+of+the+line.
++++++$commentStart+=+strpos($line,+"--");
++++++if+($commentStart+!==+false)+{
++++++++$line+=+substr($line,+0,+$commentStart);
++++++}

++++++//+Only+process+non-blank+lines.
++++++if+(strlen($line))+{

++++++++//+Remove+any+leading+and+trailing+whitespace+and+append+what's
++++++++//+left+of+the+line+to+the+current+statement.
++++++++$line+=+trim($line);
++++++++$statement+.=+$line;

++++++++//+A+semi-colon+ends+the+current+statement.++Otherwise+what+was+a
++++++++//+newline+becomes+a+single+space;
++++++++if+(substr($statement,+-1)+==+";")+{
++++++++++$ingestedSql+.=+$statement;
++++++++++$statement+=+"\n";
++++++++}
++++++++else+{
++++++++++$statement+.=+"+";
++++++++}
++++++}
++++}

++++return+$ingestedSql;
++}

?>|code-block|syntax|javascript|1737859|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

This is from a project I am working on. Basically takes any text file and extracts the SQL statements while ignoring comments and gratuitous line breaks.

<pre><code>&lt;?php

 /*
 ingestSql(string) : string

 Read the contents of a SQL batch file, stripping away comments and
 joining statements that are broken over multiple lines with the goal
 of producing lines of sql statements that can be successfully executed
 by PDO exec() or execute() functions.

 For example:
 -- My SQL Batch
 CREATE TABLE foo(
 bar VARCHAR(80),
 baz INT NOT NULL);

 Becomes:
 CREATE TABLE foo(bar VARCHAR(80), baz INT NOT NULL);
 */

 function ingestSql($sqlFilePath=__DIR__ . "/create-db.sql") {
 $sqlFile = file($sqlFilePath);
 $ingestedSql = "";
 $statement = "";
 foreach($sqlFile as $line) {

 // Ignore anything between a double-dash and the end of the line.
 $commentStart = strpos($line, "--");
 if ($commentStart !== false) {
 $line = substr($line, 0, $commentStart);
 }

 // Only process non-blank lines.
 if (strlen($line)) {

 // Remove any leading and trailing whitespace and append what's
 // left of the line to the current statement.
 $line = trim($line);
 $statement .= $line;

 // A semi-colon ends the current statement. Otherwise what was a
 // newline becomes a single space;
 if (substr($statement, -1) == ";") {
 $ingestedSql .= $statement;
 $statement = "\n";
 }
 else {
 $statement .= " ";
 }
 }
 }

 return $ingestedSql;
 }

?&gt;
</code></pre>

blocks|key|1737884|text|++++$sql+=+file_get_contents("sql.sql");|type|code-block|depth|inlineStyleRanges|entityRanges|data|syntax|javascript|1737885|这似乎是最简单的答案|unstyled|1737886|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$B|C]]|$1|D|3|E|5|F|7|J|8|@]|9|@]|A|$]]|$1|G|3|-4|5|F|7|K|8|@]|9|@]|A|$]]]|H|$]]

<pre><code> $sql = file_get_contents(&quot;sql.sql&quot;);
</code></pre>
Seems to be the simplest answer

I'm creating an installation script for an application that I'm developing and need to create databases dynamically from within PHP. I've got it to create the database but now I need to load in several .sql files. I had planned to open the file and mysql_query it a line at a time - until I looked at the schema files and realised they aren't just one query per line.

So, how do I load an sql file from within PHP (as phpMyAdmin does with its import command)?

Loading .sql files from within PHP

命令行工具

PostgreSQL

数据库

服务器

MySQL

我正在为正在开发的应用程序创建一个安装脚本，并且需要从PHP中动态创建数据库。我已经用它创建了数据库，但是现在我需要加载几个.sql文件。我原本计划打开该文件，然后一次查询一行-直到我查看了模式文件并意识到它们不仅仅是每行一个查询。那么，如何从PHP中加载sql文件(就像phpMyAdmin使用其import命令一样)...

问从PHP中加载.sql文件
EN

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问从PHP中加载.sql文件EN

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问从PHP中加载.sql文件
EN