120 lines
3.7 KiB
PHP
120 lines
3.7 KiB
PHP
<?php
|
|
|
|
declare(strict_types=1);
|
|
|
|
namespace Engelsystem\Migrations;
|
|
|
|
use Engelsystem\Database\Migration\Migration;
|
|
use Illuminate\Database\Eloquent\Collection;
|
|
use Illuminate\Database\Schema\Blueprint;
|
|
use stdClass;
|
|
|
|
/**
|
|
* This migration creates the "questions" table and migrates the existing "Questions" records.
|
|
*/
|
|
class CreateQuestionsTable extends Migration
|
|
{
|
|
use ChangesReferences;
|
|
use Reference;
|
|
|
|
public function up(): void
|
|
{
|
|
$hasPreviousQuestionsTable = $this->schema->hasTable('Questions');
|
|
|
|
if ($hasPreviousQuestionsTable) {
|
|
// Rename because some SQL DBMS handle identifiers case insensitive
|
|
$this->schema->rename('Questions', 'PreviousQuestions');
|
|
}
|
|
|
|
$this->createNewQuestionsTable();
|
|
|
|
if ($hasPreviousQuestionsTable) {
|
|
$this->copyPreviousToNewQuestionsTable();
|
|
$this->changeReferences(
|
|
'PreviousQuestions',
|
|
'QID',
|
|
'questions',
|
|
'id'
|
|
);
|
|
$this->schema->drop('PreviousQuestions');
|
|
}
|
|
}
|
|
|
|
public function down(): void
|
|
{
|
|
// Rename as some SQL DBMS handle identifiers case insensitive
|
|
$this->schema->rename('questions', 'new_questions');
|
|
|
|
$this->createPreviousQuestionsTable();
|
|
$this->copyNewToPreviousQuestionsTable();
|
|
$this->changeReferences(
|
|
'new_questions',
|
|
'id',
|
|
'Questions',
|
|
'QID'
|
|
);
|
|
|
|
$this->schema->drop('new_questions');
|
|
}
|
|
|
|
private function createNewQuestionsTable(): void
|
|
{
|
|
$this->schema->create('questions', function (Blueprint $table): void {
|
|
$table->increments('id');
|
|
$this->referencesUser($table);
|
|
$table->text('text');
|
|
$table->text('answer')->nullable();
|
|
$this->references($table, 'users', 'answerer_id')->nullable();
|
|
});
|
|
}
|
|
|
|
private function copyPreviousToNewQuestionsTable(): void
|
|
{
|
|
$connection = $this->schema->getConnection();
|
|
/** @var stdClass[] $previousQuestionsRecords */
|
|
$previousQuestionsRecords = $connection
|
|
->table('PreviousQuestions')
|
|
->get();
|
|
|
|
foreach ($previousQuestionsRecords as $previousQuestionRecord) {
|
|
$connection->table('questions')->insert([
|
|
'id' => $previousQuestionRecord->QID,
|
|
'user_id' => $previousQuestionRecord->UID,
|
|
'text' => $previousQuestionRecord->Question,
|
|
'answerer_id' => $previousQuestionRecord->AID,
|
|
'answer' => $previousQuestionRecord->Answer,
|
|
]);
|
|
}
|
|
}
|
|
|
|
private function createPreviousQuestionsTable(): void
|
|
{
|
|
$this->schema->create('Questions', function (Blueprint $table): void {
|
|
$table->increments('QID');
|
|
$this->references($table, 'users', 'UID');
|
|
$table->text('Question');
|
|
$this->references($table, 'users', 'AID')->nullable();
|
|
$table->text('Answer')->nullable();
|
|
});
|
|
}
|
|
|
|
private function copyNewToPreviousQuestionsTable(): void
|
|
{
|
|
$connection = $this->schema->getConnection();
|
|
/** @var Collection|stdClass[] $questionRecords */
|
|
$questionRecords = $connection
|
|
->table('new_questions')
|
|
->get();
|
|
|
|
foreach ($questionRecords as $questionRecord) {
|
|
$connection->table('Questions')->insert([
|
|
'QID' => $questionRecord->id,
|
|
'UID' => $questionRecord->user_id,
|
|
'Question' => $questionRecord->text,
|
|
'AID' => $questionRecord->answerer_id,
|
|
'Answer' => $questionRecord->answer,
|
|
]);
|
|
}
|
|
}
|
|
}
|