Detaillierte Einführung in das Fehlerpaket und Analyse des MySQL-Protokolls

git

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

Übersicht

Wenn der Server während der Interaktion zwischen dem MySQL-Client und dem MySQL-Server auf einen Fehler stößt und den Client informieren muss, gibt er ein Fehlerpaket zurück.

MySQL-Kommunikationsnachrichtenstruktur

Typ	Name	Beschreibung th >
int5bdf4c78156c7953567bb5a0aef2fc53	Payload-Länge	wird entsprechend dem niedrigstwertigen Byte zuerst, 3 Wörter, gespeichert Die Nutzlast der Strophe und die 1-Byte-Sequenznummer werden zu einem Nachrichtenheader zusammengefasst
intf35d6e602fd7d0f0edfa6f7d103c1b57	Seriennummer

类型	名字	描述
int5bdf4c78156c7953567bb5a0aef2fc53	payload长度	按照the least significant byte first存储，3个字节的payload和1个字节的序列号组合成报文头
intf35d6e602fd7d0f0edfa6f7d103c1b57	序列号
string	payload	报文体，长度即为前面指定的payload长度

Zeichenfolge Nutzlast Nachrichtentext, die Länge ist die zuvor angegebene Nutzlastlänge tr>

Fehlerpaket

Payload

Fehlercode tr> table>Weitere Details: http://dev.mysql.com/doc/internals/en/packet-ERR_Packet.html

1. Fehler beim Paketbetrieb

Fehlerpaketklasse

/**
 * 
 * @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 error packet.</p>
 */public class ErrorPacket extends MySQLPacket {
    public static final byte header = (byte) 0xff;    
    private static final byte SQLSTATE_MARKER = (byte) &#39;#&#39;;    
    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";
    }

}

Hex-Konvertierungstool

/**
 * 
 * @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>hex transform util.</p>
 */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();
    }
}

Fehlerpaket-Generierungstest

/**
 * 
 * @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>test auth packet.</p>
 */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);
    }

}

Das Obige ist eine detaillierte Einführung in das Fehlerpaket und die Analyse des MySQL-Protokolls. Weitere verwandte Inhalte finden Sie auf der chinesischen PHP-Website ( www.php.cn )!

Typ

Name

Beschreibung

intf35d6e602fd7d0f0edfa6f7d103c1b57 td>

header

[ff] Header des ERR-Pakets

int2cc198a1d5eb0d3eb508d858c9f5cbdb

error_code

Type	Name	Description
intf35d6e602fd7d0f0edfa6f7d103c1b57	header	[ff] header of the ERR packet
int2cc198a1d5eb0d3eb508d858c9f5cbdb	error_code	error-code
	if capabilities & CLIENT_PROTOCOL_41 {
string[1]	sql_state_marker	marker of the SQL State
string[5]	sql_state	SQL State
	}
string	error_message	human readable error message

wenn Funktionen & CLIENT_PROTOCOL_41 {

string[1]

sql_state_marker

Marker des SQL-Status

string[ 5]

sql_state

SQL-Status

}

string

error_message

Menschlich lesbare Fehlermeldung