[CONJ-366] faster connection using pipeline

src/main/java/org/mariadb/jdbc/internal/io/input/DecompressPacketInputStream.java

@@ -77,15 +77,15 @@ public class DecompressPacketInputStream implements PacketInputStream {
     private int cachePos;
     private int cacheEnd;
 
-    private InputStream inputStream;
+    private BufferedInputStream inputStream;
 
     private int packetSeq;
     private int compressPacketSeq;
     private int maxQuerySizeToLog;
     private int lastPacketLength;
 
-    public DecompressPacketInputStream(InputStream in, int maxQuerySizeToLog) {
-        inputStream = new BufferedInputStream(in, 64 * 1024);
+    public DecompressPacketInputStream(BufferedInputStream in, int maxQuerySizeToLog) {
+        inputStream = in;
         this.maxQuerySizeToLog = maxQuerySizeToLog;
     }
 

src/main/java/org/mariadb/jdbc/internal/io/input/StandardPacketInputStream.java

@@ -71,7 +71,7 @@ public class StandardPacketInputStream implements PacketInputStream {
     private byte[] header = new byte[4];
     private byte[] reusableArray = new byte[REUSABLE_BUFFER_LENGTH];
 
-    private InputStream inputStream;
+    private BufferedInputStream inputStream;
 
     private int packetSeq;
     private int maxQuerySizeToLog;
@@ -89,6 +89,16 @@ public Buffer getPacket(boolean reUsable) throws IOException {
         return new Buffer(getPacketArray(reUsable), lastPacketLength);
     }
 
+    /**
+     * Get current Buffered input stream for creating compress input stream,
+     * to avoid losing already read bytes in case of pipelining.
+     *
+     * @return buffer input stream.
+     */
+    public BufferedInputStream getBufferedInputStream() {
+        return inputStream;
+    }
+
     /**
      * Get next packet.
      * If packet is more than 16M, read as many packet needed to finish packet.