Detailed introduction to the error package and analysis of the mysql protocol

git

https://github.com/sea-boat/mysql-protocol

Overview

During the interaction between the mysql client and the mysql server, if the server encounters an error and needs to inform the client, it will return an error packet.

mysql communication message structure

##string payload Message body, the length is the previously specified payload length

Type	Name	Description
int<3>	payload length	Stored according to the least significant byte first, 3-byte payload and 1-byte sequence number combination Into the message header
int<1>	sequence number

Error packet

Payload

Type Name Description int<1> header [ff] header of the ERR packet int<2> error_code error-code string[1] string[5] string error_message human readable error message More details: http://dev .mysql.com/doc/internals/en/packet-ERR_Packet.html

##if capabilities & CLIENT_PROTOCOL_41 {
sql_state_marker	marker of the SQL State
sql_state	SQL State
##}

Error package operation

Error package class

1. /** * * @author seaboat * @date 2016-09-25 * @version 1.0 * 
   email: 849586227@qq.com
   *
             
   blog: //m.sbmmt.com/;/pre> * 
   mysql error packet.
    */public class ErrorPacket extends MySQLPacket { public static final byte header = (byte) 0xff; private static final byte SQLSTATE_MARKER = (byte) '#'; private static final byte[] DEFAULT_SQLSTATE = "HY000".getBytes(); public int errno; public byte mark = SQLSTATE_MARKER; public byte[] sqlState = DEFAULT_SQLSTATE; public byte[] message; public void read(byte[] data) { MySQLMessage mm = new MySQLMessage(data); packetLength = mm.readUB3(); packetId = mm.read(); mm.read(); errno = mm.readUB2(); if (mm.hasRemaining() && (mm.read(mm.position()) == SQLSTATE_MARKER)) { mm.read(); sqlState = mm.readBytes(5); } message = mm.readBytes(); } public void write(ByteBuffer buffer) { int size = calcPacketSize(); BufferUtil.writeUB3(buffer, size); buffer.put(packetId); buffer.put(header); BufferUtil.writeUB2(buffer, errno); buffer.put(mark); buffer.put(sqlState); buffer.put(message); } @Override public int calcPacketSize() { int size = 9;// 1 + 2 + 1 + 5 if (message != null) { size += message.length; } return size; } @Override protected String getPacketInfo() { return "MySQL Error Packet"; } }
             
   
              Copy after login
             
            

Hexadecimal conversion tool

1. /** * * @author seaboat * @date 2016-09-25 * @version 1.0 * 
   email: 849586227@qq.com
   *
             
   blog: //m.sbmmt.com/;/pre> * 
   hex transform util.
    */public class HexUtil { private final static byte[] hex = "0123456789ABCDEF".getBytes(); public static String Bytes2HexString(byte[] b) { byte[] buff = new byte[2 * b.length]; for (int i = 0; i < b.length; i++) { buff[2 * i] = hex[(b[i] >> 4) & 0x0f]; buff[2 * i + 1] = hex[b[i] & 0x0f]; } return new String(buff); } public static String str2HexStr(String str) { char[] chars = "0123456789ABCDEF".toCharArray(); StringBuilder sb = new StringBuilder(""); byte[] bs = str.getBytes(); int bit; for (int i = 0; i < bs.length; i++) { bit = (bs[i] & 0x0f0) >> 4; sb.append(chars[bit]); bit = bs[i] & 0x0f; sb.append(chars[bit]); } return sb.toString(); } }
             
   
              Copy after login
             
            

Error package generation test

1. /** * * @author seaboat * @date 2016-09-25 * @version 1.0 * 
   email: 849586227@qq.com
   *
             
   blog: //m.sbmmt.com/;/pre> * 
   test auth packet.
    */public class ErrorPacketTest { @Test public void produce() { ErrorPacket err = new ErrorPacket(); err.packetId = 1; err.errno = 32322; err.message = "sorry".getBytes(); ByteBuffer buffer = ByteBuffer.allocate(256); err.write(buffer); buffer.flip(); byte[] bytes = new byte[buffer.remaining()]; buffer.get(bytes, 0, bytes.length); String result = HexUtil.Bytes2HexString(bytes); System.out.println(result); assertTrue(Integer.valueOf(result.substring(0, 2), 16) == result .length() / 2 - 4); ErrorPacket err2 = new ErrorPacket(); err2.read(bytes); assertTrue(err2.errno == 32322); assertTrue(err2.message.length == "sorry".getBytes().length); } }
             
   
              Copy after login
             
            

   The above is a detailed introduction to the error packet and analysis content of the MySQL protocol. For more related content, please pay attention to the PHP Chinese website (m.sbmmt.com)!