com.mysql.cj.protocol.a

Class InputStreamValueEncoder

java.lang.Object

com.mysql.cj.protocol.a.AbstractValueEncoder

com.mysql.cj.protocol.a.InputStreamValueEncoder

All Implemented Interfaces:

ValueEncoder

Direct Known Subclasses:

BlobValueEncoder

public class InputStreamValueEncoder
extends AbstractValueEncoder

Field Summary

Fields

Modifier and Type	Field and Description
private byte[]	streamConvertBuf

Fields inherited from class com.mysql.cj.protocol.a.AbstractValueEncoder

charEncoding, exceptionInterceptor, preserveInstants, propertySet, sendFractionalSeconds, sendFractionalSecondsForTime, serverSession

Constructor Summary

Constructors

Constructor and Description
InputStreamValueEncoder()

Method Summary

Modifier and Type	Method and Description
void	encodeAsBinary(Message msg, BindValue binding)
void	encodeAsText(Message msg, BindValue binding)
private void	escapeblockFast(byte[] buf, NativePacketPayload packet, int size)
byte[]	getBytes(BindValue binding)
java.lang.String	getString(BindValue binding)
protected byte[]	streamToBytes(java.io.InputStream in, long length, NativePacketPayload packet)

Methods inherited from class com.mysql.cj.protocol.a.AbstractValueEncoder

adjustDuration, adjustLocalDateTime, adjustLocalTime, adjustTime, adjustTimestamp, encodeAsQueryAttribute, escapeBytesIfNeeded, getBinaryLength, getScaled, getTextLength, init, writeDate, writeDateTime, writeDateTimeWithOffset, writeTime

Methods inherited from class java.lang.Object

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

Field Detail

streamConvertBuf

private byte[] streamConvertBuf

Constructor Detail

InputStreamValueEncoder

public InputStreamValueEncoder()

Method Detail

getBytes

public byte[] getBytes(BindValue binding)

Specified by:

getBytes in interface ValueEncoder

Overrides:

getBytes in class AbstractValueEncoder

getString

public java.lang.String getString(BindValue binding)

encodeAsText

public void encodeAsText(Message msg,
                         BindValue binding)

Specified by:

encodeAsText in interface ValueEncoder

Overrides:

encodeAsText in class AbstractValueEncoder

encodeAsBinary

public void encodeAsBinary(Message msg,
                           BindValue binding)

streamToBytes

protected byte[] streamToBytes(java.io.InputStream in,
                               long length,
                               NativePacketPayload packet)

escapeblockFast

private final void escapeblockFast(byte[] buf,
                                   NativePacketPayload packet,
                                   int size)