com.taobao.tddl.dbsync.binlog

类 LogBuffer

java.lang.Object

com.taobao.tddl.dbsync.binlog.LogBuffer

直接已知子类:

LogFetcher

public class LogBuffer
extends java.lang.Object

TODO: Document Me!!

版本:

1.0

作者:

Changyuan.lh

字段概要

字段

限定符和类型	字段和说明
static java.math.BigInteger	BIGINT_MAX_VALUE
protected byte[]	buffer
static int	DIG_BASE
static int	DIG_MAX
static int	DIG_PER_DEC1
static int	DIG_PER_INT32
static int[]	dig2bytes
static java.lang.String	ISO_8859_1
protected int	limit
static long	NULL_LENGTH
protected int	origin
protected int	position
static int[]	powers10
protected int	semival
static int	SIZE_OF_INT32

构造器概要

构造器

限定符	构造器和说明
protected	LogBuffer()
	LogBuffer(byte[] buffer, int origin, int limit)

方法概要

限定符和类型	方法和说明
int	capacity() Returns this buffer's capacity.
LogBuffer	consume(int len) Consume this buffer, moving origin and position.
LogBuffer	duplicate() Return next n bytes in this buffer.
LogBuffer	duplicate(int len) Return next n bytes in this buffer.
LogBuffer	duplicate(int pos, int len) Return n bytes in this buffer.
void	fillBitmap(java.util.BitSet bitmap, int len) Fill next MY_BITMAP structure from buffer.
void	fillBitmap(java.util.BitSet bitmap, int pos, int len) Fill MY_BITMAP structure from buffer.
void	fillBytes(byte[] dest, int destPos, int len) Fill next n bytes in this buffer.
void	fillBytes(int pos, byte[] dest, int destPos, int len) Fill n bytes in this buffer.
void	fillOutput(java.io.OutputStream out, int len) Fill next n bytes into output stream.
void	fillOutput(java.io.OutputStream out, int pos, int len) Fill n bytes into output stream.
LogBuffer	forward(int len) Forwards this buffer's position.
int	getBeInt16() Return next 16-bit signed int from buffer.
int	getBeInt16(int pos) Return 16-bit signed int from buffer.
int	getBeInt24() Return next 24-bit signed int from buffer.
int	getBeInt24(int pos) Return 24-bit signed int from buffer.
int	getBeInt32() Return next 32-bit signed int from buffer.
int	getBeInt32(int pos) Return 32-bit signed int from buffer.
long	getBeLong48() Return next 48-bit signed long from buffer.
long	getBeLong48(int pos) Return 48-bit signed long from buffer.
long	getBeLong64() Return next 64-bit signed long from buffer.
long	getBeLong64(int pos) Return 64-bit signed long from buffer.
int	getBeUint16() Return next 16-bit unsigned int from buffer.
int	getBeUint16(int pos) Return 16-bit unsigned int from buffer.
int	getBeUint24() Return next 24-bit unsigned int from buffer.
int	getBeUint24(int pos) Return 24-bit unsigned int from buffer.
long	getBeUint32() Return next 32-bit unsigned int from buffer.
long	getBeUint32(int pos) Return 32-bit unsigned int from buffer.
long	getBeUlong40() Return next 40-bit unsigned int from buffer.
long	getBeUlong40(int pos) Return 40-bit unsigned int from buffer.
long	getBeUlong48() Return next 48-bit unsigned long from buffer.
long	getBeUlong48(int pos) Return 48-bit unsigned long from buffer.
long	getBeUlong56() Return next 56-bit unsigned int from buffer.
long	getBeUlong56(int pos) Return 56-bit unsigned int from buffer.
java.math.BigInteger	getBeUlong64() Return next 64-bit unsigned long from buffer.
java.math.BigInteger	getBeUlong64(int pos) Return 64-bit unsigned long from buffer.
java.util.BitSet	getBitmap(int len) Return next MY_BITMAP structure from buffer.
java.util.BitSet	getBitmap(int pos, int len) Return MY_BITMAP structure from buffer.
byte[]	getData() Return all remaining data from buffer.
byte[]	getData(int len) Return next n-byte data from buffer.
byte[]	getData(int pos, int len) Return n-byte data from buffer.
java.math.BigDecimal	getDecimal(int precision, int scale) Return next big decimal from buffer.
java.math.BigDecimal	getDecimal(int pos, int precision, int scale) Return big decimal from buffer.
double	getDouble64() Return next 64-bit double from buffer.
double	getDouble64(int pos) Return 64-bit double from buffer.
java.lang.String	getFixString(int len) Return next fix length string from buffer.
java.lang.String	getFixString(int pos, int len) Return fix length string from buffer.
java.lang.String	getFixString(int pos, int len, java.lang.String charsetName) Return fix length string from buffer.
java.lang.String	getFixString(int len, java.lang.String charsetName) Return next fix length string from buffer.
float	getFloat32() Return next 32-bit float from buffer.
float	getFloat32(int pos) Return 32-bit float from buffer.
java.lang.String	getFullString(int pos, int len, java.lang.String charsetName) Return fix-length string from buffer without null-terminate checking.
java.lang.String	getFullString(int len, java.lang.String charsetName) Return next fix-length string from buffer without null-terminate checking.
int	getInt16() Return next 16-bit signed int from buffer.
int	getInt16(int pos) Return 16-bit signed int from buffer.
int	getInt24() Return next 24-bit signed int from buffer.
int	getInt24(int pos) Return 24-bit signed int from buffer.
int	getInt32() Return next 32-bit signed int from buffer.
int	getInt32(int pos) Return 32-bit signed int from buffer.
int	getInt8() Return next 8-bit signed int from buffer.
int	getInt8(int pos) Return 8-bit signed int from buffer.
long	getLong48() Return next 48-bit signed long from buffer.
long	getLong48(int pos) Return 48-bit signed long from buffer.
long	getLong64() Return next 64-bit signed long from buffer.
long	getLong64(int pos) Return 64-bit signed long from buffer.
long	getPackedLong() Return next packed number from buffer.
long	getPackedLong(int pos) Return packed number from buffer.
java.lang.String	getString() Return next dynamic length string from buffer.
java.lang.String	getString(int pos) Return dynamic length string from buffer.
java.lang.String	getString(int pos, java.lang.String charsetName) Return dynamic length string from buffer.
java.lang.String	getString(java.lang.String charsetName) Return next dynamic length string from buffer.
int	getUint16() Return next 16-bit unsigned int from buffer.
int	getUint16(int pos) Return 16-bit unsigned int from buffer.
int	getUint24() Return next 24-bit unsigned int from buffer.
int	getUint24(int pos) Return 24-bit unsigned int from buffer.
long	getUint32() Return next 32-bit unsigned int from buffer.
long	getUint32(int pos) Return 32-bit unsigned int from buffer.
int	getUint8() Return next 8-bit unsigned int from buffer.
int	getUint8(int pos) Return 8-bit unsigned int from buffer.
long	getUlong40() Return next 40-bit unsigned int from buffer.
long	getUlong40(int pos) Return 40-bit unsigned int from buffer.
long	getUlong48() Return next 48-bit unsigned long from buffer.
long	getUlong48(int pos) Return 48-bit unsigned long from buffer.
long	getUlong56() Return next 56-bit unsigned int from buffer.
long	getUlong56(int pos) Return 56-bit unsigned int from buffer.
java.math.BigInteger	getUlong64() Return next 64-bit unsigned long from buffer.
java.math.BigInteger	getUlong64(int pos) Return 64-bit unsigned long from buffer.
boolean	hasRemaining() Tells whether there are any elements between the current position and the limit.
java.lang.String	hexdump(int pos) Return full hexdump from position.
java.lang.String	hexdump(int pos, int len) Return hexdump from position, for len bytes.
int	limit() Returns this buffer's limit.
LogBuffer	limit(int newLimit) Sets this buffer's limit.
int	position() Returns this buffer's position.
LogBuffer	position(int newPosition) Sets this buffer's position.
int	remaining() Returns the number of elements between the current position and the limit.
LogBuffer	rewind() Rewinds this buffer.

