* Python 2.6, 2.7

import os, sys, datetime

from binlog2sql_util import command_line_args, concat_sql_from_binlogevent, create_unique_file, reversed_lines

def __init__(self, connectionSettings, startFile=None, startPos=None, endFile=None, endPos=None, startTime=None,

stopTime=None, only_schemas=None, only_tables=None, nopk=False, flashback=False, stopnever=False):

'''

if not startFile:

raise ValueError('lack of parameter,startFile.')

self.connectionSettings = connectionSettings

self.startFile = startFile

self.startPos = startPos if startPos else 4 # use binlog v4

self.endFile = endFile if endFile else startFile

self.endPos = endPos

self.startTime = datetime.datetime.strptime(startTime, "%Y-%m-%d %H:%M:%S") if startTime else datetime.datetime.strptime('1970-01-01 00:00:00', "%Y-%m-%d %H:%M:%S")

self.stopTime = datetime.datetime.strptime(stopTime, "%Y-%m-%d %H:%M:%S") if stopTime else datetime.datetime.strptime('2999-12-31 00:00:00', "%Y-%m-%d %H:%M:%S")

self.nopk, self.flashback, self.stopnever = (nopk, flashback, stopnever)

self.connection = pymysql.connect(**self.connectionSettings)

try:

cur = self.connection.cursor()

cur.execute("SHOW MASTER STATUS")

self.eofFile, self.eofPos = cur.fetchone()[:2]

cur.execute("SHOW MASTER LOGS")

binIndex = [row[0] for row in cur.fetchall()]

if self.startFile not in binIndex:

raise ValueError('parameter error: startFile %s not in mysql server' % self.startFile)

for bin in binIndex:

if binlog2i(bin) >= binlog2i(self.startFile) and binlog2i(bin) <= binlog2i(self.endFile):

self.binlogList.append(bin)

cur.execute("SELECT @@server_id")

self.serverId = cur.fetchone()[0]

if not self.serverId:

raise ValueError('need set server_id in mysql server %s:%s' % (self.connectionSettings['host'], self.connectionSettings['port']))

finally:

cur.close()

stream = BinLogStreamReader(connection_settings=self.connectionSettings, server_id=self.serverId,

log_file=self.startFile, log_pos=self.startPos, only_schemas=self.only_schemas,

cur = self.connection.cursor()

tmpFile = create_unique_file('%s.%s' % (self.connectionSettings['host'],self.connectionSettings['port'])) # to simplify code, we do not use file lock for tmpFile.

ftmp = open(tmpFile ,"w")

flagLastEvent = False

eStartPos, lastPos = stream.log_pos, stream.log_pos

try:

for binlogevent in stream:

if not self.stopnever:

if (stream.log_file == self.endFile and stream.log_pos == self.endPos) or (stream.log_file == self.eofFile and stream.log_pos == self.eofPos):

flagLastEvent = True

elif datetime.datetime.fromtimestamp(binlogevent.timestamp) < self.startTime:

if not (isinstance(binlogevent, RotateEvent) or isinstance(binlogevent, FormatDescriptionEvent)):

lastPos = binlogevent.packet.log_pos

elif (stream.log_file not in self.binlogList) or (self.endPos and stream.log_file == self.endFile and stream.log_pos > self.endPos) or (stream.log_file == self.eofFile and stream.log_pos > self.eofPos) or (datetime.datetime.fromtimestamp(binlogevent.timestamp) >= self.stopTime):

if isinstance(binlogevent, QueryEvent) and binlogevent.query == 'BEGIN':

eStartPos = lastPos

if isinstance(binlogevent, QueryEvent):

sql = concat_sql_from_binlogevent(cursor=cur, binlogevent=binlogevent, flashback=self.flashback, nopk=self.nopk)

print sql

elif isinstance(binlogevent, WriteRowsEvent) or isinstance(binlogevent, UpdateRowsEvent) or isinstance(binlogevent, DeleteRowsEvent):

for row in binlogevent.rows:

sql = concat_sql_from_binlogevent(cursor=cur, binlogevent=binlogevent, row=row , flashback=self.flashback, nopk=self.nopk, eStartPos=eStartPos)

ftmp.write(sql + '\n')

print sql

if not (isinstance(binlogevent, RotateEvent) or isinstance(binlogevent, FormatDescriptionEvent)):

lastPos = binlogevent.packet.log_pos

if flagLastEvent:

ftmp.close()

self.print_rollback_sql(tmpFile)

finally:

os.remove(tmpFile)

cur.close()

stream.close()

def print_rollback_sql(self, fin):

'''print rollback sql from tmpfile'''

with open(fin) as ftmp:

sleepInterval = 1000

i = 0

for line in reversed_lines(ftmp):

print line.rstrip()

if i >= sleepInterval:

print 'SELECT SLEEP(1);'

i = 0

else:

i += 1

connectionSettings = {'host':args.host, 'port':args.port, 'user':args.user, 'passwd':args.password}

binlog2sql = Binlog2sql(connectionSettings=connectionSettings, startFile=args.startFile,

startPos=args.startPos, endFile=args.endFile, endPos=args.endPos,

startTime=args.startTime, stopTime=args.stopTime, only_schemas=args.databases,

only_tables=args.tables, nopk=args.nopk, flashback=args.flashback, stopnever=args.stopnever)