Wabel / zoho-crm-copy-db

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

    }

    public function createInsertTrigger(Table $table)

    {

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

        $this->logger->info('Creating ' . $triggerName . ' trigger for table ' . $table->getName() . '...');

        $tableNameQuoted = $this->connection->quote($table->getName());

        $sql = sprintf(

            '

            DROP TRIGGER IF EXISTS %s;

            CREATE TRIGGER %s AFTER INSERT ON `%s` 

            FOR EACH ROW

            BEGIN

              IF (NEW.id IS NULL AND NEW.createdTime 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(), $tableNameQuoted, $tableNameQuoted, $tableNameQuoted

        );

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

    }

    public function createDeleteTrigger(Table $table)

    {

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

    }

    public function createDeleteTrigger(Table $table)

    {

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

        $this->logger->info('Creating ' . $triggerName . ' trigger for table ' . $table->getName() . '...');

        $tableNameQuoted = $this->connection->quote($table->getName());

        $sql = sprintf(

            '

            DROP TRIGGER IF EXISTS %s;

            CREATE TRIGGER %s BEFORE DELETE ON `%s` 

            FOR EACH ROW

            BEGIN

              IF (OLD.id IS NOT NULL) THEN

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

              END IF;

              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(), $tableNameQuoted, $tableNameQuoted, $tableNameQuoted

        );

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

    }

    public function createUpdateTrigger(Table $table)

    {