PHP + Mysql多個表并行查詢?nèi)绾螌崿F(xiàn)

在PHP-FPM處理HTTP請求時，有時會遇到一個請求需要進行多次MySQL查詢（在報表類應(yīng)用中比較常見）。通常我們會以串行方式查詢：

創(chuàng)新互聯(lián)主要從事成都網(wǎng)站制作、成都做網(wǎng)站、網(wǎng)頁設(shè)計、企業(yè)做網(wǎng)站、公司建網(wǎng)站等業(yè)務(wù)。立足成都服務(wù)額敏,10余年網(wǎng)站建設(shè)經(jīng)驗,價格優(yōu)惠、服務(wù)專業(yè),歡迎來電咨詢建站服務(wù):18980820575

$link?=?new?mysqli();

$rs1?=?$link-query('SELECT?*?FROM?table1');

while?($row?=?$rs1-fetch_row())?{?...?}

$rs2?=?$link-query('SELECT?*?FROM?table2');

while?($row?=?$rs2-fetch_row())?{?...?}

$rs3?=?$link-query('SELECT?*?FROM?table3');

while?($row?=?$rs3-fetch_row())?{?...?}

串行查詢方式有個缺點：在MySQL返回數(shù)據(jù)之前，PHP一直是處于空等的狀態(tài)，不會繼續(xù)往后執(zhí)行。如果數(shù)據(jù)量大或者查詢復(fù)雜，MySQL響應(yīng)可能會比較慢，那么以串行方式查詢會有一些延遲。給用戶最直接的感受就是 Loading… 的圈圈一直打轉(zhuǎn)。

那么有什么辦法可以減少查詢MySQL的時間？用多進程并行查詢不行，因為PHP-FPM 中不允許用 pcntl_fork 一類的調(diào)用。

幸好還有 mysqlnd，mysqlnd提供了類似 stream_select 的機制（見 這篇文章） ，可以做到在單進程中對MySQL并行查詢。這主要運用了mysqli_poll 和 reap_async_query 兩個函數(shù)。

還是通過例子來介紹MySQL并行查詢的實施方法。假設(shè)要并行地向MySQL發(fā)出10個查詢，最基本的代碼應(yīng)該是這樣的：

1.??$links?=?[];

2.??for?($i?=?0;?$i?!==?10;?$i++)?{

3.??????$links[$i]?=?new?mysqli('127.0.0.1',?'user',?'password',?'db1');

4.??????$links[$i]-query('SELECT?SLEEP(1)',?MYSQLI_ASYNC);

5.??}

6.??$allResult?=?[];

7.??while?(!empty($links))?{

8.??????$reads?=?$links;

9.??????$errors?=?$reject?=?[];

10.?????if?(!mysqli_poll($reads,?$errors,?$reject,?null))?{

11.?????????continue;

12.?????}

13.?????foreach?($reads?as?$read)?{

14.?????????$idx?=?array_search($read,?$links,?true);

15.?????????$allResult[$idx]?=?[];

16.?????????$result?=?$read-reap_async_query();

17.?????????while?($row?=?$result-fetch_row())?{

18.?????????????$allResult[$idx][]?=?$row;

19.?????????}

20.?????????$read-close();

21.?????????unset($links[$idx]);

22.?????}

23.?}

解釋下這段代碼的含義：

2~5行，同時發(fā)起10個MySQL連接，并發(fā)出查詢

注意query() 的第二個參數(shù)帶上了 MYSQLI_ASYNC 表示非阻塞查詢

10行，使用mysqli_poll 輪詢10個連接的查詢有無返回

mysqli_poll 的第一個參數(shù)$reads是個數(shù)組，包含需要輪詢那些連接。mysqli_poll 執(zhí)行完后，會改寫$reads，改寫后$reads包含的是那些已經(jīng)有數(shù)據(jù)返回連接。

mysqli_poll的第四個參數(shù)，控制的是輪詢的等待時間，單位是“秒”。如果像本例當(dāng)中設(shè)置為null，那么mysqli_poll輪詢是阻塞的：只有監(jiān)聽的連接中，任意一個連接有數(shù)據(jù)返回了，mysqli_poll才會返回。如果等待時間設(shè)置為0，那么每次執(zhí)行mysqli_poll會立即返回，外層的while會頻繁循環(huán)。

第11~19行，遍歷已經(jīng)有數(shù)據(jù)返回的連接

reap_async_query和普通query一樣，返回的是mysqli_result，可以一行行fetch數(shù)據(jù)

20~21行，對于已經(jīng)獲得了數(shù)據(jù)的連接，下次mysqli_poll就不需要再輪詢這個連接了，所以關(guān)閉連接，并從$links數(shù)組刪除這個連接

當(dāng)所有的連接都返回了數(shù)據(jù)，$links數(shù)組空了，while循環(huán)也就終止了。

使用并行查詢的方式，可以大大縮短處理HTTP請求的時間，假設(shè)本例中的10個SQL查詢，每個需要執(zhí)行1秒。因為是并行，處理所有的查詢，也只需要1秒左右。

php如何跨數(shù)據(jù)庫查詢

1.建立兩個數(shù)據(jù)庫連接，查詢的時候分別調(diào)用。

2.使用dbname.tablename的方式來寫from，或者join（前提是你用于連接MYSQL的帳號必須同時可以訪問這兩個庫）

例如：dba，dbb

select * from dba.table1 as t1

join dbb.table1 as t2 on t1.id = t2.id

php怎么查詢兩個數(shù)據(jù)庫的內(nèi)容

你說的是數(shù)據(jù)庫，還是數(shù)據(jù)表啊。

如果是數(shù)據(jù)表的話，可以用連接查詢。

select a.id,a.username,b.id as bid b.title from 表A a left join 表B b on a.id=b.id

這樣就可以了，如果是兩個數(shù)據(jù)庫，那就比較麻煩，要創(chuàng)建兩個連接對象。再分別打開兩個表。再操作。

數(shù)據(jù)庫查詢語句

數(shù)據(jù)庫查詢語句需要根據(jù)不同的需求進行編寫。（以MySQL數(shù)據(jù)庫查詢?yōu)槔?/p>

1、如果需要查詢某個數(shù)據(jù)表的所有字段，則使用 * 代表所有字段進行查詢即可。該種方式是最簡單的一種查詢。

2、若需要查詢某表的某些字段，則在select后加上字段名，多個字段名使用 , 進行分隔。

3、若需要根據(jù)指定條件查詢某些數(shù)據(jù)記錄，則可以使用 where關(guān)鍵字來進行條件查詢。

4、若需要對查詢結(jié)果進行分組，則可以使用 Group By 關(guān)鍵字來進行分組查詢。

php mysql數(shù)據(jù)庫查詢語句并輸出

php中，.是連接符，改成這樣

$proname = "SELECT areaname FROM oepre_user_params JOIN oepre_hometown ON oepre_user_params".".`provinceid` = oepre_hometown.`areaid` WHERE userid=123;

網(wǎng)站欄目：php多個數(shù)據(jù)庫查詢語句 mysql查詢多個數(shù)據(jù)
路徑分享：http://chinadenli.net/article12/hjoodc.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供服務(wù)器托管、虛擬主機、網(wǎng)站制作、企業(yè)建站、定制開發(fā)、關(guān)鍵詞優(yōu)化

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)