Package ResultsetRow et analyse du protocole mysql

git

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

Aperçu

Le package ResultsetRow fait partie du package lorsque le serveur renvoie le ResultSet et est utilisé pour décrire les enregistrements de ligne de l'ensemble de résultats.

Structure du message de communication MySQL

Type	Nom	Description th >
int<3>	la longueur de la charge utile	est stockée en fonction de l'octet de poids faible en premier, 3 mots La charge utile de la strophe et le numéro de séquence de 1 octet sont combinés dans un en-tête de message
int<1>	Numéro de série

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

chaîne charge utile Corps du message, la longueur est la longueur de la charge utile précédemment spécifiée tr>

Package ResultssetRow

Payload

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

Plus de détails : http : / /dev.mysql.com/doc/internals/en/com-query-response.html#text-resultset

Classe de package ResultsetRow

/**
 * 
 * <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";
    }

}

Ce qui précède est le package ResultsetRow de Protocole mysql et contenu de l'analyse, veuillez faire attention au site Web PHP chinois (www.php.cn) pour plus de contenu connexe !