从类继承的方法 java.lang.Object

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

字段详细资料

buffer

protected byte[] buffer

origin

protected int origin

limit

protected int limit

position

protected int position

semival

protected int semival

BIGINT_MAX_VALUE

public static final java.math.BigInteger BIGINT_MAX_VALUE

NULL_LENGTH

public static final long NULL_LENGTH

另请参阅:

常量字段值

ISO_8859_1

public static final java.lang.String ISO_8859_1

另请参阅:

常量字段值

DIG_PER_DEC1

public static final int DIG_PER_DEC1

另请参阅:

常量字段值

DIG_BASE

public static final int DIG_BASE

另请参阅:

常量字段值

DIG_MAX

public static final int DIG_MAX

另请参阅:

常量字段值

dig2bytes

public static final int[] dig2bytes

powers10

public static final int[] powers10

DIG_PER_INT32

public static final int DIG_PER_INT32

另请参阅:

常量字段值

SIZE_OF_INT32

public static final int SIZE_OF_INT32

另请参阅:

常量字段值

构造器详细资料

LogBuffer

protected LogBuffer()

LogBuffer

public LogBuffer(byte[] buffer,
                 int origin,
                 int limit)

方法详细资料

duplicate

public final LogBuffer duplicate(int pos,
                                 int len)

