Skip to content

Commit 7745b25

Browse files
committed
Fix mysql id
1 parent af06e5a commit 7745b25

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/WorkerJS/PHPClient/MySQLTaskStore.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ public function __construct($client){
2020
}
2121

2222
public function getTask($taskID){
23-
$result = mysqli_query($this->connection, "SELECT `task` FROM `tasks` WHERE `taskID` = ".intval($taskID));
23+
$result = mysqli_query($this->connection, "SELECT `task` FROM `tasks` WHERE `taskID` = '".mysqli_real_escape_string($this->connection, $taskID)."'");
2424

2525
if(mysqli_num_rows($result) === 0){
2626
throw new \Exception("Task $taskID not found.");
@@ -31,6 +31,6 @@ public function getTask($taskID){
3131
}
3232

3333
public function setTask($taskID, Task $task){
34-
mysqli_query($this->connection, "INSERT INTO `tasks` (`taskID`, `task`) VALUES (".intval($taskID).", '".mysqli_real_escape_string($this->connection, json_encode($task->getTask()))."')");
34+
mysqli_query($this->connection, "INSERT INTO `tasks` (`taskID`, `task`) VALUES ('".mysqli_real_escape_string($this->connection, $taskID)."', '".mysqli_real_escape_string($this->connection, json_encode($task->getTask()))."')");
3535
}
3636
}

0 commit comments

Comments
 (0)