国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 學(xué)院 > 開發(fā)設(shè)計(jì) > 正文

MySql協(xié)議詳解-CRUD與Result篇

2019-11-10 17:28:28
字體:
供稿:網(wǎng)友
https://my.oschina.net/alchemystar/blog/834150

MySQL協(xié)議詳解-CRUD與Result篇

Com_query報(bào)文

一般對(duì)DB的CRUD操作都由com_query報(bào)文封裝并發(fā)送給DB。com_query報(bào)文如下圖所示: querypacketPacketLength:3byte表示body長(zhǎng)度,防"粘包"。sequenceId:1byte防串包。body部分:是一個(gè)以0x00結(jié)尾的字符串,這個(gè)字符串就是想要執(zhí)行的SQL,實(shí)際操作中即是一直讀body直到讀到一個(gè)0x00皆為的字符串即停止。

insert,update和delete

如果SQL是insert、update或者是delete,則返回的是對(duì)應(yīng)的okay或者error報(bào)文。okay報(bào)文的類表示:

public class OkPacket extends MySQLPacket { public static final byte FIELD_COUNT = 0x00; public static final byte[] OK = new byte[] { 7, 0, 0, 1, 0, 0, 0, 2, 0, 0, 0 }; public static final byte[] AUTH_OK = new byte[] { 7, 0, 0, 2, 0, 0, 0, 2, 0, 0, 0 }; public byte fieldCount = FIELD_COUNT; public long affectedRows; public long insertId; public int serverStatus; public int warningCount; public byte[] message;}

error報(bào)文的類表示:

public class ErrorPacket extends MySQLPacket { public static final byte FIELD_COUNT = (byte) 0xff; PRivate static final byte SQLSTATE_MARKER = (byte) '#'; private static final byte[] DEFAULT_SQLSTATE = "HY000".getBytes(); public byte fieldCount = FIELD_COUNT; public int errno; public byte mark = SQLSTATE_MARKER; public byte[] sqlState = DEFAULT_SQLSTATE; public byte[] message;}

Select和ResultSet報(bào)文

如果執(zhí)行的SQL是select語句,則返回的報(bào)文比較復(fù)雜,不過筆者已經(jīng)整理成圖的形式。

Row報(bào)文

首先ResultSet是由很多行(Row)組成,每一行(Row)就表示了一條記錄,Row格式如下所示:rowpacket每一行(row)又分好field_count個(gè)字段,這個(gè)field_count將會(huì)在比Row還高一層的Result格式中描述,下面有詳解。每一個(gè)字段都是一個(gè)length-value對(duì),length長(zhǎng)度是3byte,其讀取方法很特殊,現(xiàn)在直接用代碼表述:

public int readUB3() { final byte[] b = this.data; int i = b[position++] & 0xff; i |= (b[position++] & 0xff) << 8; i |= (b[position++] & 0xff) << 16; return i; }

獲取了length長(zhǎng)度之后,則可以根據(jù)此讀出來后面的value。value的類型也會(huì)在后面的Resutl格式中描述。

ResultSet格式

嚴(yán)格來說ResultSet是由多個(gè)獨(dú)立的報(bào)文以協(xié)議的形式組織起來,現(xiàn)直接放出ResultSet的協(xié)議格式圖: resultset從上圖中可以看到,當(dāng)客戶端發(fā)送一個(gè)select的com_query包后,DB會(huì)按照下列步驟返回:Step1:返回一個(gè)ResultSetHeader報(bào)文,其中包含了fieldCount,在此圖就不例出了,現(xiàn)只給出代碼定義。

public class ResultSetHeaderPacket extends MySQLPacket { public int fieldCount; public long extra;}

Step2:根據(jù)讀取到的fieldCount來在接下來的byte流里面讀取fieldCount個(gè)FiledPacket報(bào)文,FieldPacket報(bào)文的代碼定義:

