si d dl Z d dlZd dlZd dlZd dlZd dlT d dlmZ d dlm Z d dl
m Z d dl m
Z
mZ d dlZ G d de Z G d d
e Z G d d e Z G d
de Z G d de Z G d de Z G d de Z G d de Z G d de Z G d de Z G d d e Z G d d e Z G d d e Z G d! d"e Z G d# d$e Z G d% d&e Z G d' d(e Z! G d) d*e Z" G d+ d,e Z# G d- d.e Z$ G d/ d0e Z% G d1 d2e Z&dS )3 N)*)StatusVariableMismatch)parse_decimal_from_bytes)logger)UnionOptionalc x e Zd Z d
dZd Zd Zedefd Zd Z de
fd
Z defd Z d Z
dS ) BinLogEventr r r NFc : || _ || _ | j j | _ | j j | _ || _ || _ || _ | | _ | | _ d | _ d| _
d| _ | | j
| _ d S )NT)packet table_map
event_type timestamp
event_size_ctl_connection
mysql_version_ignore_decode_errors_verify_checksum_is_event_valid
_processedcomplete
_verify_event _get_dbmsdbms)self from_packetr r ctl_connectionr only_tablesignored_tables only_schemasignored_schemas
freeze_schemaignore_decode_errorsverify_checksumoptional_meta_dataenable_logginguse_column_name_caches ]/home/mmwave/public_html/mmwave/venv/lib/python3.11/site-packages/pymysqlreplication/event.py__init__zBinLogEvent.__init__ s $ " " +0 .$ - *%9" / #
(2244 c r | j d dz }t j d| d S )N s `_ `[see also] `_
:ivar commit_flag: 1byte - 00000001 = Transaction may have changes logged with SBR.
In 5.6, 5.7.0-5.7.18, and 8.0.0-8.0.1, this flag is always set. Starting in 5.7.19 and 8.0.2, this flag is cleared if the transaction only contains row events. It is set if any part of the transaction is written in statement format.
:ivar sid: 16 byte sequence - UUID representing the SID
:ivar gno: int - Group number, second component of GTID.
:ivar lt_type: int(1 byte) - The type of logical timestamp used in the logical clock fields.
:ivar last_committed: Store the transaction's commit parent sequence_number
:ivar sequence_number: The transaction's logical timestamp assigned at prepare phase
c t j ||||fi | t j d| j d d dk | _ | j d | _ t j d| j d d | _ | j d d | _ | j
dk rrt j d| j d d | _ t j d| j d d | _ d S d S )N!Br5 r r. ) )
superr* r0 r1 r
r/ commit_flagsidgnolt_typer last_committedsequence_numberr r r r r kwargsrP s r) r* zGtidEvent.__init__v s j)^VVvVVV!=t{/?/?/B/BCCAF!K;##B''=t{'7'7':':;;A>{''**1- ' '"(-dk6F6Fq6I6I"J"J1"MD #)=t{7G7G7J7J#K#KA#ND ( 'r+ c t j | j d }|dd d|dd d|dd d|dd d|dd d| j }|S ) z
GTID = source_id:transaction_id
Eg: 3E11FA47-71CA-11E1-9E33-C80AA9429562:23
See: http://dev.mysql.com/doc/refman/5.6/en/replication-gtids-concepts.htmlasciiNrg - rf r: :)binasciihexlifyrl decoderm )r nibblesgtids r) r| zGtidEvent.gtid s "48,,33G<<rr{
qt}
r"u~
r"u~
rss|
x
r+ c t d| j t d| j t | d r0t d| j t d| j d S d S )NzCommit: z GTID_NEXT: ro zlast_committed: zsequence_number: )rO rk r| hasattrro rp rJ s r) rS zGtidEvent._dump s
+)++,,,
'DI''((( 4) * * > :T%8:: ; ; ; >r+ c d| j dS )Nz )r| rJ s r) __repr__zGtidEvent.__repr__ s +di++++r+ )
rQ r] r^ __doc__r* r_ r| rS r
__classcell__rP s @r) rc rc g s
O
O
O
O
O X > > >, , , , , , ,r+ rc c . e Zd ZdZ fdZd Zd Z xZS )PreviousGtidsEventaN
PreviousGtidEvent is contains the Gtids executed in the last binary log file.
Attributes:
n_sid: which size is the gtid_set
sid: 16bytes UUID as a binary
n_intervals: how many intervals are sent
Eg: [4c9e3dfc-9d25-11e9-8d2e-0242ac1cfd7e:1-100, 4c9e3dfc-9d25-11e9-8d2e-0242ac1cfd7e:1-10:20-30]
c t t j ||||fi | j _ g _ t j D ]} j d } j } fdt | D } t j | d }
|
d d d|
dd d|
dd d|
dd d|
dd d| } j
| d j _ d S )
Nrf c z g | ]7}j d j 8S )ru )r
read_int64 read_uint64).0_r s r)
z/PreviousGtidsEvent.__init__.. sS ;))++IIdk.E.E.G.GII r+ rt rg ru rv r: z-:,)rj r r* r
r _n_sid_gtidsranger/ r rx ry rz appendjoin_previous_gtids)
r r r r r rr r rl n_intervals intervalsr{ r| rP s
` r) r* zPreviousGtidsEvent.__init__ s 0 $''0 Y
BH
k,,.. t{## % %A+""2&&C +1133K {++ I &s++227;;G2A2; 1R4= 2b5> 2b5> 233<
K t $ $ $ $ "xx 4 4 r+ c 4 t d| j d S )Nzprevious_gtids: )rO r rJ s r) rS zPreviousGtidsEvent._dump s"
7!57788888r+ c d| j dS )Nz`_.
:ivar server_id: int - The ID of the server where the GTID event occurred.
:ivar gtid_seq_no: int - The sequence number of the GTID event.
:ivar domain_id: int - The domain ID associated with the GTID event.
:ivar flags: int - Flags related to the GTID event.
:ivar gtid: str - The Global Transaction Identifier in the format ‘domain_id-server_id-gtid_seq_no’.
c T t j ||||fi | | j j | _ | j | _ | j | _ | j | _ | j d| j d| j | _
d S Nru ) rj r* r
server_idr gtid_seq_no read_uint32 domain_id
read_uint8flagsr| rq s r) r* zMariadbGtidEvent.__init__ s j)^VVvVVV . ;2244 0022[++--
~KKKK9IKK r+ c t t d| j t d| j d S )NFlags: zGTID: )rj rS rO r r| r rP s r) rS zMariadbGtidEvent._dump sL
$
$$%%%
"ty""#####r+ rQ r] r^ r r* rS r r s @r) r r s`
L L L L L$ $ $ $ $ $ $ $ $r+ r c ( e Zd ZdZ fdZd Z xZS ) MariadbBinLogCheckPointEventa;
Represents a checkpoint in a binlog event in MariaDB.
More details are available in the MariaDB Knowledge Base:
https://mariadb.com/kb/en/binlog_checkpoint_event/
:ivar filename_length: int - The length of the filename.
:ivar filename: str - The name of the file saved at the checkpoint.
c t t | j ||||fi | | j }| j | | _ d S rF )rj r r* r
r r/ rz filename)r r r r r rr filename_lengthrP s r) r* z%MariadbBinLogCheckPointEvent.__init__ sw :*D11: Y
BH
+1133 (( 99@@BB
r+ c 4 t d| j d S )Nz
Filename: )rO r rJ s r) rS z"MariadbBinLogCheckPointEvent._dump s!
*4=**+++++r+ r r s @r) r r sV C C C C C, , , , , , ,r+ r c , e Zd ZdZ fdZ fdZ xZS )MariadbAnnotateRowsEventz
Annotate rows event
If you want to check this binlog, change the value of the flag(line 382 of the 'binlogstream.py') option to 2
https://mariadb.com/kb/en/annotate_rows_event/
:ivar sql_statement: str - The SQL statement
c t j ||||fi | | j | | _ d S rF )rj r* r
r/
sql_statementrq s r) r* z!MariadbAnnotateRowsEvent.__init__ sF j)^VVvVVV ![ - -j 9 9r+ c v t t d| j d S )NzSQL statement : )rj rS rO r r s r) rS z MariadbAnnotateRowsEvent._dump
s4
5!35566666r+ r r s @r) r r s[ : : : : :7 7 7 7 7 7 7 7 7r+ r c " e Zd ZdZ fdZ xZS )MariadbGtidListEventas
GTID List event
https://mariadb.com/kb/en/gtid_list_event/
:ivar gtid_length: int - Number of GTIDs
:ivar gtid_list: list - list of 'MariadbGtidObejct'
'MariadbGtidObejct' Attributes:
domain_id: Replication Domain ID
server_id: Server_ID
gtid_seq_no: GTID sequence
gtid: 'domain_id'+ 'server_id' + 'gtid_seq_no'
c t t | j fi G fddt | j | _ fdt | j D | _ d S )Nc & e Zd ZdZ fdZ xZS )8MariadbGtidListEvent.__init__..MariadbGtidObejctzD
Information class of elements in GTID list
c 6 t | j ||||fi | | j | _ | j | _ | j | _ | j d| j d| j | _ d S r ) rj r* r
r r r r r r| r r r r r rr MariadbGtidObejctrP s r) r* zAMariadbGtidListEvent.__init__..MariadbGtidObejct.__init__( s 8'..7 Y JP "&!8!8!:!:!%!8!8!:!:#';#:#:#<#< #~ S S S SAQ S S r+ rQ r] r^ r r* r )rP r s @r) r r # sR
T
T
T
T
T
T
T
T
T
Tr+ r c ( g | ]} fi S r\ r\ )r ir r r r rr r s r) r z1MariadbGtidListEvent.__init__..4 sN
ZN
FL
r+ ) rj r r* r
r
r gtid_lengthr gtid_listr s `````@r) r* z MariadbGtidListEvent.__init__ s 2"D))2 Y
BH
T T T T T T T T T T ;2244
4+,,
r+ r r s @r) r r sB
r+ r c ( e Zd ZdZ fdZd Z xZS ) RotateEventa|
Change MySQL bin log file
Represents information for the slave to know the name of the binary log it is going to receive.
For more information: `[see details] `_.
:ivar position: int - Position inside next binlog
:ivar next_binlog: str - Name of next binlog file
c t j ||||fi | t j d| j d d | _ | j |dz
| _ d S Nr. rg r ) rj r* r0 r1 r
r/ positionrz next_binlogrq s r) r* zRotateEvent.__init__G s~ j)^VVvVVV
dDK,<, e Zd ZdZ fdZed Zd Z xZS )XAPrepareEventa
An XA prepare event is generated for a XA prepared transaction.
Like Xid_event, it contains XID of the **prepared** transaction.
For more information: `[see details] `_.
:ivar one_phase: current XA transaction commit method
:ivar xid_format_id: a number that identifies the format used by the gtrid and bqual values
:ivar xid: serialized XID representation of XA transaction (xid_gtrid + xid_bqual)
c @ t j ||||fi | | j d dk | _ t j d| j d d | _ t j d| j d d }t j d| j d d }| j | | _ | j | | _ d S )Nr5 +>??B }T4;+;+;A+>+>??B )),77 )),77r+ c h | j | j z S rF )r rz r rJ s r) xidzXAPrepareEvent.xidk s) ~$$&& )>)>)@)@@@r+ c t d| j t d| j t d| j d S )Nz One phase: zXID formatID: zXID: )rO r r r rJ s r) rS zXAPrepareEvent._dumpo sT
,DN,,---
3t 133444
dh !!!!!r+ ) rQ r] r^ r r* r_ r rS r r s @r) r r S so
8
8
8
8
8 A A XA" " " " " " "r+ r c ( e Zd ZdZ fdZd Z xZS )FormatDescriptionEventa}
Represents a Format Description Event in the MySQL binary log.
This event is written at the start of a binary log file for binlog version 4.
It provides the necessary information to decode subsequent events in the file.
:ivar binlog_version: int - Version of the binary log format.
:ivar mysql_version_str: str - Server's MySQL version in string format.
c 4 t j ||||fi | t j d| j d | _ | j d d | _ | j
d d }t t t |
d | _ t j d| j d d | _ t j d
| j d d | _ d }d }d } ||z
| j z
|z
| z
}
t j d
|
d| j |
| _ t j d| j d | _ t j d
| j d d | _ d S )Nz,>#?#? @ @ }T4;+;+;A+>+>??B !' tT[5E5Ea5H5H!I!I!!L $"8 8;M MPX X %}XXXXt{7G7G7J7J K K $*M%9I9I!9L9L$M$M!%+]49I9I!9L9L%M%Ma%P"""r+ c H t d| j t d| j t d| j t d| j t d| j t d| j t d| j d S )NzBinlog version: zmysql version: z Created: zCommon header length: zPost header length: zServer version split: zNumber of event types: )rO r r r r r r r rJ s r) rS z FormatDescriptionEvent._dump s
6!466777
8 688999
($,(()))
?t'=??@@@
;T%9;;<<<
Bt'@BBCCC
D(BDDEEEEEr+ r r s @r) r r u s] Q Q Q Q Q$F F F F F F Fr+ r c e Zd ZdS ) StopEventN)rQ r] r^ r\ r+ r) r r s Dr+ r c , e Zd ZdZ fdZ fdZ xZS )XidEventa
A COMMIT event generated when COMMIT of a transaction that modifies one or more tables of an XA-capable storage engine occurs.
For more information: `[see details] `_.
:ivar xid: uint - Transaction ID for 2 Phase Commit.
c t j ||||fi | t j d| j d d | _ d S r )rj r* r0 r1 r
r/ r rq s r) r* zXidEvent.__init__ sT j)^VVvVVV=t{'7'7':':;;A>r+ c v t t d| j d S )NzTransaction ID: )rj rS rO r r s r) rS zXidEvent._dump s3
+++,,,,,r+ r r s @r) r r s[ ? ? ? ? ?- - - - - - - - -r+ r c , e Zd ZdZ fdZ fdZ xZS )HeartbeatLogEventa A Heartbeat event
Heartbeats are sent by the master.
Master sends heartbeats when there are no unsent events in the binary log file after certain period of time.
The interval is defined by MASTER_HEARTBEAT_PERIOD connection setting.
`[see MASTER_HEARTBEAT_PERIOD] `_.
A Mysql server also does it for each skipped events in the log.
This is because to make the slave bump its position so that
if a disconnection occurs, the slave will only reconnects from the lasted skipped position. (Baloo's idea)
(see Binlog_sender::send_events in sql/rpl_binlog_sender.cc)
Warning:
That makes 106 bytes of data for skipped event in the binlog.
*this is also the case with GTID replication*.
To mitigate such behavior, you are expected to keep the binlog small
(see max_binlog_size, defaults to 1G).
In any case, the timestamp is 0 (as in 1970-01-01T00:00:00).
:ivar ident: Name of the current binlog
c t j ||||fi | | j | | _ d S rF )rj r* r
r/ rz identrq s r) r* zHeartbeatLogEvent.__init__ sO j)^VVvVVV[%%j1188::
r+ c v t t d| j d S )NzCurrent binlog: )rj rS rO r r s r) rS zHeartbeatLogEvent._dump s3
---.....r+ r r s @r) r r s[ .; ; ; ; ;/ / / / / / / / /r+ r c 2 e Zd ZdZ fdZ fdZd Z xZS )
QueryEventa
QueryEvent is generated for each query that modified database.
If row-based replication is used, DML will not be logged as RowsEvent instead.
:ivar slave_proxy_id: int - The id of the thread that issued this statement on the master server
:ivar execution_time: int - The time from when the query started to when it was logged in the binlog, in seconds.
:ivar schema_length: int - The length of the name of the currently selected database.
:ivar error_code: int - Error code generated by the master
:ivar status_vars_length: int - The length of the status variable
:ivar schema: str - The name of the currently selected database.
:ivar query: str - The query executed.
c z t j ||||fi | | j | _ | j | _ t
j d| j d d | _ | j
| _ | j
| _ | j j
| j z }| j j
|k r>| j }| | | j j
|k >| j | j | _ | j d | j |dz
| j z
| j z
dz
}| dd | _ d S )Nre r5 r
utf-8backslashreplace)errors)rj r* r
r slave_proxy_idexecution_timer0 r1 r/
schema_length read_uint16
error_codestatus_vars_lengthr@ r _read_status_vars_value_for_keyschemaadvancerz query)
r r r r r rr status_vars_end_posstatus_vars_keyr rP s
r) r* zQueryEvent.__init__ s j)^VVvVVV #k 5 5 7 7 "k 5 5 7 7 #]41A1A!1D1D E Ea H +1133"&+"9"9";"; #k 4t7N Nk$'::: "k 4 4 6 6O 0 0 A A A k$'::: k&&t'9:: A Od 5 58J JQ N
\\'2D\EE
r+ c t t d| j | j z t d| j t d| j d S )NSchema: Execution time: Query: )rj rS rO r
r r r s r) rS zQueryEvent._dump sm
&&&$+6777
6!466777
$
$$%%%%%r+ c P |t k r | j | _ dS |t k r | j | _ dS |t k rdS |t k r>| j | _
| j | _ dS |t k r\| j | _
| j | _ | j | _ dS |t k r>| j }|r!| j | | _ dS dS |t( k r>| j }|r!| j | | _ dS dS |t, k r | j | _ dS |t0 k r | j | _ dS |t4 k r | j | _ dS |t8 k rdS |t: k rx| j }|r | j | | _ | j }|r!| j | | _ dS dS |t@ k rm| j } |dk rdS g }tC | D ]0}| j " } |# | 1|| _$ dS |tJ k r | j & | _' dS |tP k rdS |tR k rdS |tT k r | j | _+ dS |tX k r | j | _- dS |t\ k r | j | _/ dS |t` k r | j | _1 dS |td k r | j | _3 dS |th k r | j & | _5 dS |tl k r | j | _7 dS tp )a parse status variable VALUE for given KEY
A status variable in query events is a sequence of status KEY-VALUE pairs.
Parsing logic from mysql-server source code edited by dongwook-chan
https://github.com/mysql/mysql-server/blob/beb865a960b9a8a16cf999c323e46c5b0c67f21f/libbinlogevents/src/statement_events.cpp#L181-L336
:ivar key: key for status variable
N)9
Q_FLAGS2_CODEr
r flags2Q_SQL_MODE_CODEr sql_modeQ_CATALOG_CODEQ_AUTO_INCREMENTr auto_increment_incrementauto_increment_offsetQ_CHARSET_CODEcharacter_set_clientcollation_connectioncollation_serverQ_TIME_ZONE_CODEr r/ time_zoneQ_CATALOG_NZ_CODEcatalog_nz_codeQ_LC_TIME_NAMES_CODElc_time_names_numberQ_CHARSET_DATABASE_CODEcharset_database_numberQ_TABLE_MAP_FOR_UPDATE_CODEtable_map_for_updateQ_MASTER_DATA_WRITTEN_CODE Q_INVOKERuserhostQ_UPDATED_DB_NAMESr read_stringr mts_accessed_db_namesQ_MICROSECONDS read_uint24 microseconds Q_COMMIT_TS Q_COMMIT_TS2!Q_EXPLICIT_DEFAULTS_FOR_TIMESTAMPexplicit_defaults_tsQ_DDL_LOGGED_WITH_XIDddl_xid Q_DEFAULT_COLLATION_FOR_UTF8MB4$default_collation_for_utf8mb4_numberQ_SQL_REQUIRE_PRIMARY_KEYsql_require_primary_keyQ_DEFAULT_TABLE_ENCRYPTIONdefault_table_encryptionQ_HRNOWhrnowQ_XIDr r )
r key
time_zone_len catalog_lenuser_lenhost_lenmts_accessed_dbsdbsr dbs
r) r z*QueryEvent._read_status_vars_value_for_key sp - +1133DKKK
O
#
# K 3 3 5 5DMMM
N
"
" D
$
$
$,0K,C,C,E,ED ))-)@)@)B)BD & & &
N
"
"(, (?(?(A(AD %(, (?(?(A(AD %$(K$;$;$=$=D ! ! !
$
$
$ K 2 2 4 4M
A!%!1!1-!@!@
A
A
%
%
% +0022K
E'+{'7'7 'D'D$$$
E
E
(
(
((, (?(?(A(AD % % %
+
+
++/;+B+B+D+DD ( ( (
/
/
/(, (?(?(A(AD % % %
.
.
. D
I
{--//H
7 K , ,X 6 6 {--//H
7 K , ,X 6 6
7
7
&
&
& #{ 5 5 7 7
3&&C+,,
[,,..
2),D & & &
N
"
" $ 7 7 9 9D
K
D
L
D
5
5
5(, (>(>(@(@D % % %
)
)
) ;2244DLLL
3
3
38< 8O8O8Q8QD 5 5 5
-
-
-+/;+A+A+C+CD ( ( (
.
.
.,0K,B,B,D,DD ) ) )
G^^ 0022DJJJ
E\\{..00DHHH( (r+ )rQ r] r^ r r* rS r r r s @r) r r sv F F F F F4& & & & & T) T) T) T) T) T) T)r+ r c , e Zd ZdZ fdZ fdZ xZS )BeginLoadQueryEventz
This event is written into the binary log file for LOAD DATA INFILE events
if the server variable binlog_mode was set to "STATEMENT".
:ivar file_id: the id of the file
:ivar block-data: data block about "LOAD DATA INFILE"
c t j ||||fi | | j | _ | j |dz
| _ d S )Nr7 )rj r* r
r file_idr/
block_datarq s r) r* z BeginLoadQueryEvent.__init__b s^ j)^VVvVVV {..00 +**:>::r+ c t t d| j t d| j d S )N File id: z Block data: )rj rS rO rO rP r s r) rS zBeginLoadQueryEvent._dumpi sL
($,(()))
.T_../////r+ r r s @r) rM rM Y s[ ; ; ; ; ;0 0 0 0 0 0 0 0 0r+ rM c , e Zd ZdZ fdZ fdZ xZS )ExecuteLoadQueryEventaz
This event handles "LOAD DATA INFILE" statement.
LOAD DATA INFILE statement reads data from file and insert into database's table.
Since QueryEvent cannot explain this special action, ExecuteLoadQueryEvent is needed.
So it is similar to a QUERY_EVENT except that it has extra static fields.
:ivar slave_proxy_id: int - The id of the thread that issued this statement on the master server
:ivar execution_time: int - The number of seconds that the statement took to execute
:ivar schema_length: int - The length of the default database's name when the statement was executed.
:ivar error_code: int - The error code resulting from execution of the statement on the master
:ivar status_vars_length: int - The length of the status variable block
:ivar file_id: int - The id of the loaded file
:ivar start_pos: int - Offset from the start of the statement to the beginning of the filename
:ivar end_pos: int - Offset from the start of the statement to the end of the filename
:ivar dup_handling_flags: int - How LOAD DATA INFILE handles duplicated data (0x0: error, 0x1: ignore, 0x2: replace)
c ^ t j ||||fi | | j | _ | j | _ | j | _ | j | _ | j | _
| j | _ | j | _ | j | _
| j | _ d S rF )rj r* r
r r r r r r r r rO start_posend_posdup_handling_flagsrq s r) r* z ExecuteLoadQueryEvent.__init__ s j)^VVvVVV #k 5 5 7 7 "k 5 5 7 7 ![ 3 3 5 5 +1133"&+"9"9";"; {..00 0022{..00 "&+"8"8":": r+ c t t | t d| j t d| j t d| j t d| j t d| j t d| j t d| j
t d| j t d | j d S )
NzSlave proxy id: r zSchema length: z Error code: zStatus vars length: rR z Start pos: z End pos: zDup handling flags: )
rj rT rS rO r r r r r rO rV rW rX r s r) rS zExecuteLoadQueryEvent._dump s
#T**00222
6!466777
6!466777
4 244555
.T_..///
>T%<>>???
($,(()))
,DN,,---
($,(()))
>T%<>>?????r+ r r s @r) rT rT o sd "; ; ; ; ;
@
@
@
@
@
@
@
@
@r+ rT c , e Zd ZdZ fdZ fdZ xZS ) IntvarEventa+
Stores the value of auto-increment variables.
This event will be created just before a QueryEvent.
:ivar type: int - 1 byte identifying the type of variable stored.
Can be either LAST_INSERT_ID_EVENT (1) or INSERT_ID_EVENT (2).
:ivar value: int - The value of the variable
c t j ||||fi | | j | _ | j | _ d S rF )rj r* r
r typer valuerq s r) r* zIntvarEvent.__init__ sX j)^VVvVVV K**,, [,,..
r+ c t t d| j t d| j d S )Nztype: Value: )rj rS rO r] r^ r s r) rS zIntvarEvent._dump sL
"ty""###
$
$$%%%%%r+ r r s @r) r[ r[ s[ / / / / /& & & & & & & & &r+ r[ c X e Zd ZdZ fdZed Zed Z fdZ xZ S ) RandEventa
RandEvent is generated every time a statement uses the RAND() function.
Indicates the seed values to use for generating a random number with RAND() in the next statement.
RandEvent only works in statement-based logging (need to set binlog_format as 'STATEMENT')
and only works when the seed number is not specified.
:ivar seed1: int - value for the first seed
:ivar seed2: int - value for the second seed
c t j ||||fi | | j | _ | j | _ d S rF )rj r* r
r _seed1_seed2rq s r) r* zRandEvent.__init__ sV j)^VVvVVVk--// k--// r+ c | j S )zGet the first seed value)rd rJ s r) seed1zRandEvent.seed1 {r+ c | j S )zGet the second seed value)re rJ s r) seed2zRandEvent.seed2 rh r+ c t t d| j t d| j d S )Nzseed1: zseed2: )rj rS rO rg rj r s r) rS zRandEvent._dump sL
$
$$%%%
$
$$%%%%%r+ )
rQ r] r^ r r* r_ rg rj rS r r s @r) rb rb s 0 0 0 0 0 X X& & & & & & & & &r+ rb c e Zd ZdZ fdZd ZdedefdZdede fdZ
dede de fd Z dede
j fd
Zdefd Zd fd
Z xZS ) UserVarEventaI
UserVarEvent is generated every time a statement uses a user variable.
Indicates the value to use for the user variable in the next statement.
:ivar name_len: int - Length of user variable
:ivar name: str - User variable name
:ivar value: str - Value of the user variable
:ivar type: int - Type of the user variable
:ivar charset: int - The number of the character set for the user variable
:ivar is_null: int - Non-zero if the variable value is the SQL NULL value, 0 otherwise
:ivar flags: int - Extra flags associated with the user variable
c r t t | j ||||fi | | j | _ | j | j | _ | j | _
d| j gd| j gd| j
gd| j gd| j gd| _ d | _ d | _ d| _ | j
s| j | _ | j | _ | j | _ | j | j | _ | j | _ | d S d\ | _ | _ | _ | _ | _ d S ) N
STRING_RESULT REAL_RESULT
INT_RESULT
ROW_RESULTDECIMAL_RESULT)r r5 r r r7 r+ )NNNNN)rj rm r* r
r name_lenr/ rz namer is_null _read_string
_read_real _read_int
_read_default
_read_decimaltype_to_codes_and_methodr^ r temp_value_bufferr] charset value_len_set_value_from_temp_bufferrq s r) r* zUserVarEvent.__init__ s *lD!!* Y
BH
"[ 4 4 6 6
))$-88??AA K 2 2 4 4 "D$56 $/2 0 !34#T%78 /
/
% IM
$(
;> | ![ 3 3 5 5DI $ 7 7 9 9DL"&+"9"9";";DN?C{?O?O@ @D " #k 4 4 6 6DJ , , . . . . .O KDIt|T^TZr+ c | j rd| j | j d| j g \ }}|dk r || j | j | _ dS || j | _ dS dS )zQ
Set the value from the temporary buffer based on the type code.
UNKNOWN_RESULTrq N)r} r| getr] rz r r^ )r type_code read_methods r) r z(UserVarEvent._set_value_from_temp_buffer s ! A%)%B%F%F ,d.@A& & "I{ L(( ([)? L L
([)? @ @
A Ar+ bufferrD c * | S )z#
Read string data.
)rz r r s r) rw zUserVarEvent._read_string s }} r+ c 8 t j d| d S )z!
Read real data.
zr sv
9 9 9 9 @ @ @ @ @ @ B B B B B B , , , , , , " " " " " " " " U
U
U
U
U
& U
U
U
p4, 4, 4, 4, 4, 4, 4, 4,n*@ *@ *@ *@ *@ *@ *@ *@Z$ $ $ $ ${ $ $ $8, , , , ,; , , ,,7 7 7 7 7{ 7 7 7$*
*
*
*
*
; *
*
*
Z + . " " " " "[ " " "D$F $F $F $F $F[ $F $F $FN - - - - -{ - - -$ / / / / / / / /BC) C) C) C) C) C) C) C)L0 0 0 0 0+ 0 0 0,,@ ,@ ,@ ,@ ,@K ,@ ,@ ,@^& & & & &+ & & &. & & & & & & & &Do* o* o* o* o*; o* o* o*d& & & & &+ & & &:& & & & & & & &, ( ( ( ( (+ ( ( ( ( (r+