1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
|
<?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 news_comments table and copies the existing NewsComments table records to the new one.
*/
class CreateNewsCommentsTable extends Migration
{
use ChangesReferences;
use Reference;
/**
* Creates the news_comments table, copies the data and drops the NewsComments table.
*/
public function up(): void
{
$this->createNewNewsCommentsTable();
if ($this->schema->hasTable('NewsComments')) {
$this->copyPreviousToNewNewsCommentsTable();
$this->changeReferences(
'NewsComments',
'ID',
'news_comments',
'id',
'unsignedInteger'
);
$this->schema->drop('NewsComments');
}
}
/**
* Recreates the previous NewsComments table, copies back the data and drops the new news_comments table.
*/
public function down(): void
{
$this->createPreviousNewsCommentsTable();
$this->copyNewToPreviousNewsCommentsTable();
$this->changeReferences(
'news_comments',
'id',
'NewsComments',
'ID',
'unsignedInteger'
);
$this->schema->drop('news_comments');
}
/**
* @return void
*/
private function createNewNewsCommentsTable(): void
{
$this->schema->create('news_comments', function (Blueprint $table) {
$table->increments('id');
$this->references($table, 'news', 'news_id');
$table->text('text');
$this->referencesUser($table);
$table->timestamps();
});
}
/**
* @return void
*/
private function copyPreviousToNewNewsCommentsTable(): void
{
$connection = $this->schema->getConnection();
/** @var stdClass[] $previousNewsCommentsRecords */
$previousNewsCommentsRecords = $connection
->table('NewsComments')
->get();
foreach ($previousNewsCommentsRecords as $previousNewsComment) {
$connection->table('news_comments')->insert([
'id' => $previousNewsComment->ID,
'news_id' => $previousNewsComment->Refid,
'text' => $previousNewsComment->Text,
'user_id' => $previousNewsComment->UID,
'created_at' => $previousNewsComment->Datum,
'updated_at' => $previousNewsComment->Datum,
]);
}
}
/**
* @return void
*/
private function createPreviousNewsCommentsTable(): void
{
$this->schema->create('NewsComments', function (Blueprint $table) {
$table->increments('ID');
$this->references($table, 'news', 'Refid');
$table->dateTime('Datum');
$table->text('Text');
$this->references($table, 'users', 'UID');
});
}
/**
* @return void
*/
private function copyNewToPreviousNewsCommentsTable(): void
{
$connection = $this->schema->getConnection();
/** @var Collection|stdClass[] $newsCommentsRecords */
$newsCommentsRecords = $connection
->table('news_comments')
->get();
foreach ($newsCommentsRecords as $newsCommentRecord) {
$connection->table('NewsComments')->insert([
'ID' => $newsCommentRecord->id,
'Datum' => $newsCommentRecord->created_at,
'Refid' => $newsCommentRecord->news_id,
'Text' => $newsCommentRecord->text,
'UID' => $newsCommentRecord->user_id,
]);
}
}
}
|
