com.taobao.tddl.dbsync.binlog

类 DirectLogFetcher

java.lang.Object

com.taobao.tddl.dbsync.binlog.LogBuffer

com.taobao.tddl.dbsync.binlog.LogFetcher

com.taobao.tddl.dbsync.binlog.DirectLogFetcher

所有已实现的接口:

java.io.Closeable, java.lang.AutoCloseable

public final class DirectLogFetcher
extends LogFetcher

TODO: Document It!!

 DirectLogFetcher fetcher = new DirectLogFetcher();
 fetcher.open(conn, file, 0, 13);
 
 while (fetcher.fetch()) {
     LogEvent event;
     do {
         event = decoder.decode(fetcher, context);
 
         // process log event.
     } while (event != null);
 }
 // connection closed.
 

版本:

1.0

作者:

Changyuan.lh

字段概要

字段

限定符和类型	字段和说明
static int	BINLOG_DUMP_NON_BLOCK BINLOG_DUMP options
static int	BINLOG_SEND_ANNOTATE_ROWS_EVENT
static byte	COM_BINLOG_DUMP Command to dump binlog
protected static org.apache.commons.logging.Log	logger
static int	MAX_PACKET_LENGTH Maximum packet length
static int	NET_HEADER_SIZE Packet header sizes
static int	PACKET_LEN_OFFSET Packet offsets
static int	PACKET_SEQ_OFFSET
static int	SQLSTATE_LENGTH

从类继承的字段 com.taobao.tddl.dbsync.binlog.LogFetcher

BIN_LOG_HEADER_SIZE, DEFAULT_GROWTH_FACTOR, DEFAULT_INITIAL_CAPACITY, factor

从类继承的字段 com.taobao.tddl.dbsync.binlog.LogBuffer

BIGINT_MAX_VALUE, buffer, DIG_BASE, DIG_MAX, DIG_PER_DEC1, DIG_PER_INT32, dig2bytes, ISO_8859_1, limit, NULL_LENGTH, origin, position, powers10, semival, SIZE_OF_INT32

构造器概要

构造器

构造器和说明
DirectLogFetcher()
DirectLogFetcher(int initialCapacity)
DirectLogFetcher(int initialCapacity, float growthFactor)

方法概要

限定符和类型	方法和说明
void	close()
boolean	fetch() Fetches the next frame of binary-log, and fill it in buffer.
void	open(java.sql.Connection conn, java.lang.String fileName, int serverId) Connect MySQL master to fetch binlog.
void	open(java.sql.Connection conn, java.lang.String fileName, int serverId, boolean nonBlocking) Connect MySQL master to fetch binlog.
void	open(java.sql.Connection conn, java.lang.String fileName, long filePosition, int serverId) Connect MySQL master to fetch binlog.
void	open(java.sql.Connection conn, java.lang.String fileName, long filePosition, int serverId, boolean nonBlocking) Connect MySQL master to fetch binlog.
protected void	putByte(byte b) Put a byte in the buffer.
protected void	putInt16(int i16) Put 16-bit integer in the buffer.
protected void	putInt32(long i32) Put 32-bit integer in the buffer.
protected void	putString(java.lang.String s) Put a string in the buffer.
protected void	sendBinlogDump(java.lang.String fileName, long filePosition, int serverId, boolean nonBlocking)

从类继承的方法 com.taobao.tddl.dbsync.binlog.LogFetcher

ensureCapacity

从类继承的方法 com.taobao.tddl.dbsync.binlog.LogBuffer

capacity, consume, duplicate, duplicate, duplicate, fillBitmap, fillBitmap, fillBytes, fillBytes, fillOutput, fillOutput, forward, getBeInt16, getBeInt16, getBeInt24, getBeInt24, getBeInt32, getBeInt32, getBeLong48, getBeLong48, getBeLong64, getBeLong64, getBeUint16, getBeUint16, getBeUint24, getBeUint24, getBeUint32, getBeUint32, getBeUlong40, getBeUlong40, getBeUlong48, getBeUlong48, getBeUlong56, getBeUlong56, getBeUlong64, getBeUlong64, getBitmap, getBitmap, getData, getData, getData, getDecimal, getDecimal, getDouble64, getDouble64, getFixString, getFixString, getFixString, getFixString, getFloat32, getFloat32, getFullString, getFullString, getInt16, getInt16, getInt24, getInt24, getInt32, getInt32, getInt8, getInt8, getLong48, getLong48, getLong64, getLong64, getPackedLong, getPackedLong, getString, getString, getString, getString, getUint16, getUint16, getUint24, getUint24, getUint32, getUint32, getUint8, getUint8, getUlong40, getUlong40, getUlong48, getUlong48, getUlong56, getUlong56, getUlong64, getUlong64, hasRemaining, hexdump, hexdump, limit, limit, position, position, remaining, rewind

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

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

