Merge branch 'feature/4311' into develop

Close zendframework#4311

library/Zend/Db/Sql/Ddl/AlterTable.php

@@ -0,0 +1,268 @@
+<?php
+/**
+ * Zend Framework (http://framework.zend.com/)
+ *
+ * @link      http://github.com/zendframework/zf2 for the canonical source repository
+ * @copyright Copyright (c) 2005-2013 Zend Technologies USA Inc. (http://www.zend.com)
+ * @license   http://framework.zend.com/license/new-bsd New BSD License
+ */
+
+namespace Zend\Db\Sql\Ddl;
+
+use Zend\Db\Adapter\Platform\PlatformInterface;
+use Zend\Db\Adapter\Platform\Sql92 as AdapterSql92Platform;
+use Zend\Db\Sql\AbstractSql;
+
+class AlterTable extends AbstractSql implements SqlInterface
+{
+    const ADD_COLUMNS      = 'addColumns';
+    const ADD_CONSTRAINTS  = 'addConstraints';
+    const CHANGE_COLUMNS   = 'changeColumns';
+    const DROP_COLUMNS     = 'dropColumns';
+    const DROP_CONSTRAINTS = 'dropConstraints';
+    const TABLE            = 'table';
+
+    /**
+     * @var array
+     */
+    protected $addColumns = array();
+
+    /**
+     * @var array
+     */
+    protected $addConstraints = array();
+
+    /**
+     * @var array
+     */
+    protected $changeColumns = array();
+
+    /**
+     * @var array
+     */
+    protected $dropColumns = array();
+
+    /**
+     * @var array
+     */
+    protected $dropConstraints = array();
+
+    /**
+     * Specifications for Sql String generation
+     * @var array
+     */
+    protected $specifications = array(
+        self::TABLE => "ALTER TABLE %1\$s\n",
+        self::ADD_COLUMNS  => array(
+            "%1\$s" => array(
+                array(1 => 'ADD COLUMN %1$s', 'combinedby' => ",\n")
+            )
+        ),
+        self::CHANGE_COLUMNS  => array(
+            "%1\$s" => array(
+                array(2 => 'CHANGE COLUMN %1$s %2$s', 'combinedby' => ",\n"),
+            )
+        ),
+        self::DROP_COLUMNS  => array(
+            "%1\$s" => array(
+                array(1 => 'DROP COLUMN %1$s', 'combinedby' => ",\n"),
+            )
+        ),
+        self::ADD_CONSTRAINTS  => array(
+            "%1\$s" => array(
+                array(1 => 'ADD %1$s', 'combinedby' => ",\n"),
+            )
+        ),
+        self::DROP_CONSTRAINTS  => array(
+            "%1\$s" => array(
+                array(1 => 'DROP CONSTRAINT %1$s', 'combinedby' => ",\n"),
+            )
+        )
+    );
+
+    /**
+     * @var string
+     */
+    protected $table = '';
+
+    /**
+     * @param string $table
+     */
+    public function __construct($table = '')
+    {
+        ($table) ? $this->setTable($table) : null;
+    }
+
+    /**
+     * @param  string $name
+     * @return self
+     */
+    public function setTable($name)
+    {
+        $this->table = $name;
+
+        return $this;
+    }
+
+    /**
+     * @param  Column\ColumnInterface $column
+     * @return self
+     */
+    public function addColumn(Column\ColumnInterface $column)
+    {
+        $this->addColumns[] = $column;
+
+        return $this;
+    }
+
+    /**
+     * @param  string $name
+     * @param  Column\ColumnInterface $column
+     * @return self
+     */
+    public function changeColumn($name, Column\ColumnInterface $column)
+    {
+        $this->changeColumns[$name] = $column;
+
+        return $this;
+    }
+
+    /**
+     * @param  string $name
+     * @return self
+     */
+    public function dropColumn($name)
+    {
+        $this->dropColumns[] = $name;
+
+        return $this;
+    }
+
+    /**
+     * @param  string $name
+     * @return self
+     */
+    public function dropConstraint($name)
+    {
+        $this->dropConstraints[] = $name;
+
+        return $this;
+    }
+
+    /**
+     * @param  Constraint\ConstraintInterface $constraint
+     * @return self
+     */
+    public function addConstraint(Constraint\ConstraintInterface $constraint)
+    {
+        $this->addConstraints[] = $constraint;
+
+        return $this;
+    }
+
+    /**
+     * @param  string|null $key
+     * @return array
+     */
+    public function getRawState($key = null)
+    {
+        $rawState = array(
+            self::TABLE => $this->table,
+            self::ADD_COLUMNS => $this->addColumns,
+            self::DROP_COLUMNS => $this->dropColumns,
+            self::CHANGE_COLUMNS => $this->changeColumns,
+            self::ADD_CONSTRAINTS => $this->addConstraints,
+            self::DROP_CONSTRAINTS => $this->dropConstraints,
+        );
+
+        return (isset($key) && array_key_exists($key, $rawState)) ? $rawState[$key] : $rawState;
+    }
+
+    /**
+     * @param  PlatformInterface $adapterPlatform
+     * @return string
+     */
+    public function getSqlString(PlatformInterface $adapterPlatform = null)
+    {
+        // get platform, or create default
+        $adapterPlatform = ($adapterPlatform) ?: new AdapterSql92Platform;
+
+        $sqls = array();
+        $parameters = array();
+
+        foreach ($this->specifications as $name => $specification) {
+            $parameters[$name] = $this->{'process' . $name}($adapterPlatform, null, null, $sqls, $parameters);
+            if ($specification && is_array($parameters[$name]) && ($parameters[$name] != array(array()))) {
+                $sqls[$name] = $this->createSqlFromSpecificationAndParameters($specification, $parameters[$name]);
+            }
+            if (stripos($name, 'table') === false && $parameters[$name] !== array(array())) {
+                $sqls[] = ",\n";
+            }
+        }
+
+        // remove last ,\n
+        array_pop($sqls);
+
+        $sql = implode('', $sqls);
+
+        return $sql;
+    }
+
+    protected function processTable(PlatformInterface $adapterPlatform = null)
+    {
+        return array($adapterPlatform->quoteIdentifier($this->table));
+    }
+
+    protected function processAddColumns(PlatformInterface $adapterPlatform = null)
+    {
+        $sqls = array();
+        foreach ($this->addColumns as $column) {
+            $sqls[] = $this->processExpression($column, $adapterPlatform)->getSql();
+        }
+
+        return array($sqls);
+    }
+
+    protected function processChangeColumns(PlatformInterface $adapterPlatform = null)
+    {
+        $sqls = array();
+        foreach ($this->changeColumns as $name => $column) {
+            $sqls[] = array(
+                $adapterPlatform->quoteIdentifier($name),
+                $this->processExpression($column, $adapterPlatform)->getSql()
+            );
+        }
+
+        return array($sqls);
+    }
+
+    protected function processDropColumns(PlatformInterface $adapterPlatform = null)
+    {
+        $sqls = array();
+        foreach ($this->dropColumns as $column) {
+             $sqls[] = $adapterPlatform->quoteIdentifier($column);
+        }
+
+        return array($sqls);
+    }
+
+    protected function processAddConstraints(PlatformInterface $adapterPlatform = null)
+    {
+        $sqls = array();
+        foreach ($this->addConstraints as $constraint) {
+            $sqls[] = $this->processExpression($constraint, $adapterPlatform);
+        }
+
+        return array($sqls);
+    }
+
+    protected function processDropConstraints(PlatformInterface $adapterPlatform = null)
+    {
+        $sqls = array();
+        foreach ($this->dropConstraints as $constraint) {
+            $sqls[] = $adapterPlatform->quoteIdentifier($constraint);
+        }
+
+        return array($sqls);
+    }
+}

