net.neoremind.fountain.support
类 TrxContext

java.lang.Object
  net.neoremind.fountain.support.TrxContext

public class TrxContext
extends Object

事务上下文，一般用于在接收binlog的主处理流程中保存一些上下文信息，例如包括：

• 当前正在处理事务的gtid
• 当前正在处理事务的binlog filename和position
• binlog最先接到固定的一个FormatDescriptionEvent，包含MySQL的一些基本信息，例如版本

作者：

zhangxu

方法摘要

static TrxContext	factory() 静态构造方法
String	getBinlogFileName()
Long	getCurrBinlogPosition()
Long	getCurrGtId()
FormatDescriptionEvent	getFmtDescEvent()
Long	getNextBinlogPosition()
byte[]	getSid()
void	handleEvent(BaseLogEvent event)
boolean	isChecksumSupport()
void	setBinlogFileName(String binlogFileName)
void	setCurrBinlogPosition(Long currBinlogPosition)
void	setCurrGtId(Long currGtId)
void	setFmtDescEvent(FormatDescriptionEvent fmtDescEvent)
void	setIsChecksumSupport(boolean isChecksumSupport)
void	setNextBinlogPosition(Long nextBinlogPosition)
void	setSid(byte[] sid)
String	toString()

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

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

方法详细信息

factory

public static TrxContext factory()

静态构造方法

返回：

TrxContext

toString

public String toString()

覆盖：

类 Object 中的 toString

handleEvent

public void handleEvent(BaseLogEvent event)

getSid

public byte[] getSid()

setSid

public void setSid(byte[] sid)

getFmtDescEvent

public FormatDescriptionEvent getFmtDescEvent()

setFmtDescEvent

public void setFmtDescEvent(FormatDescriptionEvent fmtDescEvent)

getCurrGtId

public Long getCurrGtId()

setCurrGtId

public void setCurrGtId(Long currGtId)

getBinlogFileName

public String getBinlogFileName()

setBinlogFileName

public void setBinlogFileName(String binlogFileName)

getNextBinlogPosition

public Long getNextBinlogPosition()

setNextBinlogPosition

public void setNextBinlogPosition(Long nextBinlogPosition)

getCurrBinlogPosition

public Long getCurrBinlogPosition()

setCurrBinlogPosition

public void setCurrBinlogPosition(Long currBinlogPosition)

isChecksumSupport

public boolean isChecksumSupport()

setIsChecksumSupport

public void setIsChecksumSupport(boolean isChecksumSupport)