PHP + Mysql多個(gè)表并行查詢?nèi)绾螌?shí)現(xiàn)

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

創(chuàng)新互聯(lián)主要從事成都網(wǎng)站制作、成都做網(wǎng)站、網(wǎng)頁設(shè)計(jì)、企業(yè)做網(wǎng)站、公司建網(wǎng)站等業(yè)務(wù)。立足成都服務(wù)額敏,10余年網(wǎng)站建設(shè)經(jīng)驗(yàn),價(jià)格優(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())?{?...?}

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

那么有什么辦法可以減少查詢MySQL的時(shí)間？用多進(jìn)程并行查詢不行，因?yàn)镻HP-FPM 中不允許用 pcntl_fork 一類的調(diào)用。

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

還是通過例子來介紹MySQL并行查詢的實(shí)施方法。假設(shè)要并行地向MySQL發(fā)出10個(gè)查詢，最基本的代碼應(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行，同時(shí)發(fā)起10個(gè)MySQL連接，并發(fā)出查詢

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

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

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

mysqli_poll的第四個(gè)參數(shù)，控制的是輪詢的等待時(shí)間，單位是“秒”。如果像本例當(dāng)中設(shè)置為null，那么mysqli_poll輪詢是阻塞的：只有監(jiān)聽的連接中，任意一個(gè)連接有數(shù)據(jù)返回了，mysqli_poll才會(huì)返回。如果等待時(shí)間設(shè)置為0，那么每次執(zhí)行mysqli_poll會(huì)立即返回，外層的while會(huì)頻繁循環(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就不需要再輪詢這個(gè)連接了，所以關(guān)閉連接，并從$links數(shù)組刪除這個(gè)連接

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

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

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

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

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

例如：dba，dbb

select * from dba.table1 as t1

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

php怎么查詢兩個(gè)數(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

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

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

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

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

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

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

4、若需要對查詢結(jié)果進(jìn)行分組，則可以使用 Group By 關(guān)鍵字來進(jì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;