mysql 協議的幾種包及解析

if(NULL){??  0xfb  }else{  ??Protocol::LengthEncodedString  }

public?class?ResultsetRowPacket?extends?MySQLPacket?{  ????private?static?final?byte?NULL_MARK?=?(byte)?251;  ????public?int?columnCount;  ????public?List<byte>?columnValues;    ????public?ResultsetRowPacket()?{    ????}    ????public?ResultsetRowPacket(int?columnCount)?{  ????????this.columnCount?=?columnCount;  ????}    ????@Override  ????public?void?read(byte[]?data)?{  ????????MySQLMessage?mm?=?new?MySQLMessage(data);  ????????packetLength?=?mm.readUB3();  ????????packetId?=?mm.read();  ????????for?(int?i?=?0;?i?<p style="margin: 0.8em 0px; padding: 0px; box-sizing: border-box; font-weight: 100; color: rgb(85, 85, 85); font-family: " microsoft yahei line-height: white-space: normal widows: background-color: rgb>ColumnDefinition包</p> <p>Payload</p> <pre class="brush:php;toolbar:false">lenenc_str?????catalog  lenenc_str?????schema  lenenc_str?????table  lenenc_str?????org_table  lenenc_str?????name  lenenc_str?????org_name  lenenc_int?????length?of?fixed-length?fields?[0c]  2??????????????character?set  4??????????????column?length  1??????????????type  2??????????????flags  1??????????????decimals  2??????????????filler?[00]?[00]  ??if?command?was?COM_FIELD_LIST?{  lenenc_int?????length?of?default-values  string[$len]???default?values  ??}

public?class?ColumnDefinitionPacket?extends?MySQLPacket?{  ????private?static?final?byte[]?DEFAULT_CATALOG?=?"def".getBytes();  ????private?static?final?byte?NEXT_LENGTH?=?0x0c;  ????private?static?final?byte[]?FILLER?=?{?00,?00?};    ????public?byte[]?catalog?=?DEFAULT_CATALOG;//?always?"def"  ????public?byte[]?schema;  ????public?byte[]?table;  ????public?byte[]?orgTable;  ????public?byte[]?name;  ????public?byte[]?orgName;  ????public?byte?nextLength?=?NEXT_LENGTH;//?always?0x0c  ????public?int?charsetSet;  ????public?long?length;  ????public?int?type;  ????public?int?flags;  ????public?byte?decimals;  ????public?byte[]?filler?=?FILLER;  ????public?byte[]?defaultValues;    ????public?void?read(byte[]?data)?{  ????????MySQLMessage?mm?=?new?MySQLMessage(data);  ????????this.packetLength?=?mm.readUB3();  ????????this.packetId?=?mm.read();  ????????this.catalog?=?mm.readBytesWithLength();  ????????this.schema?=?mm.readBytesWithLength();  ????????this.table?=?mm.readBytesWithLength();  ????????this.orgTable?=?mm.readBytesWithLength();  ????????this.name?=?mm.readBytesWithLength();  ????????this.orgName?=?mm.readBytesWithLength();  ????????this.nextLength?=?mm.read();  ????????this.charsetSet?=?mm.readUB2();  ????????this.length?=?mm.readUB4();  ????????this.type?=?mm.read()?&?0xff;  ????????this.flags?=?mm.readUB2();  ????????this.decimals?=?mm.read();  ????????this.filler?=?mm.readBytes(2);  ????????if?(mm.hasRemaining())?{  ????????????this.defaultValues?=?mm.readBytesWithLength();  ????????}  ????}    ????@Override  ????public?void?write(ByteBuffer?buffer)?{  ????????int?size?=?calcPacketSize();  ????????BufferUtil.writeUB3(buffer,?size);  ????????buffer.put(packetId);  ????????BufferUtil.writeWithLength(buffer,?catalog,?(byte)?0);  ????????BufferUtil.writeWithLength(buffer,?schema,?(byte)?0);  ????????BufferUtil.writeWithLength(buffer,?table,?(byte)?0);  ????????BufferUtil.writeWithLength(buffer,?orgTable,?(byte)?0);  ????????BufferUtil.writeWithLength(buffer,?name,?(byte)?0);  ????????BufferUtil.writeWithLength(buffer,?orgName,?(byte)?0);  ????????buffer.put(NEXT_LENGTH);  ????????BufferUtil.writeUB2(buffer,?charsetSet);  ????????BufferUtil.writeUB4(buffer,?length);  ????????buffer.put((byte)?(type?&?0xff));  ????????BufferUtil.writeUB2(buffer,?flags);  ????????buffer.put(decimals);  ????????buffer.put(FILLER);  ????????if?(defaultValues?!=?null)?{  ????????????//only?use?for?show?columns  ????????????BufferUtil.writeWithLength(buffer,?defaultValues);  ????????}  ????}    ????@Override  ????public?int?calcPacketSize()?{  ????????int?size?=?(catalog?==?null???1?:?BufferUtil.getLength(catalog));  ????????size?+=?(schema?==?null???1?:?BufferUtil.getLength(schema));  ????????size?+=?(table?==?null???1?:?BufferUtil.getLength(table));  ????????size?+=?(orgTable?==?null???1?:?BufferUtil.getLength(orgTable));  ????????size?+=?(name?==?null???1?:?BufferUtil.getLength(name));  ????????size?+=?(orgName?==?null???1?:?BufferUtil.getLength(orgName));  ????????size?+=?13;  ????????if?(defaultValues?!=?null)?{  ????????????size?+=?BufferUtil.getLength(defaultValues);  ????????}  ????????return?size;  ????}    ????@Override  ????protected?String?getPacketInfo()?{  ????????return?"MySQL?Column?Definition?Packet";  ????}    }

Protocol::LengthEncodedInteger

public?class?ColumnCountPacket?extends?MySQLPacket?{    ????public?int?columnCount;    ????public?void?read(byte[]?data)?{  ????????MySQLMessage?mm?=?new?MySQLMessage(data);  ????????this.packetLength?=?mm.readUB3();  ????????this.packetId?=?mm.read();  ????????this.columnCount?=?(int)?mm.readLength();  ????}    ????@Override  ????public?void?write(ByteBuffer?buffer)?{  ????????int?size?=?calcPacketSize();  ????????BufferUtil.writeUB3(buffer,?size);  ????????buffer.put(packetId);  ????????BufferUtil.writeLength(buffer,?columnCount);  ????}    ????@Override  ????public?int?calcPacketSize()?{  ????????int?size?=?BufferUtil.getLength(columnCount);  ????????return?size;  ????}    ????@Override  ????protected?String?getPacketInfo()?{  ????????return?"MySQL?Column?Count?Packet";  ????}    }