Sync/DiffProvider/Binlog/BinlogDecorator.php
public function current()
    {
        $buffer = $this->binlogParser->current();
        $type = $buffer[BinlogParser::PARAM_QUERY]['type'];

        $diffItem = DiffItemFactory::create($type);
        $diffItem->setTimestamp($buffer[BinlogParser::PARAM_DATE]);
        $diffItem->setDiffId($buffer[BinlogParser::PARAM_POSITION]);
        $diffItem->setCategory($buffer[BinlogParser::PARAM_QUERY]['table']);
        $mapping = $this->getTableMapping($diffItem->getCategory());

        if (isset($buffer[BinlogParser::PARAM_QUERY]['where'])) {
            $diffItem->setWhereParams(
                $this->applyMapping(
                    $buffer[BinlogParser::PARAM_QUERY]['where'],
                    $mapping
                )
            );
        }

        if (isset($buffer[BinlogParser::PARAM_QUERY]['set'])) {
            $diffItem->setSetParams(
                $this->applyMapping(
                    $buffer[BinlogParser::PARAM_QUERY]['set'],
                    $mapping
                )
            );
        }

        return $diffItem;
    }
public function current()
    {
        $buffer = $this->binlogParser->current();
        $type = $buffer[BinlogParser::PARAM_QUERY]['type'];

        $diffItem = DiffItemFactory::create($type);
        $diffItem->setTimestamp($buffer[BinlogParser::PARAM_DATE]);
        $diffItem->setDiffId($buffer[BinlogParser::PARAM_POSITION]);
        $diffItem->setCategory($buffer[BinlogParser::PARAM_QUERY]['table']);
        $mapping = $this->getTableMapping($diffItem->getCategory());

        if (isset($buffer[BinlogParser::PARAM_QUERY]['where'])) {
            $diffItem->setWhereParams(
                $this->applyMapping(
                    $buffer[BinlogParser::PARAM_QUERY]['where'],
                    $mapping
                )
            );
        }

        if (isset($buffer[BinlogParser::PARAM_QUERY]['set'])) {
            $diffItem->setSetParams(
                $this->applyMapping(
                    $buffer[BinlogParser::PARAM_QUERY]['set'],
                    $mapping
                )
            );
        }

        return $diffItem;
    }
{@inheritdoc}