git
https://github.com/sea-boat/mysql-protocol
概況
mysql連接如果想要改變該連接默認的schema，則客戶端可以向服務(wù)端發(fā)送初始化DB命令包。
mysql通信報文結(jié)構(gòu)
| 類型 | 名字 | 描述 |
|---|---|---|
| int | payload長度 | 按照the least significant byte first存儲，3個字節(jié)的payload和1個字節(jié)的序列號組合成報文頭 |
| int | 序列號 | |
| string | payload | 報文體，長度即為前面指定的payload長度 |
初始化DB命令包
Payload
1??????????????[02]?COM_INIT_DBstring[EOF]????schema?name
更多詳情 ：?http://dev.mysql.com/doc/internals/en/com-init-db.html
初始化命令包操作
-
初始化命令包
/** ?*? ?*?@author?seaboat ?*?@date?2016-09-25 ?*?@version?1.0 ?*?<pre class="brush:php;toolbar:false"><b>email: </b>849586227@qq.com
?*?
<b>blog: </b>http://www.php.cn/;/pre> * <p>mysql init db packet.</p> */public class InitDBPacket extends MySQLPacket { public byte[] schema; public void read(byte[] data) { MySQLMessage mm = new MySQLMessage(data); packetLength = mm.readUB3(); packetId = mm.read(); mm.read(); // skip COM_INIT_DB this.schema = mm.readBytes(); } public void write(ByteBuffer buffer) { BufferUtil.writeUB3(buffer, calcPacketSize()); buffer.put(packetId); buffer.put(COM_INIT_DB); buffer.put(schema); } @Override public int calcPacketSize() { int i = 1; i += schema.length; return i; } @Override protected String getPacketInfo() { return "MySQL Init DB Packet"; } }
?以上就是mysql 協(xié)議的初始化DB命令包及解析的內(nèi)容，更多相關(guān)內(nèi)容請關(guān)注PHP中文網(wǎng)（www.php.cn）！
? 版權(quán)聲明
文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載。
THE END