Return n bytes in this buffer.

duplicate

public final LogBuffer duplicate(int len)

Return next n bytes in this buffer.

duplicate

public final LogBuffer duplicate()

Return next n bytes in this buffer.

capacity

public final int capacity()

Returns this buffer's capacity.

返回:

The capacity of this buffer

position

public final int position()

Returns this buffer's position.

返回:

The position of this buffer

position

public final LogBuffer position(int newPosition)

Sets this buffer's position. If the mark is defined and larger than the new position then it is discarded.

参数:

newPosition - The new position value; must be non-negative and no larger than the current limit

返回:

This buffer

抛出:

java.lang.IllegalArgumentException - If the preconditions on newPosition do not hold

forward

public final LogBuffer forward(int len)

Forwards this buffer's position.

参数:

len - The forward distance

返回:

This buffer

consume

public final LogBuffer consume(int len)

Consume this buffer, moving origin and position.

参数:

len - The consume distance

返回:

This buffer

rewind

public final LogBuffer rewind()

Rewinds this buffer. The position is set to zero.

返回:

This buffer

limit

public final int limit()

Returns this buffer's limit.

返回:

The limit of this buffer

limit

public final LogBuffer limit(int newLimit)

Sets this buffer's limit. If the position is larger than the new limit then it is set to the new limit. If the mark is defined and larger than the new limit then it is discarded.

参数:

newLimit - The new limit value; must be non-negative and no larger than this buffer's capacity

返回:

This buffer

抛出:

java.lang.IllegalArgumentException - If the preconditions on newLimit do not hold

remaining

public final int remaining()

Returns the number of elements between the current position and the limit.

返回:

The number of elements remaining in this buffer

hasRemaining

public final boolean hasRemaining()

Tells whether there are any elements between the current position and the limit.

返回:

true if, and only if, there is at least one element remaining in this buffer

getInt8

public final int getInt8(int pos)

Return 8-bit signed int from buffer.

getInt8

public final int getInt8()

Return next 8-bit signed int from buffer.

getUint8

public final int getUint8(int pos)

Return 8-bit unsigned int from buffer.

getUint8

public final int getUint8()

Return next 8-bit unsigned int from buffer.