public class FieldPacket extends MySQLPacket { private static final byte[] DEFAULT_CATALOG = "def".getBytes(); private static final byte[] FILLER = new byte[2]; public byte[] catalog = DEFAULT_CATALOG; public byte[] db; public byte[] table; public byte[] orgTable; public byte[] name; public byte[] orgName; public int charsetIndex; public long length; public int type; public int flags; public byte decimals; public byte[] definition;}

具體邏輯請(qǐng)參照githubStep3:再讀取一個(gè)eof包表示field包流的結(jié)束eof包的代碼定義:

public class EOFPacket extends MySQLPacket { public static final byte FIELD_COUNT = (byte) 0xfe; public byte fieldCount = FIELD_COUNT; public int warningCount; public int status = 2;

Step4:一直讀Row,直到讀到last eof位置,Row格式已經(jīng)在上面給過。Step5:如果讀到任何一個(gè)error包后,此此讀取結(jié)束,拋出錯(cuò)誤。Step6:值得注意的是,如果eof中的status & SERVER_MORE_RESULT_EXISTS不為0,表明還有ResultSet。則繼續(xù)返回到fieldCount階段進(jìn)行下一步的讀取。Step7:至此,整個(gè)ResultSet讀取完畢。下面給出上述過程的java代碼(基于Netty):

private boolean handleResultSet(BinaryPacket bin, CmdType cmdType) { boolean result = false; int type = bin.data[0]; switch (type) { case ErrorPacket.FIELD_COUNT: // 重置狀態(tài),且告訴上層當(dāng)前select已經(jīng)處理完畢 resetSelect(); result = true; ErrorPacket err = new ErrorPacket(); err.read(bin); // write(bin,cmdType); getResponseHandler().errorResponse(bin); logger.error("handleResultSet errorMessage:" + new String(err.message)); break; case EOFPacket.FIELD_COUNT: EOFPacket eof = new EOFPacket(); eof.read(bin); if (selectState == BackendConnState.RESULT_SET_FIELDS) { // logger.info("eof"); // 推進(jìn)狀態(tài) 需要步進(jìn)兩次狀態(tài),先到field_eof,再到row selectStateStep(); selectStateStep(); // 給FieldList增加eof addToFieldList(bin); getResponseHandler().fieldListResponse(fieldList); } else { if (eof.hasStatusFlag(MySQLPacket.SERVER_MORE_RESULTS_EXISTS)) { // 重置為select的初始狀態(tài),但是還是處在select mode下 selectState = BackendConnState.RESULT_SET_FIELD_COUNT; } else { // 重置,且告訴上層當(dāng)前select已經(jīng)處理完畢 resetSelect(); result = true; } getResponseHandler().lastEofResponse(bin); } break; default: switch (selectState) { case BackendConnState.RESULT_SET_FIELD_COUNT: selectStateStep(); addToFieldList(bin); break; case BackendConnState.RESULT_SET_FIELDS: addToFieldList(bin); break; case BackendConnState.RESULT_SET_ROW: getResponseHandler().rowResponse(bin); break; } } return result; }

GitHub鏈接

https://github.com/alchemystar/Lancelot.git


發(fā)表評(píng)論 共有條評(píng)論
用戶名: 密碼:
驗(yàn)證碼: 匿名發(fā)表
主站蜘蛛池模板: 二连浩特市| 共和县| 安平县| 游戏| 金塔县| 桐庐县| 门头沟区| 龙胜| 土默特右旗| 罗山县| 云梦县| 高台县| 宣化县| 礼泉县| 盐亭县| 闸北区| 柳林县| 花垣县| 武陟县| 修文县| 青阳县| 称多县| 永平县| 新巴尔虎左旗| 神池县| 墨江| 青河县| 沙河市| 尼勒克县| 汕尾市| 阜宁县| 顺昌县| 罗城| 楚雄市| 象州县| 察雅县| 大连市| 临洮县| 常宁市| 墨玉县| 江达县|