(self, ev, dst_curs)
handle one data event
handle one data event
handle one data event
def handle_data_event(self, ev, dst_curs):
        """handle one data event"""
        t = self.get_table_by_name(ev.extra1)
        if not t or not t.interesting(ev, self.cur_tick, self.copy_thread, self.copy_table_name):
            self.stat_increase('ignored_events')
            return

        try:
            p = self.used_plugins[ev.extra1]
        except KeyError:
            p = t.get_plugin()
            self.used_plugins[ev.extra1] = p
            p.prepare_batch(self.batch_info, dst_curs)

        p.process_event(ev, self.apply_sql, dst_curs)
def handle_data_event ( self , ev , dst_curs ) : t = self . get_table_by_name ( ev . extra1 ) if not t or not t . interesting ( ev , self . cur_tick , self . copy_thread , self . copy_table_name ) : self . stat_increase ( 'ignored_events' ) return try : p = self . used_plugins [ ev . extra1 ] except KeyError : p = t . get_plugin ( ) self . used_plugins [ ev . extra1 ] = p p . prepare_batch ( self . batch_info , dst_curs ) p . process_event ( ev , self . apply_sql , dst_curs )