fk support removed

Author: krowinski

src/MySQLReplication/Event/RowEvent/Columns.php

@@ -35,14 +35,7 @@ public static function parse($columnType, array $columnSchema, BinaryDataReader
         self::$field['unsigned'] = !(stripos($columnSchema['COLUMN_TYPE'], 'unsigned') === false);
         self::$field['type_is_bool'] = false;
         self::$field['is_primary'] = $columnSchema['COLUMN_KEY'] === 'PRI';
-        self::$field['is_foreign'] = null !== $columnSchema['REFERENCED_TABLE_NAME'] && null !== $columnSchema['REFERENCED_COLUMN_NAME'];
-
-        if (self::$field['is_foreign'])
-        {
-            self::$field['referenced_table_name'] = $columnSchema['REFERENCED_TABLE_NAME'];
-            self::$field['referenced_column_name'] = $columnSchema['REFERENCED_COLUMN_NAME'];
-        }
-
+        
         if (self::$field['type'] === ConstFieldType::VARCHAR)
         {
             self::$field['max_length'] = $binaryDataReader->readInt16();

src/MySQLReplication/Event/RowEvent/RowEvent.php

@@ -161,9 +161,7 @@ public function makeTableMapDTO()
                         'CHARACTER_SET_NAME' => null,
                         'COLUMN_COMMENT' => null,
                         'COLUMN_TYPE' => 'BLOB',
-                        'COLUMN_KEY' => '',
-                        'REFERENCED_TABLE_NAME' => '',
-                        'REFERENCED_COLUMN_NAME' => '',
+                        'COLUMN_KEY' => ''
                     ];
 
                     $type = ConstFieldType::IGNORE;

src/MySQLReplication/Repository/MySQLRepository.php

@@ -34,28 +34,18 @@ public function getFields($schema, $table)
     {
         $sql = '
              SELECT
-                c.`COLUMN_NAME`,
-                c.`COLLATION_NAME`,
-                c.`CHARACTER_SET_NAME`,
-                c.`COLUMN_COMMENT`,
-                c.`COLUMN_TYPE`,
-                c.`COLUMN_KEY`,
-                `kcu`.`REFERENCED_TABLE_NAME`,
-                `kcu`.`REFERENCED_COLUMN_NAME`
+                `COLUMN_NAME`,
+                `COLLATION_NAME`,
+                `CHARACTER_SET_NAME`,
+                `COLUMN_COMMENT`,
+                `COLUMN_TYPE`,
+                `COLUMN_KEY`
             FROM
-                `information_schema`.`COLUMNS`   c
-            LEFT JOIN
-                `information_schema`.KEY_COLUMN_USAGE kcu
-            ON
-                    c.`TABLE_SCHEMA` = kcu.`TABLE_SCHEMA`
-                AND
-                    c.`TABLE_NAME` = kcu.`TABLE_NAME`
-                AND
-                    c.`COLUMN_NAME` = kcu.`COLUMN_NAME`
+                `information_schema`.`COLUMNS`
             WHERE
-                    c.`TABLE_SCHEMA` = ?
+                    `TABLE_SCHEMA` = ?
                 AND
-                    c.`TABLE_NAME` = ?
+                    `TABLE_NAME` = ?
        ';
 
         return $this->getConnection()->fetchAll($sql, [$schema, $table]);