com.continuent.tungsten.replicator.extractor.mysql
Class QueryLogEvent

java.lang.Object
  com.continuent.tungsten.replicator.extractor.mysql.LogEvent
      com.continuent.tungsten.replicator.extractor.mysql.QueryLogEvent

Direct Known Subclasses:

ExecuteLoadQueryLogEvent

public class QueryLogEvent
extends LogEvent

Version:

1.0

Author:

Seppo Jaakola, Stephane Giron

Field Summary

protected byte[]	charset
protected boolean	charset_inited
protected java.lang.String	charsetName
protected int	clientCharsetId
protected int	clientCollationId
protected java.lang.String	databaseName
protected int	errorCode
protected boolean	parseStatements
protected java.lang.String	query Fixed data part: 4 bytes.
protected byte[]	queryAsBytes
protected int	serverCollationId
protected long	threadId

Fields inherited from class com.continuent.tungsten.replicator.extractor.mysql.LogEvent

execTime, flags, logPos, serverId, startPosition, threadSpecificEvent, type, when

Constructor Summary

protected	QueryLogEvent(byte[] buffer, FormatDescriptionLogEvent descriptionEvent, int eventType)
	QueryLogEvent(byte[] buffer, int eventLength, FormatDescriptionLogEvent descriptionEvent, boolean parseStatements, boolean useBytesForString, java.lang.String currentPosition)

Method Summary

protected int	extractStatusVariables(byte[] buffer, int start, int end)
java.lang.String	getAutocommitFlag() Returns the flagAutocommit value.
int	getAutoIncrementIncrement()
int	getAutoIncrementOffset()
java.lang.String	getAutoIsNullFlag() Returns the flagAutoIsNull value.
java.lang.String	getCharsetName() Return the native charset used to store query as bytes.
int	getClientCharsetId() Returns the charsetID value.
int	getClientCollationId() Returns the clientCollationId value.
java.lang.String	getDefaultDb()
int	getErrorCode()
java.lang.String	getForeignKeyChecksFlag() Returns the flagForeignKeyChecks value.
java.lang.String	getQuery()
byte[]	getQueryAsBytes()
int	getServerCollationId() Returns the serverCollationId value.
long	getSessionId()
java.lang.String	getSqlMode() Returns the sqlModeAsString value.
java.lang.String	getUniqueChecksFlag() Returns the flagUniqueChecks value.

Methods inherited from class com.continuent.tungsten.replicator.extractor.mysql.LogEvent

doChecksum, extractDecimal, getDecimalBinarySize, getExecTime, getNextEventPosition, getType, getWhen, hexdump, hexdump, hexdump, readLogEvent

Methods inherited from class java.lang.Object

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

Field Detail

query

protected java.lang.String query

Fixed data part:

• 4 bytes. The ID of the thread that issued this statement. Needed for temporary tables. This is also useful for a DBA for knowing who did what on the master.
• 4 bytes. The time in seconds that the statement took to execute. Only useful for inspection by the DBA.
• 1 byte. The length of the name of the database which was the default database when the statement was executed. This name appears later, in the variable data part. It is necessary for statements such as INSERT INTO t VALUES(1) that don't specify the database and rely on the default database previously selected by USE.
• 2 bytes. The error code resulting from execution of the statement on the master. Error codes are defined in include/mysqld_error.h. 0 means no error. How come statements with a non-zero error code can exist in the binary log? This is mainly due to the use of non-transactional tables within transactions. For example, if an INSERT ... SELECT fails after inserting 1000 rows into a MyISAM table (for example, with a duplicate-key violation), we have to write this statement to the binary log, because it truly modified the MyISAM table. For transactional tables, there should be no event with a non-zero error code (though it can happen, for example if the connection was interrupted (Control-C)). The slave checks the error code: After executing the statement itself, it compares the error code it got with the error code in the event, and if they are different it stops replicating (unless --slave-skip-errors was used to ignore the error).
• 2 bytes (not present in v1, v3). The length of the status variable block.

Variable part:

• Zero or more status variables (not present in v1, v3). Each status variable consists of one byte code identifying the variable stored, followed by the value of the variable. The format of the value is variable-specific, as described later.
• The default database name (null-terminated).
• The SQL statement. The slave knows the size of the other fields in the variable part (the sizes are given in the fixed data part), so by subtraction it can know the size of the statement.

Source : http://forge.mysql.com/wiki/MySQL_Internals_Binary_Log

queryAsBytes

protected byte[] queryAsBytes

charsetName

protected java.lang.String charsetName

databaseName

protected java.lang.String databaseName

errorCode

protected int errorCode

threadId

protected long threadId

charset_inited

protected boolean charset_inited

charset

protected byte[] charset

clientCharsetId

protected int clientCharsetId

clientCollationId

protected int clientCollationId

serverCollationId

protected int serverCollationId

parseStatements

protected boolean parseStatements

Constructor Detail

QueryLogEvent

protected QueryLogEvent(byte[] buffer,
                        FormatDescriptionLogEvent descriptionEvent,
                        int eventType)
                 throws ReplicatorException

Throws:

ReplicatorException

QueryLogEvent

public QueryLogEvent(byte[] buffer,
                     int eventLength,
                     FormatDescriptionLogEvent descriptionEvent,
                     boolean parseStatements,
                     boolean useBytesForString,
                     java.lang.String currentPosition)
              throws ReplicatorException

Throws:

ReplicatorException

Method Detail

getQuery

public java.lang.String getQuery()

getDefaultDb

public java.lang.String getDefaultDb()

getSessionId

public long getSessionId()

getErrorCode

public int getErrorCode()

extractStatusVariables

protected int extractStatusVariables(byte[] buffer,
                                     int start,
                                     int end)
                              throws ReplicatorException

Throws:

ReplicatorException

getSqlMode

public java.lang.String getSqlMode()

Returns the sqlModeAsString value.

Returns:

Returns the sqlModeAsString.

getAutoIsNullFlag

public java.lang.String getAutoIsNullFlag()

Returns the flagAutoIsNull value.

Returns:

Returns the flagAutoIsNull.

getForeignKeyChecksFlag

public java.lang.String getForeignKeyChecksFlag()

Returns the flagForeignKeyChecks value.

Returns:

Returns the flagForeignKeyChecks.

getAutocommitFlag

public java.lang.String getAutocommitFlag()

Returns the flagAutocommit value.

Returns:

Returns the flagAutocommit.

getUniqueChecksFlag

public java.lang.String getUniqueChecksFlag()

Returns the flagUniqueChecks value.

Returns:

Returns the flagUniqueChecks.

getClientCharsetId

public int getClientCharsetId()

Returns the charsetID value.

Returns:

Returns the charsetID.

getClientCollationId

public int getClientCollationId()

Returns the clientCollationId value.

Returns:

Returns the clientCollationId.

getServerCollationId

public int getServerCollationId()

Returns the serverCollationId value.

Returns:

Returns the serverCollationId.

getAutoIncrementIncrement

public int getAutoIncrementIncrement()

getAutoIncrementOffset

public int getAutoIncrementOffset()

getQueryAsBytes

public byte[] getQueryAsBytes()

getCharsetName

public java.lang.String getCharsetName()

Return the native charset used to store query as bytes.