getInt16

public final int getInt16(int pos)

Return 16-bit signed int from buffer. (little-endian)

另请参阅:

- sint2korr

getInt16

public final int getInt16()

Return next 16-bit signed int from buffer. (little-endian)

另请参阅:

- sint2korr

getUint16

public final int getUint16(int pos)

Return 16-bit unsigned int from buffer. (little-endian)

另请参阅:

- uint2korr

getUint16

public final int getUint16()

Return next 16-bit unsigned int from buffer. (little-endian)

另请参阅:

- uint2korr

getBeInt16

public final int getBeInt16(int pos)

Return 16-bit signed int from buffer. (big-endian)

另请参阅:

- mi_sint2korr

getBeInt16

public final int getBeInt16()

Return next 16-bit signed int from buffer. (big-endian)

另请参阅:

- mi_sint2korr

getBeUint16

public final int getBeUint16(int pos)

Return 16-bit unsigned int from buffer. (big-endian)

另请参阅:

- mi_usint2korr

getBeUint16

public final int getBeUint16()

Return next 16-bit unsigned int from buffer. (big-endian)

另请参阅:

- mi_usint2korr

getInt24

public final int getInt24(int pos)

Return 24-bit signed int from buffer. (little-endian)

另请参阅:

- sint3korr

getInt24

public final int getInt24()

Return next 24-bit signed int from buffer. (little-endian)

另请参阅:

- sint3korr

getBeInt24

public final int getBeInt24(int pos)

Return 24-bit signed int from buffer. (big-endian)

另请参阅:

- mi_usint3korr

getBeInt24

public final int getBeInt24()

Return next 24-bit signed int from buffer. (big-endian)

另请参阅:

- mi_usint3korr

getUint24

public final int getUint24(int pos)

Return 24-bit unsigned int from buffer. (little-endian)

另请参阅:

- uint3korr

getUint24

public final int getUint24()

Return next 24-bit unsigned int from buffer. (little-endian)

另请参阅:

- uint3korr

getBeUint24

public final int getBeUint24(int pos)

Return 24-bit unsigned int from buffer. (big-endian)

另请参阅:

- mi_usint3korr

getBeUint24

public final int getBeUint24()

Return next 24-bit unsigned int from buffer. (big-endian)

另请参阅:

- mi_usint3korr

getInt32

public final int getInt32(int pos)

Return 32-bit signed int from buffer. (little-endian)

另请参阅:

- sint4korr

getBeInt32

public final int getBeInt32(int pos)

Return 32-bit signed int from buffer. (big-endian)

另请参阅:

- mi_sint4korr

getInt32

public final int getInt32()

Return next 32-bit signed int from buffer. (little-endian)

另请参阅:

- sint4korr

getBeInt32

public final int getBeInt32()

Return next 32-bit signed int from buffer. (big-endian)

另请参阅:

- mi_sint4korr

getUint32

public final long getUint32(int pos)

Return 32-bit unsigned int from buffer. (little-endian)

另请参阅:

- uint4korr

getBeUint32

public final long getBeUint32(int pos)

Return 32-bit unsigned int from buffer. (big-endian)

另请参阅:

- mi_usint4korr

getUint32

public final long getUint32()

Return next 32-bit unsigned int from buffer. (little-endian)

另请参阅:

- uint4korr

getBeUint32

public final long getBeUint32()

Return next 32-bit unsigned int from buffer. (big-endian)

另请参阅:

- mi_uint4korr

getUlong40

public final long getUlong40(int pos)

Return 40-bit unsigned int from buffer. (little-endian)

getUlong40

public final long getUlong40()

Return next 40-bit unsigned int from buffer. (little-endian)

getBeUlong40

public final long getBeUlong40(int pos)

Return 40-bit unsigned int from buffer. (big-endian)

另请参阅:

- mi_uint5korr

getBeUlong40

public final long getBeUlong40()

