如何编写可以将数据重新分发到新表中的 Doctrine 迁移

php doctrine-orm symfony doctrine-migrations

2022-08-30 21:10:51

我有一个数据库（实际上是在Symfony1应用程序中使用Propel创建的）。我正在Symfony2和Tructic中重新实现它，但我也想借此机会在某种程度上重构数据库。

我已经定义了一组 Doctrine 实体并运行 doctrine：migrations：diff，这为我创建了一个基本的迁移来添加表、列和约束，并删除大量列。

但是，在删除这些列之前，我想将数据复制到一些新表中，然后将这些表中的新记录链接到第一个表中的新列。我不认为在纯SQL中可以做到这一点（通常，一个表的内容分布在三个或四个表中）。

这给了我一个提示，并导致我找到了这个（我跳过了，因为我不知道“容器”可能与我的问题有什么相关性）。

但是，我在Symfony或Trinity文档中没有找到的是在迁移中实际移动数据的示例 - 对我来说，这似乎是迁移的核心目的之一！

我可能会使用上面这些链接中的提示，但是我不确定如何继续。我没有（也不想花时间创建，尽管我确信我可以做到）现有数据库模式的教义实体：然后我可以使用DQL吗？我根本不知道。

所以有两个问题：

有人可以给我一个在表之间移动数据的教义迁移的例子吗？
或者，任何人都可以澄清DQL的语法对教义中实体定义的依赖性吗？我可以使用它来指定不在实体定义中的列吗？

答案 1

好吧，我似乎已经找到了它，从许多来源（包括这个）和反复试验。

Cerad的评论有点帮助，但主要是我通过使用DBAL层来读取数据（我可以通过它获得），并使用ORM来保存新数据（这需要EntityManager，所以我不得不在容器中使用这个技巧）。$this->connection

我把所有的代码都放进了，包括从表中删除列的生成的代码。postUp()

我的代码示例位：

use Symfony\Component\DependencyInjection\ContainerAwareInterface;
use Symfony\Component\DependencyInjection\ContainerInterface;

use PG\InventoryBundle\Entity\Item;
use PG\InventoryBundle\Entity\Address;
         .
         .
         .

/**
 * Auto-generated Migration: Please modify to your needs!
 */
class Version20140519211228 extends AbstractMigration implements ContainerAwareInterface
{
  private $container;

  public function setContainer(ContainerInterface $container = null)
  {
    $this->container = $container;
  }

  public function up(Schema $schema)
  {
         .
         .
         .
  }
}

public function postUp(Schema $schema)
{
    $em = $this->container->get('doctrine.orm.entity_manager');
    // ... update the entities
    $query = "SELECT * FROM item";
    $stmt = $this->connection->prepare($query);
    $stmt->execute();

    // We can't use Doctrine's ORM to fetch the item, because it has a load of extra fields
    // that aren't in the entity definition.
    while ($row = $stmt->fetch()) {
      // But we will also get the entity, so that we can put addresses in it.
      $id = $row['id'];
      // And create new objects
      $stock = new Stock();
         .
         .
         .

      $stock->setAssetNo($row['asset_no']);
      $stock->setItemId($row['id']);
      $em->persist($stock);

      $em->flush();
    }

    // Now we can drop fields we don't need. 
    $this->connection->executeQuery("ALTER TABLE item DROP container_id");
    $this->connection->executeQuery("ALTER TABLE item DROP location_id");
         .
         .
         .

 }

答案 2