doctrine / dbal

        }

        $shards = $this->shardManager->getShards();

        foreach ($shards as $shard) {

            $this->shardManager->selectShard($shard['rangeLow']);

            $federationSql = $this->synchronizer->getDropAllSchema();

            if ($federationSql) {

                $sql[] = "-- Work on Federation ID " . $shard['id'] . "\n" .

                         "USE FEDERATION " . $this->shardManager->getFederationName() . " (" . $this->shardManager->getDistributionKey() . " = " . $shard['rangeLow'].") WITH RESET, FILTERING = OFF;";

                $sql = array_merge($sql, $federationSql);

            }

        }

        $sql[] = "USE FEDERATION ROOT WITH RESET;";

        $sql[] = "DROP FEDERATION " . $this->shardManager->getFederationName();

        $shards = $this->shardManager->getShards();

        foreach ($shards as $shard) {

            $this->shardManager->selectShard($shard['rangeLow']);

            $federationSql = $operation($this->synchronizer, $federation);

            if ($federationSql) {

                $sql[] = "-- Work on Federation ID " . $shard['id'] . "\n" .

                         "USE FEDERATION " . $this->shardManager->getFederationName() . " (" . $this->shardManager->getDistributionKey() . " = " . $shard['rangeLow'].") WITH RESET, FILTERING = OFF;";

                $sql   = array_merge($sql, $federationSql);

            }

        }

        return $sql;

    }