bug: Column was not escaped for clause REPLACE ROW DELETION POLICY (#…

…125)
colopl · Aug 1, 2023 · 5c89cc6 · 5c89cc6
1 parent 8efa875
commit 5c89cc6
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 2 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -13,6 +13,7 @@ Changed
 
 Fixed
 - Transaction state was not being cleared if rolled back failed. (#107)
+- Column was not escaped for clause `REPLACE ROW DELETION POLICY` (#125)
 
 # v5.1.0
 

diff --git a/src/Schema/Grammar.php b/src/Schema/Grammar.php
@@ -144,7 +144,9 @@ public function compileReplaceRowDeletionPolicy(Blueprint $blueprint, Fluent $co
         if ($command->policy !== 'olderThan') {
             throw new RuntimeException('Unknown deletion policy:'.$command->policy);
         }
-        return "alter table {$this->wrapTable($blueprint)} replace row deletion policy (older_than({$command->column}, interval {$command->days} day))";
+        $table = $this->wrapTable($blueprint);
+        $column = $this->wrap($command->column);
+        return "alter table {$table} replace row deletion policy (older_than({$column}, interval {$command->days} day))";
     }
 
     /**

diff --git a/tests/Schema/BlueprintTest.php b/tests/Schema/BlueprintTest.php
@@ -330,7 +330,7 @@ public function test_replace_row_deletion_policy(): void
         $statement = $blueprint2->toSql($conn, $grammar)[0];
 
         self::assertEquals(
-            "alter table `{$table}` replace row deletion policy (older_than(t, interval 200 day))",
+            "alter table `{$table}` replace row deletion policy (older_than(`t`, interval 200 day))",
             $statement,
         );
     }