@@ -33,32 +33,32 @@ public function run($request)
33
33
$ schema = DataObject::getSchema ();
34
34
35
35
foreach ($ this ->tables as $ db ) {
36
+ $ table = $ schema ->tableName ($ db );
36
37
$ columns = $ schema ->databaseFields ($ db );
37
- $ query = "SHOW COLUMNS FROM $ db " ;
38
+ $ query = "SHOW COLUMNS FROM $ table " ;
38
39
$ liveColumns = DB ::query ($ query )->column ();
39
- $ backedUp = 0 ;
40
- $ query = "SHOW TABLES LIKE 'Backup_ $ db' " ;
40
+ $ query = "SHOW TABLES LIKE 'Backup_ $ table' " ;
41
41
$ tableExists = DB ::query ($ query )->value ();
42
42
if ($ tableExists != null ) {
43
- echo "Tasks run already on $ db exiting " ;
43
+ echo "Tasks run already on $ table exiting " ;
44
44
return ;
45
45
}
46
- $ backedUp = 0 ;
47
- foreach ($ liveColumns as $ index => $ column ) {
48
- if ($ backedUp == 0 ) {
49
- echo "Backing up $ db <br /> " ;
50
- echo "Creating Backup_ $ db <br /> " ;
46
+ $ backedUp = false ;
47
+ foreach ($ liveColumns as $ column ) {
48
+ if (! $ backedUp ) {
49
+ echo "Backing up $ table <br /> " ;
50
+ echo "Creating Backup_ $ table <br /> " ;
51
51
// backup table
52
- $ query = "CREATE TABLE Backup_ $ db LIKE $ db " ;
52
+ $ query = "CREATE TABLE Backup_ $ table LIKE $ table " ;
53
53
DB ::query ($ query );
54
- echo "Populating Backup_ $ db <br /> " ;
55
- $ query = "INSERT Backup_ $ db SELECT * FROM $ db " ;
54
+ echo "Populating Backup_ $ table <br /> " ;
55
+ $ query = "INSERT Backup_ $ table SELECT * FROM $ table " ;
56
56
DB ::query ($ query );
57
- $ backedUp = 1 ;
57
+ $ backedUp = true ;
58
58
}
59
59
if (!isset ($ columns [$ column ]) && !in_array ($ column , $ this ->keepColumns ?? [])) {
60
- echo "Dropping $ column from $ db <br /> " ;
61
- $ query = "ALTER TABLE $ db DROP COLUMN $ column " ;
60
+ echo "Dropping $ column from $ table <br /> " ;
61
+ $ query = "ALTER TABLE $ table DROP COLUMN $ column " ;
62
62
DB ::query ($ query );
63
63
}
64
64
}
0 commit comments