PHP執行批量mysql語句

當有多條mysql語句連起來需要執行，比如

$sqls= “insert table a values(1,2); insert table a values(2,3);”

需要執行的話php中可以使用的方法有三個：

mysql_query

pdo

mysqli

三種方法當sqls語句沒有問題的時候都是可以的。

但是

第一條sql錯誤：三個方法都傳回false

第一條sql正确，第二條sql錯誤：mysql_query、pdo、 mysqli:query也是傳回true。是以這個時候你是沒法判斷你的sqls是否有那條語句是錯誤的。

解決這種辦法有幾個招：

将每條sql都拆分開來執行。這樣每個語句分開執行就解決了。但是這種方法多出了好幾種方法，是以不可取。

使用cmd執行指令 mysql…. .< sqls.sql, 然後捕獲輸出。這也是一種方法，但是感覺是繞着問題走，應該還有更好的方法。

這個方法可以執行多條sql語句，然後使用mysqli::next_result來設定sql的偏移量，使用mysqli::error擷取目前偏移的sql的錯誤狀态

下面是第三種方法的示例代碼

代碼如下：

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

<code>$sql</code> <code>= config::get(</code><code>'sql'</code><code>);</code>

<code>$content</code> <code>=</code><code>file_get_contents</code><code>(</code><code>$sql</code><code>);</code>

<code>$config</code> <code>= config::get(</code><code>'config'</code><code>)</code>

<code>$mysqli</code> <code>= mysqli_connect(</code><code>$config</code><code>[</code><code>'host'</code><code>],</code><code>$config</code><code>[</code><code>'user'</code><code>],</code><code>$config</code><code>[</code><code>'password'</code><code>],</code><code>$config</code><code>[</code><code>'dbname'</code><code>]);</code>

<code>$ret</code> <code>=</code><code>$mysqli</code><code>-&gt;multi_query(</code><code>$content</code><code>);</code>

<code>if</code><code>(</code><code>$ret</code> <code>=== false) {</code>

<code>    </code><code>echo</code> <code>mysqli_error(</code><code>$mysqli</code><code>);</code>

<code>}</code>

<code>while</code> <code>(mysqli_more_results(</code><code>$mysqli</code><code>)) {</code>

<code>    </code><code>if</code> <code>(mysqli_next_result(</code><code>$mysqli</code><code>) === false) {</code>

<code>        </code><code>echo</code> <code>mysqli_error(</code><code>$mysqli</code><code>);</code>

<code>        </code><code>echo</code> <code>"\r\n"</code><code>;</code>

<code>        </code><code>break</code><code>;</code>

<code>    </code><code>}</code>

<code>$mysqli</code><code>-&gt;close();</code>

這樣的話當sqls語句中任意一條有錯誤的話，程式就會跳出這個錯誤。

如果你要編寫初始化mysql的腳本的話，這招就非常好用了。