OroCRM\Bundle\SalesBundle\Migrations\Schema\v1_25_5\OroCRMSalesBundle

Complexity

Total Complexity

7

Size/Duplication

Total Lines	52
Duplicated Lines	100 %

Coupling/Cohesion

Components	0
Dependencies	3

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	up()	10	10	1
B	changeOnDeleteToCascade()	25	25	6

<?php

namespace OroCRM\Bundle\SalesBundle\Migrations\Schema\v1_25_5;

use Doctrine\DBAL\Schema\Schema;
use Oro\Bundle\MigrationBundle\Migration\Migration;
use Oro\Bundle\MigrationBundle\Migration\QueryBag;

class OroCRMSalesBundle implements Migration

This class seems to be duplicated in your project.

{
    /**
     * Changes account_id to onDelete=CASCADE
     *
     * {@inheritdoc}
     */
    public function up(Schema $schema, QueryBag $queries)
    {
        $this->changeOnDeleteToCascade(
            $schema,
            [
                'orocrm_sales_b2bcustomer' => ['account_id'],
                'orocrm_sales_opportunity' => ['customer_id'],
            ]
        );
    }

    /**
     * @param Schema $schema
     * @param array $data
     * [
     *     table name => [column name, ...],
     *     ...
     * ]
     */
    protected function changeOnDeleteToCascade(Schema $schema, array $data)
    {
        foreach ($data as $tableName => $columns) {
            $table = $schema->getTable($tableName);
            foreach ($columns as $column) {
                $foreignKeys = $table->getForeignKeys();
                foreach ($foreignKeys as $foreignKey) {
                    $foreignKeyColumns = $foreignKey->getUnquotedLocalColumns();
                    if ($foreignKeyColumns === [$column]) {
                        if ($foreignKey->getOption('onDelete') !== 'CASCADE') {
                            $table->removeForeignKey($foreignKey->getName());
                            $table->addForeignKeyConstraint(
                                $foreignKey->getUnqualifiedForeignTableName(),
                                $foreignKeyColumns,
                                $foreignKey->getUnquotedForeignColumns(),
                                ['onDelete' => 'CASCADE', 'onUpdate' => $foreignKey->getOption('onUpdate')]
                            );
                        }

                        break;
                    }
                }
            }
        }
    }
}