Return next 40-bit unsigned int from buffer. (big-endian)

另请参阅:

- mi_uint5korr

getLong48

public final long getLong48(int pos)

Return 48-bit signed long from buffer. (little-endian)

另请参阅:

- sint6korr

getBeLong48

public final long getBeLong48(int pos)

Return 48-bit signed long from buffer. (big-endian)

另请参阅:

- mi_sint6korr

getLong48

public final long getLong48()

Return next 48-bit signed long from buffer. (little-endian)

另请参阅:

- sint6korr

getBeLong48

public final long getBeLong48()

Return next 48-bit signed long from buffer. (Big-endian)

另请参阅:

- mi_sint6korr

getUlong48

public final long getUlong48(int pos)

Return 48-bit unsigned long from buffer. (little-endian)

另请参阅:

- uint6korr

getBeUlong48

public final long getBeUlong48(int pos)

Return 48-bit unsigned long from buffer. (big-endian)

另请参阅:

- mi_uint6korr

getUlong48

public final long getUlong48()

Return next 48-bit unsigned long from buffer. (little-endian)

另请参阅:

- uint6korr

getBeUlong48

public final long getBeUlong48()

Return next 48-bit unsigned long from buffer. (big-endian)

另请参阅:

- mi_uint6korr

getUlong56

public final long getUlong56(int pos)

Return 56-bit unsigned int from buffer. (little-endian)

getUlong56

public final long getUlong56()

Return next 56-bit unsigned int from buffer. (little-endian)

getBeUlong56

public final long getBeUlong56(int pos)

Return 56-bit unsigned int from buffer. (big-endian)

getBeUlong56

public final long getBeUlong56()

Return next 56-bit unsigned int from buffer. (big-endian)

getLong64

public final long getLong64(int pos)

Return 64-bit signed long from buffer. (little-endian)

另请参阅:

- sint8korr

getBeLong64

public final long getBeLong64(int pos)

Return 64-bit signed long from buffer. (big-endian)

另请参阅:

- mi_sint8korr

getLong64

public final long getLong64()

Return next 64-bit signed long from buffer. (little-endian)

另请参阅:

- sint8korr

getBeLong64

public final long getBeLong64()

Return next 64-bit signed long from buffer. (big-endian)

另请参阅:

- mi_sint8korr

getUlong64

public final java.math.BigInteger getUlong64(int pos)

Return 64-bit unsigned long from buffer. (little-endian)

另请参阅:

- uint8korr

getBeUlong64

public final java.math.BigInteger getBeUlong64(int pos)

Return 64-bit unsigned long from buffer. (big-endian)

另请参阅:

- mi_uint8korr

getUlong64

public final java.math.BigInteger getUlong64()

Return next 64-bit unsigned long from buffer. (little-endian)

另请参阅:

- uint8korr

getBeUlong64

public final java.math.BigInteger getBeUlong64()

Return next 64-bit unsigned long from buffer. (big-endian)

另请参阅:

- mi_uint8korr

getFloat32

public final float getFloat32(int pos)

Return 32-bit float from buffer. (little-endian)

另请参阅:

- float4get

getFloat32

public final float getFloat32()

Return next 32-bit float from buffer. (little-endian)

另请参阅:

- float4get

getDouble64

public final double getDouble64(int pos)

Return 64-bit double from buffer. (little-endian)

另请参阅:

- float8get

getDouble64

public final double getDouble64()

Return next 64-bit double from buffer. (little-endian)

另请参阅:

- float8get

getPackedLong

public final long getPackedLong(int pos)

Return packed number from buffer. (little-endian) A Packed Integer has the capacity of storing up to 8-byte integers, while small integers still can use 1, 3, or 4 bytes. The value of the first byte determines how to read the number, according to the following table.

