com.mysql.cj.protocol.a

Class CompressedInputStream

java.lang.Object

java.io.InputStream

com.mysql.cj.protocol.a.CompressedInputStream

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class CompressedInputStream
extends java.io.InputStream

Used to de-compress packets from the MySQL server when protocol-level compression is turned on.

Field Summary

Fields

Modifier and Type	Field and Description
private byte[]	buffer The packet data after it has been un-compressed
private java.io.InputStream	in The stream we are reading from the server
private java.util.zip.Inflater	inflater The ZIP inflater used to un-compress packets
private Log	log Connection logger
private byte[]	packetHeaderBuffer The buffer to read packet headers into
private int	pos The position we are reading from
private RuntimeProperty<java.lang.Boolean>	traceProtocol Connection property reference

Constructor Summary

Constructors

Constructor and Description
CompressedInputStream(java.io.InputStream streamFromServer, RuntimeProperty<java.lang.Boolean> traceProtocol, Log log) Creates a new CompressedInputStream that reads the given stream from the server.

Method Summary

Modifier and Type	Method and Description
int	available()
void	close()
private void	getNextPacketFromServer() Retrieves and un-compressed (if necessary) the next packet from the server.
private void	getNextPacketIfRequired(int numBytes) Determines if another packet needs to be read from the server to be able to read numBytes from the stream.
int	read()
int	read(byte[] b)
int	read(byte[] b, int off, int len)
private int	readFully(byte[] b, int off, int len)
long	skip(long n)

Methods inherited from class java.io.InputStream

mark, markSupported, reset

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

buffer

private byte[] buffer

The packet data after it has been un-compressed

in

private java.io.InputStream in

The stream we are reading from the server

inflater

private java.util.zip.Inflater inflater

The ZIP inflater used to un-compress packets

traceProtocol

private RuntimeProperty<java.lang.Boolean> traceProtocol

Connection property reference

log

private Log log

Connection logger

packetHeaderBuffer

private byte[] packetHeaderBuffer

The buffer to read packet headers into

pos

private int pos

The position we are reading from

Constructor Detail

CompressedInputStream

public CompressedInputStream(java.io.InputStream streamFromServer,
                             RuntimeProperty<java.lang.Boolean> traceProtocol,
                             Log log)

Creates a new CompressedInputStream that reads the given stream from the server.

Parameters:

streamFromServer - original server InputStream

traceProtocol - "traceProtocol" property

log - logger

Method Detail

available

public int available()
              throws java.io.IOException

Overrides:

available in class java.io.InputStream

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Overrides:

close in class java.io.InputStream

Throws:

java.io.IOException

getNextPacketFromServer

private void getNextPacketFromServer()
                              throws java.io.IOException

Retrieves and un-compressed (if necessary) the next packet from the server.

Throws:

java.io.IOException - if an I/O error occurs

getNextPacketIfRequired

private void getNextPacketIfRequired(int numBytes)
                              throws java.io.IOException

Determines if another packet needs to be read from the server to be able to read numBytes from the stream.

Parameters:

numBytes - the number of bytes to be read

Throws:

java.io.IOException - if an I/O error occors.

read

public int read()
         throws java.io.IOException

Specified by:

read in class java.io.InputStream

Throws:

java.io.IOException

read

public int read(byte[] b)
         throws java.io.IOException

Overrides:

read in class java.io.InputStream

Throws:

java.io.IOException

read

public int read(byte[] b,
                int off,
                int len)
         throws java.io.IOException

Overrides:

read in class java.io.InputStream

Throws:

java.io.IOException

readFully

private final int readFully(byte[] b,
                            int off,
                            int len)
                     throws java.io.IOException

Throws:

java.io.IOException

skip

public long skip(long n)
          throws java.io.IOException

Overrides:

skip in class java.io.InputStream

Throws:

java.io.IOException