20171009115032_drop_objects_entity_table.php

Go to the documentation of this file.

<?php

use Phinx\Migration\AbstractMigration;

class DropObjectsEntityTable extends AbstractMigration {
    public function up() {

        if (!$this->hasTable('objects_entity') || !$this->hasTable('metadata')) {
            return;
        }

        $prefix = $this->getAdapter()->getOption('table_prefix');
        $cols = ['title', 'description'];
        $col_names = "'" . implode("', '", $cols) . "'";
        
        $objects_query = "SELECT * FROM {$prefix}objects_entity LIMIT 100";
        while ($rows = $this->fetchAll($objects_query)) {
            $guids = [];
            foreach ($rows as $row) {
                $guids[] = $row['guid'];
            }
            
            $guids = implode(',', $guids);
            
            // remove existing metadata... attributes are more important
            $this->execute("
                DELETE FROM {$prefix}metadata
                WHERE entity_guid IN ({$guids}) AND
                name IN ({$col_names})
            ");
            
            $new_metadata_rows = [];
            foreach ($rows as $row) {
                foreach ($cols as $col) {
                    $value = $row[$col];
                    if (is_null($value) || $value === '') {
                        continue;
                    }
                    
                    $new_metadata_rows[] = [
                        'entity_guid' => $row['guid'],
                        'name' => $col,
                        'value' => $value,
                        'value_type' => 'text',
                        'owner_guid' => 0,
                        'access_id' => 2,
                        'time_created' => time(),
                        'enabled' => 'yes',
                    ];
                }
            }
            
            if (!empty($new_metadata_rows)) {
                $this->table('metadata')->insert($new_metadata_rows)->saveData();
            }
            
            // remove from objects so it does not get processed again in the next while loop
            $this->execute("
                DELETE FROM {$prefix}objects_entity
                WHERE guid IN ({$guids})
            ");
        }
        
        // all data migrated, so drop the table
        $this->table('objects_entity')->drop()->save();
    }
}