-

Author: SergeyGrishin

.gitignore

@@ -3,9 +3,10 @@
 namespace orm\DataBase;
 
 
+use orm\DataBase\fields\Number;
 use orm\DataBase\fields\DateTime;
-use orm\DataBase\fields\ForeignKey;
 use orm\DataBase\fields\PrimaryKey;
+use orm\DataBase\fields\ForeignKey;
 use orm\DataBase\fields\StringField;
 
 
@@ -18,6 +19,23 @@
 class Field
 {
 
+    /**
+     * @param string $type type of number field (int, float, double)
+     * @param int $size size of field
+     * @param string $attribute attribute of field (binary, unsigned)
+     * @param bool $auto_increment, auto_increment flag
+     * @return \orm\DataBase\fields\Number
+     */
+    public static function number($type = "int", $size = 10, $attribute = "", $auto_increment = false)
+    {
+        $obj = new Number();
+        $obj->type = $type;
+        $obj->size = $size;
+        $obj->attribute = $attribute;
+        $obj->auto_increment = $auto_increment;
+        return $obj;
+    }
+
     /**
      * describe PRIMARY KEY with AUTO_INCREMENT
      * @return PrimaryKey

lib/orm/DataBase/Field.php

@@ -45,11 +45,17 @@ public function initTable()
     public function migrate()
     {
         try {
-            (new QueryExecutor(PdoAdapter::getInstance()
-                ->getPdoObject()->prepare(
-                    (new Migration($this->table_fields, $this->table_name))
-                        ->buildMigrationSqlCode()), []))
-                ->executeSql();
+            $generator = $this->getQueryGeneratorInstance();
+            $create_database_query = $generator->createDataBase(QueryMemento::createInstance()->getStorage()["dbname"]);
+            $create_table_query = $generator->createTable($this->table_name, $this->table_fields);
+
+            print_r($create_table_query);
+
+//            (new QueryExecutor(PdoAdapter::getInstance()
+//                ->getPdoObject()->prepare(
+//                    (new Migration($this->table_fields, $this->table_name))
+//                        ->buildMigrationSqlCode()), []))
+//                ->executeSql();
         } catch (\PDOException $e) {
             throw new MigrationException($e->getMessage());
         }

lib/orm/DataBase/Table.php

@@ -0,0 +1,36 @@
+<?php
+
+/**
+ * @TODO: think about merging functional of this class and class PrimaryKey.
+ * @TODO: Create universal class and make 2 children
+ */
+
+
+namespace orm\DataBase\fields;
+
+
+/**
+ * Class Number
+ * @package lib\orm\DataBase\fields
+ */
+class Number
+{
+
+    /**
+     * @var
+     */
+    public $type;
+    /**
+     * @var
+     */
+    public $size;
+    /**
+     * @var
+     */
+    public $attribute;
+    /**
+     * @var
+     */
+    public $auto_increment;
+
+}

lib/orm/DataBase/fields/Number.php

@@ -3,6 +3,12 @@
 namespace orm\Query;
 
 
+use orm\DataBase\fields\DateTime;
+use orm\DataBase\fields\ForeignKey;
+use orm\DataBase\fields\PrimaryKey;
+use orm\DataBase\fields\StringField;
+use orm\Exceptions\MigrationException;
+
 class MysqlQueryGenerator implements QueryGeneratorInterface
 {
 
@@ -46,4 +52,41 @@ public function selectAll($table)
     {
         return $this->pdo->prepare("select * from {$table}");
     }
+
+    public function createDataBase($dbname)
+    {
+        return $this->pdo->prepare("create database if not exists `{$dbname}` default character set utf8 collate" .
+                "utf8_general_ci;\nuse `{$dbname}`;\n");
+    }
+
+    public function createTable($table, $fields)
+    {
+        $query = "set foreign_key_checks = 0;\n";
+        $foreign_keys = "";
+        $query .= "drop table if exists `{$table}`; create table `{$table}` (\n";
+        foreach ($fields as $key => $field) {
+            if ($field instanceof PrimaryKey) {
+                $query .= "`{$key}` {$field->type}({$field->size}) not null primary key auto_increment,\n";
+            } elseif ($field instanceof ForeignKey) {
+                $query .= "`{$key}` int not null,\n";
+                $table = new $field->table();
+                $reflection = new \ReflectionClass($table);
+                $property = $reflection->getProperty("table_name");
+                $property->setAccessible(true);
+                $foreign_keys .= "alter table `{$table}` add constraint `{$key}_fk` foreign key (`{$key}`)" .
+                        " references `{$property->getValue($table)}` (`{$field->field}`) on delete " .
+                        "{$field->on_delete} on update {$field->on_update};\n";
+                $property->setAccessible(false);
+            } elseif ($field instanceof StringField) {
+                $query .= "`{$key}` {$field->type}({$field->size}) not null,\n";
+            } elseif ($field instanceof DateTime) {
+                $query .= "`{$key}` {$field->type} not null,\n";
+            } else {
+                throw new MigrationException("Migration Exception");
+            }
+        }
+        return $this->pdo->prepare(substr($query, 0, -2) . "\n) engine=InnoDB default charset=utf8;\n" .
+                $foreign_keys . "set foreign_key_checks = 1;\n");
+    }
+
 }

lib/orm/Migrations/Migration.php

@@ -1,10 +1,11 @@
 <?php
 
+
 namespace orm\Query;
 
 
 /**
- * Interface QueryGeneratorInterface. Base API for all *QueryGenerator classes
+ * Interface QueryGeneratorInterface
  * @package orm\Query
  */
 interface QueryGeneratorInterface
@@ -41,4 +42,18 @@ public function selectByKeys($table, $keys);
      */
     public function selectAll($table);
 
+    /**
+     * Signature of createDataBase query generator.
+     * @param $dbname string, name of database
+     * @return \PDOStatement, prepared query
+     */
+    public function createDataBase($dbname);
+
+    /**
+     * @param $table string, name of table
+     * @param $fields array of objects \DataBase\fields\* with structure of fields of table
+     * @return \PDOStatement, prepared query
+     */
+    public function createTable($table, $fields);
+
 }