doctrine / dbal

    /**

     * @return string

     */

    private function getCreateFederationStatement()

    {

        $federationType = Type::getType($this->shardManager->getDistributionType());

        $federationTypeSql = $federationType->getSQLDeclaration([], $this->conn->getDatabasePlatform());

        return "--Create Federation\n" .

               "CREATE FEDERATION " . $this->shardManager->getFederationName() . " (" . $this->shardManager->getDistributionKey() . " " . $federationTypeSql ."  RANGE)";

    }

}

     *

     * @return void

     */

    public function splitFederation($splitDistributionValue)

    {

        $type = Type::getType($this->distributionType);

        $sql = "ALTER FEDERATION " . $this->getFederationName() . " " .

               "SPLIT AT (" . $this->getDistributionKey() . " = " .

               $this->conn->quote($splitDistributionValue, $type->getBindingType()) . ")";

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

    }

}