establishConnection('w'); foreach (new LiskMigrationIterator($session_table) as $session) { $id = $session->getID(); echo "Migrating session {$id}...\n"; $old_type = $session->getType(); $new_type = preg_replace('/-.*$/', '', $old_type); if ($old_type !== $new_type) { queryfx( $conn_w, 'UPDATE %T SET type = %s WHERE id = %d', $session_table->getTableName(), $new_type, $id); } } echo "Done.\n";