php – Doctrine2迁移使用DBAL而不是$this-> addSql

我一直在挖掘图书馆,我看到$this-> addsql()用于构建要执行的sql列表,然后稍后执行.

我想做一些我选择一些数据的东西,迭代行,插入新的数据,然后删除我选择的数据.这很容易使DBAL库变得简单,但我想知道,我可以安全地在迁移中使用受保护的$连接吗？或者是坏的,因为它会在我的$this-> addsql()sql执行之前执行语句？而且,似乎这样会从我在代码中看到的干法运行设置中断.有没有人有过这种类型的迁移的经验？有没有最佳做法？

以下是我想做的迁移,但我不确定这是否受到Doctrine Migrations的支持：

public function up(Schema $schema)
{
    // this up() migration is autogenerated,please modify it to your needs
    $this->abortIf($this->connection->getDatabasePlatform()->getName() != "MysqL");

    $this->addsql("ALTER TABLE article_enclosures ADD is_scrape tinyint(1) NOT NULL");
    $this->addsql("ALTER TABLE images DROP FOREIGN KEY FK_E01FBE6AA536AAC7");

    // Now lets take all images with a scrape and convert the scrape to an enclosure
    // 
    // Select all images where not scrape_id is null (join on article_image_scrape)
    // for each image:
    //     insert into article_enclosures
    //     update image set enclosure_id = new ID
    //     delete from article_image_scrape where id...
    //
    // insert into article_enclosures select article_image_scrapes...

    $sql = "SELECT i.id img_id,e.* FROM images i JOIN article_image_scrapes e ON i.scrape_id = e.id";
    $stmt = $this->connection->prepare($sql);
    $stmt->execute();
    $scrapestoDelete = array();
    while ($row = $stmt->fetch()) {
        $scrapeArticle = $row['article_id'];
        $scrapeOldId = $row['id'];
        $scrapeUrl = $row['url'];
        $scrapeExtension = $row['extension'];
        $scrapeUrlHash = $row['url_hash'];
        $imageId = $row['image_id'];

        $this->connection->insert('article_enclosures',array(
            'url' => $scrapeUrl,'extension' => $scrapeExtension,'url_hash' => $scrapeUrlHash
        ));

        $scrapeNewId = $this->connection->lastInsertId();

        $this->connection->update('images',array(
            'enclosure_id' => $scrapeNewId,'scrape_id' => null
        ),array(
            'id' => $imageId
        ));

        $scrapestoDelete[] = $scrapeOldId;
    }

    foreach ($scrapestoDelete as $id) {
        $this->connection->delete('article_image_scrapes',array('id' => $id));
    }

    $this->addsql("INSERT INTO article_scrapes (article_id,url,extension,url_hash) "
            ."SELECT s.id,s.url,s.extension,s.url_hash"
            ."FROM article_image_scrapes s");

    $this->addsql("DROP INDEX IDX_E01FBE6AA536AAC7 ON images");
    $this->addsql("ALTER TABLE images DROP scrape_id,CHANGE enclosure_id enclosure_id INT NOT NULL");
}