library/Zend/Db/Sql/Ddl/Column/Blob.php

@@ -0,0 +1,91 @@
+<?php
+/**
+ * Zend Framework (http://framework.zend.com/)
+ *
+ * @link      http://github.com/zendframework/zf2 for the canonical source repository
+ * @copyright Copyright (c) 2005-2013 Zend Technologies USA Inc. (http://www.zend.com)
+ * @license   http://framework.zend.com/license/new-bsd New BSD License
+ */
+
+namespace Zend\Db\Sql\Ddl\Column;
+
+class Blob extends Column
+{
+    /**
+     * @var int
+     */
+    protected $length;
+
+    /**
+     * @var string Change type to blob
+     */
+    protected $type = 'BLOB';
+
+    /**
+     * @param null  $name
+     * @param int   $length
+     * @param bool  $nullable
+     * @param null  $default
+     * @param array $options
+     */
+    public function __construct($name, $length, $nullable = false, $default = null, array $options = array())
+    {
+        $this->setName($name);
+        $this->setLength($length);
+        $this->setNullable($nullable);
+        $this->setDefault($default);
+        $this->setOptions($options);
+    }
+
+    /**
+     * @param  int $length
+     * @return self
+     */
+    public function setLength($length)
+    {
+        $this->length = $length;
+        return $this;
+    }
+
+    /**
+     * @return int
+     */
+    public function getLength()
+    {
+        return $this->length;
+    }
+
+    /**
+     * @return array
+     */
+    public function getExpressionData()
+    {
+        $spec = $this->specification;
+
+        $params   = array();
+        $params[] = $this->name;
+        $params[] = $this->type;
+
+        if ($this->length) {
+            $params[1] .= ' ' . $this->length;
+        }
+
+        $types = array(self::TYPE_IDENTIFIER, self::TYPE_LITERAL);
+
+        if (!$this->isNullable) {
+            $params[1] .= ' NOT NULL';
+        }
+
+        if ($this->default !== null) {
+            $spec    .= ' DEFAULT %s';
+            $params[] = $this->default;
+            $types[]  = self::TYPE_VALUE;
+        }
+
+        return array(array(
+            $spec,
+            $params,
+            $types,
+        ));
+    }
+}