• 0-250 The first byte is the number (in the range 0-250). No additional bytes are used.
• 252 Two more bytes are used. The number is in the range 251-0xffff.
• 253 Three more bytes are used. The number is in the range 0xffff-0xffffff.
• 254 Eight more bytes are used. The number is in the range 0xffffff-0xffffffffffffffff.

That representation allows a first byte value of 251 to represent the SQL NULL value.

getPackedLong

public final long getPackedLong()

Return next packed number from buffer. (little-endian)

另请参阅:

getPackedLong(int)

getFixString

public final java.lang.String getFixString(int pos,
                                           int len)

Return fix length string from buffer.

getFixString

public final java.lang.String getFixString(int len)

Return next fix length string from buffer.

getFixString

public final java.lang.String getFixString(int pos,
                                           int len,
                                           java.lang.String charsetName)

Return fix length string from buffer.

getFixString

public final java.lang.String getFixString(int len,
                                           java.lang.String charsetName)

Return next fix length string from buffer.

getFullString

public final java.lang.String getFullString(int pos,
                                            int len,
                                            java.lang.String charsetName)

Return fix-length string from buffer without null-terminate checking. Fix bug #17 https://github.com/AlibabaTech/canal/issues/17

getFullString

public final java.lang.String getFullString(int len,
                                            java.lang.String charsetName)

Return next fix-length string from buffer without null-terminate checking. Fix bug #17 ://github.com/AlibabaTech/canal/issues/17

getString

public final java.lang.String getString(int pos)

Return dynamic length string from buffer.

getString

public final java.lang.String getString()

Return next dynamic length string from buffer.

getString

public final java.lang.String getString(int pos,
                                        java.lang.String charsetName)

Return dynamic length string from buffer.

getString

public final java.lang.String getString(java.lang.String charsetName)

Return next dynamic length string from buffer.

getDecimal

public final java.math.BigDecimal getDecimal(int pos,
                                             int precision,
                                             int scale)

Return big decimal from buffer.

另请参阅:

- bin2decimal()

getDecimal

public final java.math.BigDecimal getDecimal(int precision,
                                             int scale)

Return next big decimal from buffer.

另请参阅:

- bin2decimal()

fillBitmap

public final void fillBitmap(java.util.BitSet bitmap,
                             int pos,
                             int len)

Fill MY_BITMAP structure from buffer.

参数:

len - The length of MY_BITMAP in bits.

fillBitmap

public final void fillBitmap(java.util.BitSet bitmap,
                             int len)

Fill next MY_BITMAP structure from buffer.

参数:

len - The length of MY_BITMAP in bits.

getBitmap

public final java.util.BitSet getBitmap(int pos,
                                        int len)

Return MY_BITMAP structure from buffer.

参数:

len - The length of MY_BITMAP in bits.

getBitmap

public final java.util.BitSet getBitmap(int len)

Return next MY_BITMAP structure from buffer.

参数:

len - The length of MY_BITMAP in bits.

fillOutput

public final void fillOutput(java.io.OutputStream out,
                             int pos,
                             int len)
                      throws java.io.IOException

Fill n bytes into output stream.

抛出:

java.io.IOException

fillOutput

public final void fillOutput(java.io.OutputStream out,
                             int len)
                      throws java.io.IOException

Fill next n bytes into output stream.

抛出:

java.io.IOException

fillBytes

public final void fillBytes(int pos,
                            byte[] dest,
                            int destPos,
                            int len)

Fill n bytes in this buffer.

fillBytes

public final void fillBytes(byte[] dest,
                            int destPos,
                            int len)

Fill next n bytes in this buffer.

getData

public final byte[] getData(int pos,
                            int len)

Return n-byte data from buffer.

getData

public final byte[] getData(int len)

Return next n-byte data from buffer.

getData

public final byte[] getData()

Return all remaining data from buffer.

hexdump

public final java.lang.String hexdump(int pos)

Return full hexdump from position.

hexdump

public final java.lang.String hexdump(int pos,
                                      int len)

Return hexdump from position, for len bytes.