Heim  >  Artikel  >  Datenbank  >  ResultsetRow-Paket und Analyse des MySQL-Protokolls

ResultsetRow-Paket und Analyse des MySQL-Protokolls

黄舟
黄舟Original
2017-03-07 13:19:591857Durchsuche

git

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

Übersicht

Das ResultsetRow-Paket ist Teil des Pakets, wenn der Server das ResultSet zurückgibt, und wird zur Beschreibung der Zeilendatensätze des Ergebnissatzes verwendet.

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>

ResultsetRow-Paket

Payload

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

Weitere Details: http: / /dev.mysql.com/doc/internals/en/com-query-response.html#text-resultset

ResultsetRow-Paketklasse

/**
 * 
 * <pre class="brush:php;toolbar:false"><b>resultset row packet.</b>
* @author *
seaboat
*
<b>email: </b>849586227@qq.com
*
<b>blog: </b>http://www.php.cn/;/pre>
 * @version 1.0
 * @see http://www.php.cn/
 */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 < columnCount; i++) {
            columnValues.add(mm.readBytesWithLength());
        }
    }    @Override
    public void write(ByteBuffer buffer) {
        BufferUtil.writeUB3(buffer, calcPacketSize());
        buffer.put(packetId);        
        for (int i = 0; i < columnCount; i++) {            
        byte[] fv = columnValues.get(i);            
        if (fv == null) {
                buffer.put(NULL_MARK);
            } else {
                BufferUtil.writeLength(buffer, fv.length);
                buffer.put(fv);
            }
        }
    }    @Override
    public int calcPacketSize() {        
    int size = 0;        
    for (int i = 0; i < columnCount; i++) {            
    byte[] v = columnValues.get(i);
            size += (v == null || v.length == 0) ? 1 : BufferUtil.getLength(v);
        }        return size;
    }    @Override
    protected String getPacketInfo() {        
    return "MySQL Resultset Row Packet";
    }

}

Das Obige ist das ResultsetRow-Paket von MySQL-Protokoll und Der Inhalt der Analyse. Weitere verwandte Inhalte finden Sie auf der chinesischen PHP-Website (www.php.cn)!


Stellungnahme:
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn