建站
咨詢(xún)
售后
建站咨詢(xún)
新聞中心
本文從一個(gè)select語(yǔ)句的執(zhí)行過(guò)程出發(fā)，遍歷MySQL的多個(gè)幾子系統(tǒng)。
成都創(chuàng)新互聯(lián)公司專(zhuān)注于中大型企業(yè)的成都做網(wǎng)站、網(wǎng)站制作和網(wǎng)站改版、網(wǎng)站營(yíng)銷(xiāo)服務(wù)，追求商業(yè)策劃與數(shù)據(jù)分析、創(chuàng)意藝術(shù)與技術(shù)開(kāi)發(fā)的融合，累計(jì)客戶(hù)數(shù)千家，服務(wù)滿(mǎn)意度達(dá)97%。幫助廣大客戶(hù)順利對(duì)接上互聯(lián)網(wǎng)浪潮，準(zhǔn)確優(yōu)選出符合自己需要的互聯(lián)網(wǎng)運(yùn)用，我們將一直專(zhuān)注品牌網(wǎng)站制作和互聯(lián)網(wǎng)程序開(kāi)發(fā)，在前進(jìn)的路上，與客戶(hù)一起成長(zhǎng)！
先放圖一張, 按圖索驥開(kāi)始我們的歷險(xiǎn).
當(dāng)客戶(hù)端連接上MySQL服務(wù)端之后,發(fā)出請(qǐng)求之前,服務(wù)端的線(xiàn)程是阻塞在do_command(sql/parse.cc)里的my_net_read函數(shù)中(就是socket里的read).
當(dāng)客戶(hù)端鍵入sql語(yǔ)句(本文例子select * from zzz)發(fā)送到服務(wù)端之后, my_net_read返回, 并從tcpbuffer中讀取數(shù)據(jù)寫(xiě)入到packet這個(gè)字符串.
- packet_length= my_net_read(net);
packet的第一個(gè)字節(jié)是個(gè)標(biāo)志位, 決定數(shù)據(jù)包是查詢(xún)還是命令,成功,或者出錯(cuò)。
接下來(lái)就進(jìn)入dispatch_command(sql/sql/parse.cc)這個(gè)函數(shù), 數(shù)據(jù)類(lèi)型不再需要.
- return_value= dispatch_command(command, thd, packet+1, (uint) (packet_length-1));
進(jìn)入dispatch_command, 我們可見(jiàn)
- statistic_increment(thd->status_var.questions, &LOCK_status);
這個(gè)就是show status questions的值累加.
接下的mysql_parse(sql/sql_parse.cc), 該函數(shù)是sql語(yǔ)句解析的總路口.
進(jìn)入該函數(shù)后首先碰到的是query_cache_send_result_to_client,故名思義這個(gè)函數(shù)是在QCache里查詢(xún)是否有相同的語(yǔ)句, 有則立即從QCache返回結(jié)果, 于是整個(gè)sql就結(jié)束了.
QCache里不存在的sql則繼續(xù)前進(jìn)來(lái)到parse_sql(sql/sql_parse.cc),這個(gè)函數(shù)主要就是調(diào)用了MYSQLparse. 而MYSQLparse其實(shí)就是bison/yacc里的yyparse(^_^),
- #define yyparse MYSQLparse
是的開(kāi)始解析sql了. 關(guān)于詞法分析和語(yǔ)法匹配簡(jiǎn)單說(shuō)幾下.
對(duì)于一條像select * from zzz的語(yǔ)句首先進(jìn)入詞法分析,找到2個(gè)token(select, from), 然后根據(jù)token進(jìn)行語(yǔ)法匹配, 規(guī)則在sql/yacc.yy里, 我把幾個(gè)匹配到的pattern和action貼出來(lái).
- select:
- select_init
- {
- LEX *lex= Lex;
- lex->sql_command= SQLCOM_SELECT;
- }
- ;
- /* Need select_init2 for subselects. */
- select_init:
- SELECT_SYM select_init2
- | '(' select_paren ')' union_opt
- ;
- select_paren:
- SELECT_SYM select_part2
- {
- LEX *lex= Lex;
- SELECT_LEX * sel= lex->current_select;
- .....
- select_from:
- FROM join_table_list where_clause group_clause having_clause
- opt_order_clause opt_limit_clause procedure_clause
- {
- Select->context.table_list=
- Select->context.first_name_resolution_table=
- (TABLE_LIST *) Select->table_list.first;
- }
- ....
- select_item_list:
- select_item_list ',' select_item
- | select_item
- | '*'
- {
- THD *thd= YYTHD;
- Item *item= new (thd->mem_root)
- Item_field(&thd->lex->current_select->context,
- NULL, NULL, "*");
- if (item == NULL)
- MYSQL_YYABORT;
- if (add_item_to_list(thd, item))
- MYSQL_YYABORT;
- (thd->lex->current_select->with_wild)++;
- }
- ;
- select_item:
- remember_name select_item2 remember_end select_alias
- {
- THD *thd= YYTHD;
- DBUG_ASSERT($1 < $3);
- if (add_item_to_list(thd, $2))
- MYSQL_YYABORT;
- if ($4.str)
- ...
可以看到action里最關(guān)鍵的就是add_item_to_list 和table_list的賦值.
解析后對(duì)于需要查詢(xún)的表(zzz)和字段(*)這些信息都寫(xiě)入到thd->lex這個(gè)結(jié)構(gòu)體里了.
例如其中thd->lex->query_tables就是表(zzz)的狀況, thd->lex->current_select->with_wild 是表示該語(yǔ)句是否使用了*等等.
- (gdb) p *thd->lex->query_tables
- $7 = {next_local = 0x0, next_global = 0x0, prev_global = 0x855a458, db = 0x85a16b8 "test", alias = 0x85a16e0 "zzz",
- table_name = 0x85a16c0 "zzz", schema_table_name = 0x0, option = 0x0, on_expr = 0x0, prep_on_expr = 0x0, cond_equal = 0x0,
sql解析完了, 優(yōu)化呢? 別急接著往下看.
接著進(jìn)入mysql_execute_command函數(shù)，這個(gè)函數(shù)是所有sql命令的總?cè)肟?
由于是這個(gè)sql是一個(gè)select, 于是execute_sqlcom_select就是我們下個(gè)要執(zhí)行的函數(shù),又然后進(jìn)入了mysql_select(^_^怒了如此復(fù)雜).
mysql_select 就是優(yōu)化器的模塊, 這個(gè)模塊代碼比較復(fù)雜. 我們可以清楚看到創(chuàng)建優(yōu)化器，優(yōu)化，執(zhí)行的3個(gè)步驟, 優(yōu)化細(xì)節(jié)不表.
- if (!(join= new JOIN(thd, fields, select_options, result)))
- ...
- if ((err= join->optimize()))
- ...
- join->exec();
結(jié)束了優(yōu)化，我們要具體執(zhí)行join->exec()，該函數(shù)實(shí)際進(jìn)入的是JOIN::exec()(sql_select.cc)。
exec()首先向客戶(hù)端發(fā)送字段title的函數(shù)send_fields, 沒(méi)數(shù)據(jù)但字段也是要的。
然后再進(jìn)入do_select()，根據(jù)表的存儲(chǔ)引擎跳入到引擎具體的實(shí)現(xiàn)(zzz是myisam表)。
這里mi_scan就是myisam引擎掃描文件的函數(shù)，再看到
- (gdb) p info->filename
- ./test/zzz
這不就是zzz表對(duì)應(yīng)的物理文件嗎。
通過(guò)一系列的mi函數(shù)訪(fǎng)問(wèn)磁盤(pán)拿到數(shù)據(jù)之后，會(huì)通過(guò)send_data發(fā)送數(shù)據(jù)給client，并從dispatch_command返回.最后在net_end_statement結(jié)束整個(gè)sql。
一個(gè)簡(jiǎn)單的select語(yǔ)句背后的執(zhí)行過(guò)程是非常復(fù)雜的，上面的步驟都只是點(diǎn)到就止。
ps: 在sql_yacc.yy可見(jiàn)MySQL對(duì)于Oracle中常用的dual表的嘲諷。
【編輯推薦】
- 教你如何利用MySQL學(xué)習(xí)MongoDB
- Craigslist采用MongoDB替代MySQL
- MySQL中的NoSQL插件
- SQL與NoSQL——MySQL與NoSQL的融合
- 論MySQL何時(shí)使用索引，何時(shí)不使用索引
分享標(biāo)題：探索MySQL源代碼之SQL歷險(xiǎn)記
當(dāng)前URL：http://www.dlmjj.cn/article/cccecpo.html
