Wabel / zoho-crm-copy-db

        $this->connection->exec($sql);

    }

    public function createDeleteTrigger(Table $table)

    {

        $triggerName = sprintf('TRG_%s_ONDELETE', $table->getName());

        $sql = sprintf('

            DROP TRIGGER IF EXISTS %s;

            CREATE TRIGGER %s BEFORE DELETE ON `%s` 

            FOR EACH ROW

            BEGIN

              INSERT INTO local_delete VALUES (%s, OLD.uid, OLD.id);

              DELETE FROM local_insert WHERE table_name = %s AND uid = OLD.uid;

              DELETE FROM local_update WHERE table_name = %s AND uid = OLD.uid;

            END;

            ', $triggerName, $triggerName, $table->getName(), $this->connection->quote($table->getName()), $this->connection->quote($table->getName()), $this->connection->quote($table->getName()));

        $this->connection->exec($sql);

    }

    public function createUpdateTrigger(Table $table)

    {

        $triggerName = sprintf('TRG_%s_ONUPDATE', $table->getName());

        $dbalTableDiffService->createOrUpdateTable($localDelete);

    }

    public function createInsertTrigger(Table $table)

    {

        $triggerName = sprintf('TRG_%s_ONINSERT', $table->getName());

        $sql = sprintf('

            DROP TRIGGER IF EXISTS %s;

            CREATE TRIGGER %s AFTER INSERT ON `%s` 

            FOR EACH ROW

            BEGIN

              IF (NEW.lastActivityTime IS NULL) THEN

                INSERT INTO local_insert VALUES (%s, NEW.uid);

                DELETE FROM local_delete WHERE table_name = %s AND uid = NEW.uid;

                DELETE FROM local_update WHERE table_name = %s AND uid = NEW.uid;

              END IF;

            END;

            ', $triggerName, $triggerName, $table->getName(), $this->connection->quote($table->getName()), $this->connection->quote($table->getName()), $this->connection->quote($table->getName()));

        $this->connection->exec($sql);

    }

    public function createDeleteTrigger(Table $table)

    {

        $triggerName = sprintf('TRG_%s_ONDELETE', $table->getName());