Initialization DB command package and analysis of mysql protocol

git

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

Overview

mysql connection If you want to change the default schema of the connection, the client can send an initialization DB command package to the server.

mysql communication message structure

Payload

1              [02] COM_INIT_DBstring[EOF]    schema name

1. Initialization command package

/**
 * 
 * @author seaboat
 * @date 2016-09-25
 * @version 1.0
 * <pre class="brush:php;toolbar:false"><b>email: </b>849586227@qq.com

*

<b>blog: </b>//m.sbmmt.com/;/pre>
 * <p>mysql init db packet.</p>
 */public class InitDBPacket extends MySQLPacket {
    public byte[] schema;    public void read(byte[] data) {
        MySQLMessage mm = new MySQLMessage(data);
        packetLength = mm.readUB3();
        packetId = mm.read();
        mm.read(); // skip COM_INIT_DB
        this.schema = mm.readBytes();
    }    public void write(ByteBuffer buffer) {
        BufferUtil.writeUB3(buffer, calcPacketSize());
        buffer.put(packetId);
        buffer.put(COM_INIT_DB);
        buffer.put(schema);
    }    @Override
    public int calcPacketSize() {        int i = 1;
        i += schema.length;        return i;
    }    @Override
    protected String getPacketInfo() {        return "MySQL Init DB Packet";
    }

}

Copy after login
The above is the content of the initialization DB command package and analysis of the mysql protocol, more For related content, please pay attention to the PHP Chinese website (m.sbmmt.com)!