字段详细资料

logger

protected static final org.apache.commons.logging.Log logger

COM_BINLOG_DUMP

public static final byte COM_BINLOG_DUMP

Command to dump binlog

另请参阅:

常量字段值

NET_HEADER_SIZE

public static final int NET_HEADER_SIZE

Packet header sizes

另请参阅:

常量字段值

SQLSTATE_LENGTH

public static final int SQLSTATE_LENGTH

另请参阅:

常量字段值

PACKET_LEN_OFFSET

public static final int PACKET_LEN_OFFSET

Packet offsets

另请参阅:

常量字段值

PACKET_SEQ_OFFSET

public static final int PACKET_SEQ_OFFSET

另请参阅:

常量字段值

MAX_PACKET_LENGTH

public static final int MAX_PACKET_LENGTH

Maximum packet length

另请参阅:

常量字段值

BINLOG_DUMP_NON_BLOCK

public static final int BINLOG_DUMP_NON_BLOCK

BINLOG_DUMP options

另请参阅:

常量字段值

BINLOG_SEND_ANNOTATE_ROWS_EVENT

public static final int BINLOG_SEND_ANNOTATE_ROWS_EVENT

另请参阅:

常量字段值

构造器详细资料

DirectLogFetcher

public DirectLogFetcher()

DirectLogFetcher

public DirectLogFetcher(int initialCapacity)

DirectLogFetcher

public DirectLogFetcher(int initialCapacity,
                        float growthFactor)

方法详细资料

open

public void open(java.sql.Connection conn,
                 java.lang.String fileName,
                 int serverId)
          throws java.io.IOException

Connect MySQL master to fetch binlog.

抛出:

java.io.IOException

open

public void open(java.sql.Connection conn,
                 java.lang.String fileName,
                 int serverId,
                 boolean nonBlocking)
          throws java.io.IOException

Connect MySQL master to fetch binlog.

抛出:

java.io.IOException

open

public void open(java.sql.Connection conn,
                 java.lang.String fileName,
                 long filePosition,
                 int serverId)
          throws java.io.IOException

Connect MySQL master to fetch binlog.

抛出:

java.io.IOException

open

public void open(java.sql.Connection conn,
                 java.lang.String fileName,
                 long filePosition,
                 int serverId,
                 boolean nonBlocking)
          throws java.io.IOException

Connect MySQL master to fetch binlog.

抛出:

java.io.IOException

putByte

protected final void putByte(byte b)

Put a byte in the buffer.

参数:

b - the byte to put in the buffer

putInt16

protected final void putInt16(int i16)

Put 16-bit integer in the buffer.

参数:

i16 - the integer to put in the buffer

putInt32

protected final void putInt32(long i32)

Put 32-bit integer in the buffer.

参数:

i32 - the integer to put in the buffer

putString

protected final void putString(java.lang.String s)

Put a string in the buffer.

参数:

s - the value to put in the buffer

sendBinlogDump

protected final void sendBinlogDump(java.lang.String fileName,
                                    long filePosition,
                                    int serverId,
                                    boolean nonBlocking)
                             throws java.io.IOException

抛出:

java.io.IOException

fetch

public boolean fetch()
              throws java.io.IOException

Fetches the next frame of binary-log, and fill it in buffer.

指定者:

fetch 在类中 LogFetcher

抛出:

java.io.IOException

另请参阅:

LogFetcher.fetch()

close

public void close()
           throws java.io.IOException

指定者:

close 在接口中 java.io.Closeable

指定者:

close 在接口中 java.lang.AutoCloseable

指定者:

close 在类中 LogFetcher

抛出:

java.io.IOException

另请参阅:

LogFetcher.close()